org.apache.paimon.flink.predicate

Class SimpleSqlPredicateConvertor

java.lang.Object

org.apache.paimon.flink.predicate.SimpleSqlPredicateConvertor

public class SimpleSqlPredicateConvertor
extends Object

convert sql to predicate.

Constructor Summary

Constructors

Constructor and Description
SimpleSqlPredicateConvertor(RowType type)

Method Summary

Modifier and Type	Method and Description
Predicate	convert(Object sqlBasicCall)
Predicate	convertSqlToPredicate(String whereSql)
int	getFieldIndex(String field)
Predicate	visitBiFunction(Object left, Object right, java.util.function.BiFunction<Integer,Object,Predicate> visitLeft, java.util.function.BiFunction<Integer,Object,Predicate> visitRight)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSqlPredicateConvertor

public SimpleSqlPredicateConvertor(RowType type)
                            throws Exception

Throws:

Exception

Method Detail

convertSqlToPredicate

public Predicate convertSqlToPredicate(String whereSql)
                                throws Exception

Throws:

Exception

convert

public Predicate convert(Object sqlBasicCall)
                  throws Exception

Throws:

Exception

visitBiFunction

public Predicate visitBiFunction(Object left,
                                 Object right,
                                 java.util.function.BiFunction<Integer,Object,Predicate> visitLeft,
                                 java.util.function.BiFunction<Integer,Object,Predicate> visitRight)
                          throws Exception

Throws:

Exception

getFieldIndex

public int getFieldIndex(String field)