org.apache.flink.orc.nohive

Class OrcNoHiveColumnarRowInputFormat

java.lang.Object

org.apache.flink.orc.nohive.OrcNoHiveColumnarRowInputFormat

public class OrcNoHiveColumnarRowInputFormat
extends Object

Helper class to create OrcColumnarRowInputFormat for no-hive.

Method Summary

Modifier and Type

Method and Description

static <SplitT extends FileSourceSplit> OrcColumnarRowInputFormat<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,SplitT>

createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig, RowType tableType, List<String> partitionKeys, PartitionFieldExtractor<SplitT> extractor, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, java.util.function.Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory) Create a partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.

Methods inherited from class java.lang.Object

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

Method Detail

createPartitionedFormat

public static <SplitT extends FileSourceSplit> OrcColumnarRowInputFormat<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch,SplitT> createPartitionedFormat(org.apache.hadoop.conf.Configuration hadoopConfig,
                                                                                                                                                                  RowType tableType,
                                                                                                                                                                  List<String> partitionKeys,
                                                                                                                                                                  PartitionFieldExtractor<SplitT> extractor,
                                                                                                                                                                  int[] selectedFields,
                                                                                                                                                                  List<OrcFilters.Predicate> conjunctPredicates,
                                                                                                                                                                  int batchSize,
                                                                                                                                                                  java.util.function.Function<RowType,TypeInformation<RowData>> rowTypeInfoFactory)

Create a partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.