org.apache.flink.orc

Class OrcRowSplitReader

java.lang.Object

org.apache.flink.orc.OrcSplitReader<Row>

org.apache.flink.orc.OrcRowSplitReader

All Implemented Interfaces:

Closeable, AutoCloseable

public class OrcRowSplitReader
extends OrcSplitReader<Row>

OrcSplitReader to read ORC files into Row.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.orc.OrcSplitReader

OrcSplitReader.Between, OrcSplitReader.Equals, OrcSplitReader.In, OrcSplitReader.IsNull, OrcSplitReader.LessThan, OrcSplitReader.LessThanEquals, OrcSplitReader.Not, OrcSplitReader.NullSafeEquals, OrcSplitReader.Or, OrcSplitReader.Predicate

Field Summary

Fields inherited from class org.apache.flink.orc.OrcSplitReader

nextRow, rowBatch

Constructor Summary

Constructors

Constructor and Description
OrcRowSplitReader(Configuration conf, org.apache.orc.TypeDescription schema, int[] selectedFields, List<OrcSplitReader.Predicate> conjunctPredicates, int batchSize, Path path, long splitStart, long splitLength)

Method Summary

Modifier and Type	Method and Description
protected int	fillRows() Fills an ORC batch into an array of Row.
Row	nextRecord(Row reuse) Reads the next record from the input.

Methods inherited from class org.apache.flink.orc.OrcSplitReader

close, getRecordReader, reachedEnd

Methods inherited from class java.lang.Object

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

Constructor Detail

OrcRowSplitReader

public OrcRowSplitReader(Configuration conf,
                         org.apache.orc.TypeDescription schema,
                         int[] selectedFields,
                         List<OrcSplitReader.Predicate> conjunctPredicates,
                         int batchSize,
                         Path path,
                         long splitStart,
                         long splitLength)
                  throws IOException

Throws:

IOException

Method Detail

fillRows

protected int fillRows()

Description copied from class: OrcSplitReader

Fills an ORC batch into an array of Row.

Specified by:

fillRows in class OrcSplitReader<Row>

Returns:

The number of rows that were filled.

nextRecord

public Row nextRecord(Row reuse)

Description copied from class: OrcSplitReader

Reads the next record from the input.

Specified by:

nextRecord in class OrcSplitReader<Row>

Parameters:

reuse - Object that may be reused.

Returns:

Read record.