Package org.apache.iceberg.flink
Class FlinkFilters
java.lang.Object
org.apache.iceberg.flink.FlinkFilters
-
Method Summary
Modifier and TypeMethodDescriptionstatic Optional<Expression>
convert
(org.apache.flink.table.expressions.Expression flinkExpression) Convert flink expression to iceberg expression.
-
Method Details
-
convert
public static Optional<Expression> convert(org.apache.flink.table.expressions.Expression flinkExpression) Convert flink expression to iceberg expression.the BETWEEN, NOT_BETWEEN, IN expression will be converted by flink automatically. the BETWEEN will be converted to (GT_EQ AND LT_EQ), the NOT_BETWEEN will be converted to (LT_EQ OR GT_EQ), the IN will be converted to OR, so we do not add the conversion here
- Parameters:
flinkExpression
- the flink expression- Returns:
- the iceberg expression
-