Package org.apache.iceberg.flink

Class FlinkFilters

java.lang.Object

org.apache.iceberg.flink.FlinkFilters

public class FlinkFilters
extends Object

Method Summary

Modifier and Type	Method	Description
static Optional<Expression>	convert(org.apache.flink.table.expressions.Expression flinkExpression)	Convert flink expression to iceberg expression.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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