Package org.apache.flink.orc.nohive

Class OrcNoHiveSplitReaderUtil

java.lang.Object

org.apache.flink.orc.nohive.OrcNoHiveSplitReaderUtil

public class OrcNoHiveSplitReaderUtil
extends Object

Util for generating OrcSplitReader.

Constructor Summary

Constructors

Constructor	Description
OrcNoHiveSplitReaderUtil()

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.orc.OrcColumnarRowSplitReader<?>	genPartColumnarRowReader(org.apache.hadoop.conf.Configuration conf, String[] fullFieldNames, org.apache.flink.table.types.DataType[] fullFieldTypes, Map<String,Object> partitionSpec, int[] selectedFields, List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates, int batchSize, org.apache.flink.core.fs.Path path, long splitStart, long splitLength)	Util for generating partitioned OrcColumnarRowSplitReader.

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcNoHiveSplitReaderUtil

public OrcNoHiveSplitReaderUtil()

Method Detail

genPartColumnarRowReader

public static org.apache.flink.orc.OrcColumnarRowSplitReader<?> genPartColumnarRowReader(org.apache.hadoop.conf.Configuration conf,
                                                                                         String[] fullFieldNames,
                                                                                         org.apache.flink.table.types.DataType[] fullFieldTypes,
                                                                                         Map<String,Object> partitionSpec,
                                                                                         int[] selectedFields,
                                                                                         List<org.apache.flink.orc.OrcFilters.Predicate> conjunctPredicates,
                                                                                         int batchSize,
                                                                                         org.apache.flink.core.fs.Path path,
                                                                                         long splitStart,
                                                                                         long splitLength)
                                                                                  throws IOException

Util for generating partitioned OrcColumnarRowSplitReader.

Throws:

IOException