Class FlinkFilters

java.lang.Object
org.apache.iceberg.flink.FlinkFilters

public class FlinkFilters extends Object
  • 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