Uses of Class
org.apache.flink.orc.OrcFilters.Predicate

Packages that use OrcFilters.Predicate

Package	Description
org.apache.flink.orc
org.apache.flink.orc.shim

Uses of OrcFilters.Predicate in org.apache.flink.orc

Subclasses of OrcFilters.Predicate in org.apache.flink.orc

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.

Fields in org.apache.flink.orc with type parameters of type OrcFilters.Predicate

Modifier and Type	Field	Description
protected List<OrcFilters.Predicate>	AbstractOrcFileInputFormat.conjunctPredicates

Methods in org.apache.flink.orc that return OrcFilters.Predicate

Modifier and Type	Method	Description
protected OrcFilters.Predicate	OrcFilters.Not.child()
static OrcFilters.Predicate	OrcFilters.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	OrcFilters.toOrcPredicate(org.apache.flink.table.expressions.Expression expression)

Methods in org.apache.flink.orc that return types with arguments of type OrcFilters.Predicate

Modifier and Type	Method	Description
protected Iterable<OrcFilters.Predicate>	OrcFilters.Or.children()

Method parameters in org.apache.flink.orc with type arguments of type OrcFilters.Predicate

Modifier and Type	Method	Description
static OrcFilters.Predicate	OrcFilters.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 OrcColumnarRowSplitReader<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>	OrcSplitReaderUtil.genPartColumnarRowReader(String hiveVersion, org.apache.hadoop.conf.Configuration conf, String[] fullFieldNames, org.apache.flink.table.types.DataType[] fullFieldTypes, Map<String,Object> partitionSpec, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)	Util for generating partitioned OrcColumnarRowSplitReader.

Constructors in org.apache.flink.orc with parameters of type OrcFilters.Predicate

Constructor	Description
And(OrcFilters.Predicate... predicates)	Creates an AND predicate.
Not(OrcFilters.Predicate predicate)	Creates a NOT predicate.
Or(OrcFilters.Predicate... predicates)	Creates an OR predicate.

Constructor parameters in org.apache.flink.orc with type arguments of type OrcFilters.Predicate

Constructor	Description
AbstractOrcFileInputFormat(OrcShim<BatchT> shim, org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize)
OrcColumnarRowInputFormat(OrcShim<BatchT> shim, org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, ColumnBatchFactory<BatchT,SplitT> batchFactory, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> producedTypeInfo)
OrcColumnarRowSplitReader(OrcShim<BATCH> shim, org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, OrcColumnarRowSplitReader.ColumnBatchGenerator<BATCH> batchGenerator, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)
OrcSplitReader(OrcShim<BATCH> shim, org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)

Uses of OrcFilters.Predicate in org.apache.flink.orc.shim

Method parameters in org.apache.flink.orc.shim with type arguments of type OrcFilters.Predicate

Modifier and Type	Method	Description
org.apache.orc.RecordReader	OrcShim.createRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)	Create orc RecordReader from conf, schema and etc...
org.apache.orc.RecordReader	OrcShimV200.createRecordReader(org.apache.hadoop.conf.Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)