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 classOrcFilters.AndAn AND predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.BetweenAn BETWEEN predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.EqualsAn EQUALS predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.InAn IN predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.IsNullAn IS_NULL predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.LessThanA LESS_THAN predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.LessThanEqualsA LESS_THAN_EQUALS predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.NotA NOT predicate to negate a predicate that can be evaluated by the OrcInputFormat.static classOrcFilters.NullSafeEqualsAn EQUALS predicate that can be evaluated with Null safety by the OrcInputFormat.static classOrcFilters.OrAn 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. conjunctPredicatesMethods in org.apache.flink.orc that return OrcFilters.Predicate Modifier and Type Method Description protected OrcFilters.PredicateOrcFilters.Not. child()static OrcFilters.PredicateOrcFilters. 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.PredicateOrcFilters. 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.PredicateOrcFilters. 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 partitionedOrcColumnarRowSplitReader.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.RecordReaderOrcShim. 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 orcRecordReaderfrom conf, schema and etc...org.apache.orc.RecordReaderOrcShimV200. 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)
-