| Package | Description |
|---|---|
| com.aliyun.odps.storage | |
| com.aliyun.odps.storage.read |
| Modifier and Type | Method and Description |
|---|---|
TableReadSessionBuilder |
MaxStorageClient.createTableReadSessionBuilder(TableIdentifier table)
Creates a new builder for a table read session.
|
| Modifier and Type | Method and Description |
|---|---|
TableReadSessionBuilder |
TableReadSessionBuilder.enableFilterFallback(boolean enable)
Sets whether to fallback to no filter if specific filtering fails.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withArrowOptions(ArrowOptions arrowOptions)
Sets the Arrow options for data processing.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withBucketIds(List<Integer> requiredBucketIds)
Sets the required bucket IDs to read from the table.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withColumns(List<String> requiredDataColumns)
Sets the required data columns to read from the table.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withFilter(String filterPredicate)
Sets the filter for server-side data filtering.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withIncrementalReadEnabled(boolean incrementalRead)
Sets whether to enable incremental read mode for the session.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withIncrementalReadOptions(IncrementalReadOptions incrementalReadOptions)
Sets the incremental read options for the read session.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withMaxFilesPerSplit(int maxFilesPerSplit)
Sets the maximum number of files per split for reading.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withPartitionColumns(List<String> requiredPartitionColumns)
Sets the required partition columns to read from the table.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withPartitions(List<PartitionSpec> requiredPartitions)
Sets the required partitions to read from the table.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withSessionId(String sessionId) |
TableReadSessionBuilder |
TableReadSessionBuilder.withSessionReadyTimeout(long timeoutSeconds)
Sets the maximum time to wait for the session to be ready.
|
TableReadSessionBuilder |
TableReadSessionBuilder.withSplitOptions(SplitOptions splitOptions)
Sets the split options for parallel processing.
|
| Constructor and Description |
|---|
TableReadSession(StorageStub storageStub,
TableIdentifier tableId,
org.apache.arrow.memory.BufferAllocator allocator,
CreateTableReadSessionResponse response,
TableReadSessionBuilder builder)
Constructs a new TableReadSession with the provided parameters.
|
Copyright © 2026 Alibaba Cloud Computing. All rights reserved.