com.aliyun.odps.storage.read

Class InstanceReaderBuilder

java.lang.Object

com.aliyun.odps.storage.read.InstanceReaderBuilder

public class InstanceReaderBuilder
extends Object

This builder allows configuration of various instance read options including:

• Buffer and batch size options
• Data column selection
• Row skip counts
• Compression settings
• Data format preferences

Constructor Summary

Constructors

Constructor and Description
InstanceReaderBuilder(StorageStub storageStub, InstanceIdentifier instanceId, String sessionId, TableSchema tableSchema, org.apache.arrow.memory.BufferAllocator allocator)

Method Summary

Modifier and Type	Method and Description
ArrowReader	build() Build a new MaxInstanceArrowReader with current configurations.
org.apache.arrow.memory.BufferAllocator	getAllocator()
BlockingQueue<Object>	getAsyncQueue()
TableSchema	getTableSchema()
boolean	isAsync()
InstanceReaderBuilder	withAsync(boolean async)
InstanceReaderBuilder	withAsyncQueue(BlockingQueue<Object> asyncQueue)
InstanceReaderBuilder	withColumns(List<String> columns)
InstanceReaderBuilder	withCount(long count)
InstanceReaderBuilder	withEnableLimit(boolean enableLimit)
InstanceReaderBuilder	withOffset(long offset)
InstanceReaderBuilder	withQueryId(long queryId)
InstanceReaderBuilder	withTaskName(String taskName)

Methods inherited from class java.lang.Object

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

Constructor Detail

InstanceReaderBuilder

public InstanceReaderBuilder(StorageStub storageStub,
                             InstanceIdentifier instanceId,
                             String sessionId,
                             TableSchema tableSchema,
                             org.apache.arrow.memory.BufferAllocator allocator)

Method Detail

withOffset

public InstanceReaderBuilder withOffset(long offset)

withCount

public InstanceReaderBuilder withCount(long count)

withColumns

public InstanceReaderBuilder withColumns(List<String> columns)

withTaskName

public InstanceReaderBuilder withTaskName(String taskName)

withQueryId

public InstanceReaderBuilder withQueryId(long queryId)

withEnableLimit

public InstanceReaderBuilder withEnableLimit(boolean enableLimit)

withAsync

public InstanceReaderBuilder withAsync(boolean async)

withAsyncQueue

public InstanceReaderBuilder withAsyncQueue(BlockingQueue<Object> asyncQueue)

getAllocator

public org.apache.arrow.memory.BufferAllocator getAllocator()

getTableSchema

public TableSchema getTableSchema()

isAsync

public boolean isAsync()

getAsyncQueue

public BlockingQueue<Object> getAsyncQueue()

build

public ArrowReader build()

Build a new MaxInstanceArrowReader with current configurations.