Package org.apache.flink.orc

Class OrcFilters

java.lang.Object

org.apache.flink.orc.OrcFilters

public class OrcFilters
extends Object

Utility class that provides helper methods to work with Orc Filter PushDown.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	OrcFilters.And	An AND predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.Between	An BETWEEN predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.Equals	An EQUALS predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.In	An IN predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.IsNull	An IS_NULL predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.LessThan	A LESS_THAN predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.LessThanEquals	A LESS_THAN_EQUALS predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.Not	A NOT predicate to negate a predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.NullSafeEquals	An EQUALS predicate that can be evaluated with Null safety by the OrcInputFormat.
static class	OrcFilters.Or	An OR predicate that can be evaluated by the OrcInputFormat.
static class	OrcFilters.Predicate	A filter predicate that can be evaluated by the OrcInputFormat.

Constructor Summary

Constructors

Constructor	Description
OrcFilters()

Method Summary

Modifier and Type	Method	Description
static OrcFilters.Predicate	convertBinary(org.apache.flink.table.expressions.CallExpression callExp, org.apache.flink.util.function.TriFunction<String,org.apache.hadoop.hive.ql.io.sarg.PredicateLeaf.Type,Serializable,OrcFilters.Predicate> func, org.apache.flink.util.function.TriFunction<String,org.apache.hadoop.hive.ql.io.sarg.PredicateLeaf.Type,Serializable,OrcFilters.Predicate> reverseFunc)
static OrcFilters.Predicate	toOrcPredicate(org.apache.flink.table.expressions.Expression expression)

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcFilters

public OrcFilters()

Method Detail

convertBinary

public static OrcFilters.Predicate convertBinary(org.apache.flink.table.expressions.CallExpression callExp,
                                                 org.apache.flink.util.function.TriFunction<String,org.apache.hadoop.hive.ql.io.sarg.PredicateLeaf.Type,Serializable,OrcFilters.Predicate> func,
                                                 org.apache.flink.util.function.TriFunction<String,org.apache.hadoop.hive.ql.io.sarg.PredicateLeaf.Type,Serializable,OrcFilters.Predicate> reverseFunc)

toOrcPredicate

public static OrcFilters.Predicate toOrcPredicate(org.apache.flink.table.expressions.Expression expression)