Package 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	Description
static <SplitT extends org.apache.flink.connector.file.src.FileSourceSplit> org.apache.flink.orc.OrcColumnarRowInputFormat<?,SplitT>	createPartitionedFormat(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<org.apache.flink.orc.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 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 org.apache.flink.connector.file.src.FileSourceSplit> org.apache.flink.orc.OrcColumnarRowInputFormat<?,SplitT> createPartitionedFormat(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<org.apache.flink.orc.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 partitioned OrcColumnarRowInputFormat, the partition columns can be generated by split.