org.apache.paimon.flink

Class PredicateConverter

java.lang.Object

org.apache.paimon.flink.PredicateConverter

All Implemented Interfaces:

org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

public class PredicateConverter
extends Object
implements org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

Convert Expression to Predicate.

For FieldReferenceExpression, please use name instead of index, if the project pushdown is before and the filter pushdown is after, the index of the filter will be projected.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PredicateConverter.UnsupportedExpression Encounter an unsupported expression, the caller can choose to ignore this filter branch.

Constructor Summary

Constructors

Constructor and Description
PredicateConverter(PredicateBuilder builder)
PredicateConverter(org.apache.flink.table.types.logical.RowType type)

Method Summary

Modifier and Type	Method and Description
static Optional<Predicate>	convert(org.apache.flink.table.types.logical.RowType rowType, org.apache.flink.table.expressions.ResolvedExpression filter) Try best to convert a ResolvedExpression to Predicate.
Predicate	visit(org.apache.flink.table.expressions.CallExpression call)
Predicate	visit(org.apache.flink.table.expressions.Expression expression)
Predicate	visit(org.apache.flink.table.expressions.FieldReferenceExpression fieldReferenceExpression)
Predicate	visit(org.apache.flink.table.expressions.TypeLiteralExpression typeLiteralExpression)
Predicate	visit(org.apache.flink.table.expressions.ValueLiteralExpression valueLiteralExpression)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.expressions.ExpressionVisitor

visit

Constructor Detail

PredicateConverter

public PredicateConverter(org.apache.flink.table.types.logical.RowType type)

PredicateConverter

public PredicateConverter(PredicateBuilder builder)

Method Detail

visit

public Predicate visit(org.apache.flink.table.expressions.CallExpression call)

Specified by:

visit in interface org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

visit

public Predicate visit(org.apache.flink.table.expressions.ValueLiteralExpression valueLiteralExpression)

Specified by:

visit in interface org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

visit

public Predicate visit(org.apache.flink.table.expressions.FieldReferenceExpression fieldReferenceExpression)

Specified by:

visit in interface org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

visit

public Predicate visit(org.apache.flink.table.expressions.TypeLiteralExpression typeLiteralExpression)

Specified by:

visit in interface org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

visit

public Predicate visit(org.apache.flink.table.expressions.Expression expression)

Specified by:

visit in interface org.apache.flink.table.expressions.ExpressionVisitor<Predicate>

convert

public static Optional<Predicate> convert(org.apache.flink.table.types.logical.RowType rowType,
                                          org.apache.flink.table.expressions.ResolvedExpression filter)

Try best to convert a ResolvedExpression to Predicate.

Parameters:

filter - a resolved expression

Returns:

Predicate if no PredicateConverter.UnsupportedExpression thrown.