Uses of Interface
org.apache.flink.orc.shim.OrcShim
-
Packages that use OrcShim Package Description org.apache.flink.orc org.apache.flink.orc.shim -
-
Uses of OrcShim in org.apache.flink.orc
Fields in org.apache.flink.orc declared as OrcShim Modifier and Type Field Description protected OrcShim<BatchT>AbstractOrcFileInputFormat. shimMethods in org.apache.flink.orc with parameters of type OrcShim Modifier and Type Method Description static <SplitT extends org.apache.flink.connector.file.src.FileSourceSplit>
OrcColumnarRowInputFormat<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch,SplitT>OrcColumnarRowInputFormat. createPartitionedFormat(OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch> shim, org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.flink.table.types.logical.RowType tableType, List<String> partitionKeys, org.apache.flink.connector.file.table.PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, java.util.function.Function<org.apache.flink.table.types.logical.RowType,org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData>> rowTypeInfoFactory)Create a partitionedOrcColumnarRowInputFormat, the partition columns can be generated by split.Constructors in org.apache.flink.orc with parameters of type OrcShim 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)OrcColumnarRowFileInputFormat(OrcShim shim, org.apache.hadoop.conf.Configuration hadoopConfig, org.apache.orc.TypeDescription schema, int[] selectedFields, List conjunctPredicates, int batchSize, ColumnBatchFactory batchFactory, org.apache.flink.api.common.typeinfo.TypeInformation producedTypeInfo)Deprecated.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)OrcVectorizedReader(OrcShim<BatchT> shim, org.apache.orc.RecordReader orcReader, org.apache.flink.connector.file.src.util.Pool<AbstractOrcFileInputFormat.OrcReaderBatch<T,BatchT>> pool) -
Uses of OrcShim in org.apache.flink.orc.shim
Classes in org.apache.flink.orc.shim that implement OrcShim Modifier and Type Class Description classOrcShimV200Shim orc for Hive version 2.0.0 and upper versions.classOrcShimV210Shim orc for Hive version 2.1.0 and upper versions.classOrcShimV230Shim orc for Hive version 2.1.0 and upper versions.Methods in org.apache.flink.orc.shim that return OrcShim Modifier and Type Method Description static OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>OrcShim. createShim(String hiveVersion)Create shim from hive version.static OrcShim<org.apache.hadoop.hive.ql.exec.vector.VectorizedRowBatch>OrcShim. defaultShim()Default with orc dependent, we should use v2.3.0.
-