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 and Description
OrcNoHiveSplitReaderUtil()

Method Summary

Modifier and Type	Method and Description
static OrcColumnarRowSplitReader<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch>	genPartColumnarRowReader(Configuration conf, String[] fullFieldNames, DataType[] fullFieldTypes, Map<String,Object> partitionSpec, int[] selectedFields, List<OrcFilters.Predicate> conjunctPredicates, int batchSize, 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 OrcColumnarRowSplitReader<org.apache.orc.storage.ql.exec.vector.VectorizedRowBatch> genPartColumnarRowReader(Configuration conf,
                                                                                                                           String[] fullFieldNames,
                                                                                                                           DataType[] fullFieldTypes,
                                                                                                                           Map<String,Object> partitionSpec,
                                                                                                                           int[] selectedFields,
                                                                                                                           List<OrcFilters.Predicate> conjunctPredicates,
                                                                                                                           int batchSize,
                                                                                                                           Path path,
                                                                                                                           long splitStart,
                                                                                                                           long splitLength)
                                                                                                                    throws IOException

Util for generating partitioned OrcColumnarRowSplitReader.

Throws:

IOException