com.aliyun.odps.storage.read

Class ArrowReaderImpl

java.lang.Object

com.aliyun.odps.table.arrow.readers.ArrowBatchReusedReader

com.aliyun.odps.storage.read.ArrowReaderImpl

All Implemented Interfaces:

ArrowReader, Closeable, AutoCloseable

public class ArrowReaderImpl
extends ArrowBatchReusedReader

Constructor Summary

Constructors

Constructor and Description
ArrowReaderImpl(InputStream is, org.apache.arrow.memory.BufferAllocator allocator)
ArrowReaderImpl(InstanceReaderBuilder builder, InputStream is)
ArrowReaderImpl(TableReaderBuilder builder, InputStream is)

Method Summary

Modifier and Type	Method and Description
RecordReader	getAsRecordReader()
TableSchema	getTableSchema()

Methods inherited from class com.aliyun.odps.table.arrow.readers.ArrowBatchReusedReader

bytesRead, close, close, getCurrentValue, getSchema, nextBatch

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowReaderImpl

public ArrowReaderImpl(TableReaderBuilder builder,
                       InputStream is)

ArrowReaderImpl

public ArrowReaderImpl(InstanceReaderBuilder builder,
                       InputStream is)

ArrowReaderImpl

public ArrowReaderImpl(InputStream is,
                       org.apache.arrow.memory.BufferAllocator allocator)

Method Detail

getTableSchema

public TableSchema getTableSchema()

getAsRecordReader

public RecordReader getAsRecordReader()