Module org.apache.arrow.adapter.orc

Package org.apache.arrow.adapter.orc

Class OrcStripeReader

java.lang.Object

org.apache.arrow.vector.ipc.ArrowReader

org.apache.arrow.adapter.orc.OrcStripeReader

All Implemented Interfaces:

AutoCloseable, DictionaryProvider

public class OrcStripeReader
extends ArrowReader

Orc stripe that load data into ArrowRecordBatch.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.vector.dictionary.DictionaryProvider

DictionaryProvider.MapDictionaryProvider

Field Summary

Fields inherited from class org.apache.arrow.vector.ipc.ArrowReader

allocator, dictionaries

Method Summary

Modifier and Type	Method	Description
long	bytesRead()	Return the number of bytes read from the ReadChannel.
protected void	closeReadSource()	Close the underlying read source.
boolean	loadNextBatch()	Load the next ArrowRecordBatch to the vector schema root if available.
protected Schema	readSchema()	Read the Schema from the source, will be invoked at the beginning the initialization.

Methods inherited from class org.apache.arrow.vector.ipc.ArrowReader

close, close, ensureInitialized, getDictionaryIds, getDictionaryVectors, getVectorSchemaRoot, initialize, loadDictionary, loadRecordBatch, lookup, prepareLoadNextBatch

Methods inherited from class java.lang.Object

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

Method Details

loadNextBatch

public boolean loadNextBatch()
                      throws IOException

Description copied from class: ArrowReader

Load the next ArrowRecordBatch to the vector schema root if available.

Specified by:

loadNextBatch in class ArrowReader

Returns:

true if a batch was read, false on EOS

Throws:

IOException - on error

bytesRead

public long bytesRead()

Description copied from class: ArrowReader

Return the number of bytes read from the ReadChannel.

Specified by:

bytesRead in class ArrowReader

Returns:

number of bytes read

closeReadSource

protected void closeReadSource()
                        throws IOException

Description copied from class: ArrowReader

Close the underlying read source.

Specified by:

closeReadSource in class ArrowReader

Throws:

IOException - on error

readSchema

protected Schema readSchema()
                     throws IOException

Description copied from class: ArrowReader

Read the Schema from the source, will be invoked at the beginning the initialization.

Specified by:

readSchema in class ArrowReader

Returns:

the read Schema

Throws:

IOException - on error