Package org.apache.iceberg.flink
Class FlinkFilters
- java.lang.Object
-
- org.apache.iceberg.flink.FlinkFilters
-
public class FlinkFilters extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.util.Optional<Expression>
convert(org.apache.flink.table.expressions.Expression flinkExpression)
Convert flink expression to iceberg expression.
-
-
-
Method Detail
-
convert
public static java.util.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
-
-