public class TableReaderBuilder extends Object
| Modifier and Type | Method and Description |
|---|---|
ArrowReader |
build() |
org.apache.arrow.memory.BufferAllocator |
getAllocator() |
BlockingQueue<Object> |
getAsyncQueue() |
InputSplit |
getInputSplit() |
String |
getSessionId() |
StorageStub |
getStorageStub() |
TableIdentifier |
getTableId() |
TableSchema |
getTableSchema() |
boolean |
isAsync() |
TableReaderBuilder |
withAsync(boolean async) |
TableReaderBuilder |
withAsyncQueue(BlockingQueue<Object> asyncQueue) |
TableReaderBuilder |
withDataColumns(List<String> dataColumns) |
TableReaderBuilder |
withDataColumnsUnordered(boolean dataColumnsUnordered) |
TableReaderBuilder |
withDataFormat(DataFormat dataFormat) |
TableReaderBuilder |
withMaxBatchRawSize(long maxBatchRawSize) |
TableReaderBuilder |
withMaxBatchRows(long maxBatchRows) |
TableReaderBuilder |
withSkipRowNum(long skipRowNum) |
public TableReaderBuilder withMaxBatchRows(long maxBatchRows)
public TableReaderBuilder withSkipRowNum(long skipRowNum)
public TableReaderBuilder withMaxBatchRawSize(long maxBatchRawSize)
public TableReaderBuilder withDataFormat(DataFormat dataFormat)
public TableReaderBuilder withDataColumns(List<String> dataColumns)
public TableReaderBuilder withDataColumnsUnordered(boolean dataColumnsUnordered)
public TableReaderBuilder withAsync(boolean async)
public TableReaderBuilder withAsyncQueue(BlockingQueue<Object> asyncQueue)
public TableIdentifier getTableId()
public String getSessionId()
public StorageStub getStorageStub()
public InputSplit getInputSplit()
public org.apache.arrow.memory.BufferAllocator getAllocator()
public boolean isAsync()
public BlockingQueue<Object> getAsyncQueue()
public TableSchema getTableSchema()
public ArrowReader build()
Copyright © 2026 Alibaba Cloud Computing. All rights reserved.