org.apache.iceberg.flink

Class FlinkFilters

java.lang.Object

org.apache.iceberg.flink.FlinkFilters

public class FlinkFilters
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static java.util.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 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