A B C D E F G H I J L M N O P Q R S T U V W

A

abort() - Method in class com.aliyun.odps.storage.write.TableWriteSession

Aborts the write session, discarding all written data.

abortTableWriteSession(TableIdentifier, String, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

AbortTableWriteSessionRequest - Class in com.aliyun.odps.storage.internal.models

AbortTableWriteSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest

AbortTableWriteSessionRequest.AbortTableWriteSessionRequestBuilder - Class in com.aliyun.odps.storage.internal.models

AppendTableRecordWriter - Class in com.aliyun.odps.storage.write

AppendTableRecordWriter(TableArrowWriter, long) - Constructor for class com.aliyun.odps.storage.write.AppendTableRecordWriter

ArrowOptionsSerializer - Class in com.aliyun.odps.storage.internal.serializer

ArrowOptionsSerializer() - Constructor for class com.aliyun.odps.storage.internal.serializer.ArrowOptionsSerializer

ArrowReaderImpl - Class in com.aliyun.odps.storage.read

ArrowReaderImpl(TableReaderBuilder, InputStream) - Constructor for class com.aliyun.odps.storage.read.ArrowReaderImpl

ArrowReaderImpl(InstanceReaderBuilder, InputStream) - Constructor for class com.aliyun.odps.storage.read.ArrowReaderImpl

ArrowReaderImpl(InputStream, BufferAllocator) - Constructor for class com.aliyun.odps.storage.read.ArrowReaderImpl

AUTO_COMMIT_DEFAULT_STREAM_ID - Static variable in class com.aliyun.odps.storage.internal.Constants

AUTO_COMMIT_SESSION_ID - Static variable in class com.aliyun.odps.storage.internal.Constants

available() - Method in class com.aliyun.odps.storage.internal.io.LimitedInputStream

返回可从此输入流读取（或跳过）而不会阻塞的字节数的估计值。 该值是底层流的可用字节数和此流剩余限制之间的较小者。

available() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

B

batchDownload(List<Blob>) - Method in interface com.aliyun.odps.storage.BlobManager

Downloads multiple blobs in batch.

batchDownload(List<Blob>) - Method in class com.aliyun.odps.storage.internal.BlobManagerImpl

batchUploadBlob(long, List<byte[]>) - Method in class com.aliyun.odps.storage.write.TableArrowWriter

Uploads multiple blobs in a single batch request.

BlobDataIterator - Interface in com.aliyun.odps.storage.read

一个用于按顺序迭代批量下载的 Blob 内容的迭代器。

BlobDataIteratorImpl - Class in com.aliyun.odps.storage.internal.io

| BlobIteratorImpl.next() 返回一个 LimitedInputStream, | 它包装了下面的"干净的协议帧流"，限定了单个Blob的Data范围 +-------------------------------------------------------------------------+ | BlobIteratorImpl (迭代器实现) | | | | - 它消费的是一个“干净的协议帧流”。 | | - 它的工作是解析 [HeaderLen][Header][DataLen][Data]...

BlobDataIteratorImpl(InputStream, List<Blob>) - Constructor for class com.aliyun.odps.storage.internal.io.BlobDataIteratorImpl

BlobDownloadException - Exception in com.aliyun.odps.storage.exceptions

BlobDownloadException(String, Exception, Blob) - Constructor for exception com.aliyun.odps.storage.exceptions.BlobDownloadException

BlobManager - Interface in com.aliyun.odps.storage

Manager for blob download operations in MaxCompute Storage API.

BlobManagerImpl - Class in com.aliyun.odps.storage.internal

BlobManagerImpl(StorageStub) - Constructor for class com.aliyun.odps.storage.internal.BlobManagerImpl

BlobWriteItem - Class in com.aliyun.odps.storage.internal.models

BlobWriteItem.Builder - Class in com.aliyun.odps.storage.internal.models

A builder for creating immutable BlobWriteItem instances.

BlobWriteItem.ChecksumType - Enum in com.aliyun.odps.storage.internal.models

BlobWriteRequest - Class in com.aliyun.odps.storage.internal.models

BlobWriteRequest() - Constructor for class com.aliyun.odps.storage.internal.models.BlobWriteRequest

BlobWriteResponse - Class in com.aliyun.odps.storage.internal.models

BlobWriteResponse() - Constructor for class com.aliyun.odps.storage.internal.models.BlobWriteResponse

bufferAllocator(BufferAllocator) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the buffer allocator for memory management.

build() - Method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest.AbortTableWriteSessionRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

Builds the final, immutable BlobWriteItem instance.

build() - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest.CloseWriteStreamRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest.GetTableReadSessionRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest.GetTableWriteSessionRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest.GetWriteStreamRequestBuilder

build() - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Builds and returns a new StubSettings instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Builds and returns a new MaxStorageClient instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.models.DataFormat.Builder

Builds and returns a new DataFormat instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.models.SessionStats.Builder

Builds and returns a new SessionStats instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

Build a new MaxInstanceArrowReader with current configurations.

build() - Method in class com.aliyun.odps.storage.read.InstanceReadSessionBuilder

Builds and returns a new InstanceReadSession instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

build() - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Builds and returns a new TableReadSession instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Builds and returns a new HttpSettings instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Builds and returns a new IncrementalReadOptions instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.settings.SplitOptions.SplitOptionsBuilder

Builds and returns a new SplitOptions instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

Builds and returns a new ArrowWriter instance with the configured settings.

build() - Method in class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Builds and returns a new TableWriteSession instance with the configured settings.

builder() - Static method in class com.aliyun.odps.storage.internal.models.BlobWriteItem

Builder() - Constructor for class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

builder() - Static method in class com.aliyun.odps.storage.MaxStorageClient

Creates a new builder for constructing MaxStorageClient instances.

Builder() - Constructor for class com.aliyun.odps.storage.MaxStorageClient.Builder

bytesWritten() - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

bytesWritten() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

C

ClientException - Exception in com.aliyun.odps.storage

Represents an error that occurs on the client side.

ClientException(String) - Constructor for exception com.aliyun.odps.storage.ClientException

Constructs a new ClientException with the specified error message.

ClientException(Exception) - Constructor for exception com.aliyun.odps.storage.ClientException

Constructs a new ClientException with the specified cause.

ClientException(String, Throwable) - Constructor for exception com.aliyun.odps.storage.ClientException

Constructs a new ClientException with the specified error message and cause.

close() - Method in class com.aliyun.odps.storage.internal.io.BlobDataIteratorImpl

close() - Method in class com.aliyun.odps.storage.internal.io.CrcStrippedInputStream

close() - Method in class com.aliyun.odps.storage.internal.io.DiskSpillingInputStream

关闭流并删除底层的临时文件。

close() - Method in class com.aliyun.odps.storage.internal.io.LimitedInputStream

close() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

close() - Method in class com.aliyun.odps.storage.internal.StorageStub

close() - Method in class com.aliyun.odps.storage.MaxStorageClient

Closes the client and releases all associated resources.

close() - Method in interface com.aliyun.odps.storage.read.BlobDataIterator

close() - Method in class com.aliyun.odps.storage.read.TableReadSession

close() - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

close() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

close() - Method in class com.aliyun.odps.storage.write.TableWriteSession

Closes the write session, automatically aborting if not already committed.

closeWriteStream(TableIdentifier, CloseWriteStreamRequest, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

CloseWriteStreamRequest - Class in com.aliyun.odps.storage.internal.models

CloseWriteStreamRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest

CloseWriteStreamRequest.CloseWriteStreamRequestBuilder - Class in com.aliyun.odps.storage.internal.models

CloseWriteStreamResponse - Class in com.aliyun.odps.storage.internal.models

CloseWriteStreamResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CloseWriteStreamResponse

columnId(long) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

ColumnTypeInfo - Class in com.aliyun.odps.storage.internal.data

ColumnTypeInfo() - Constructor for class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

com.aliyun.odps.storage - package com.aliyun.odps.storage

com.aliyun.odps.storage.exceptions - package com.aliyun.odps.storage.exceptions

com.aliyun.odps.storage.internal - package com.aliyun.odps.storage.internal

com.aliyun.odps.storage.internal.data - package com.aliyun.odps.storage.internal.data

com.aliyun.odps.storage.internal.io - package com.aliyun.odps.storage.internal.io

com.aliyun.odps.storage.internal.models - package com.aliyun.odps.storage.internal.models

com.aliyun.odps.storage.internal.retry - package com.aliyun.odps.storage.internal.retry

com.aliyun.odps.storage.internal.serializer - package com.aliyun.odps.storage.internal.serializer

com.aliyun.odps.storage.internal.utils - package com.aliyun.odps.storage.internal.utils

com.aliyun.odps.storage.models - package com.aliyun.odps.storage.models

com.aliyun.odps.storage.read - package com.aliyun.odps.storage.read

com.aliyun.odps.storage.settings - package com.aliyun.odps.storage.settings

com.aliyun.odps.storage.write - package com.aliyun.odps.storage.write

commit() - Method in class com.aliyun.odps.storage.write.TableWriteSession

Commits the write session, making all written data available in the table.

commitTableWriteSession(TableIdentifier, String, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

CommitTableWriteSessionRequest - Class in com.aliyun.odps.storage.internal.models

CommitTableWriteSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder - Class in com.aliyun.odps.storage.internal.models

CommitWriteSessionResponse - Class in com.aliyun.odps.storage.internal.models

CommitWriteSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CommitWriteSessionResponse

Constants - Class in com.aliyun.odps.storage.internal

Constants() - Constructor for class com.aliyun.odps.storage.internal.Constants

contentType() - Method in class com.aliyun.odps.storage.internal.io.RawArrowRequestBody

CrcStrippedInputStream - Class in com.aliyun.odps.storage.internal.io

Strips CRC32C checksums from a stream formatted as: [4096 bytes data][4 bytes CRC] ...

CrcStrippedInputStream(InputStream) - Constructor for class com.aliyun.odps.storage.internal.io.CrcStrippedInputStream

create(InputStream) - Static method in class com.aliyun.odps.storage.internal.io.DiskSpillingInputStream

工厂方法，用于创建一个 DiskSpillingInputStream。

createInstanceReadSession(InstanceIdentifier, CreateInstanceReadSessionRequest) - Method in class com.aliyun.odps.storage.internal.StorageStub

createInstanceReadSessionBuilder(InstanceIdentifier) - Method in class com.aliyun.odps.storage.MaxStorageClient

Creates a new builder for an instance read session.

CreateInstanceReadSessionRequest - Class in com.aliyun.odps.storage.internal.models

CreateInstanceReadSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionRequest

CreateInstanceReadSessionResponse - Class in com.aliyun.odps.storage.internal.models

CreateInstanceReadSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

createInstanceReadStream(InstanceIdentifier, String, Long, Long, CreateInstanceReadStreamRequest) - Method in class com.aliyun.odps.storage.internal.StorageStub

CreateInstanceReadStreamRequest - Class in com.aliyun.odps.storage.internal.models

CreateInstanceReadStreamRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

createProxySelector(ProxyConfig) - Static method in class com.aliyun.odps.storage.internal.utils.OkHttpProxyHelper

createReaderBuilder() - Method in class com.aliyun.odps.storage.read.InstanceReadSession

Creates a new builder for an Arrow reader for the specified input split.

createReaderBuilder(InputSplit) - Method in class com.aliyun.odps.storage.read.TableReadSession

Creates a new builder for an Arrow reader for the specified input split.

createTableReadSession(TableIdentifier, CreateTableReadSessionRequest) - Method in class com.aliyun.odps.storage.internal.StorageStub

createTableReadSessionBuilder(TableIdentifier) - Method in class com.aliyun.odps.storage.MaxStorageClient

Creates a new builder for a table read session.

CreateTableReadSessionRequest - Class in com.aliyun.odps.storage.internal.models

CreateTableReadSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

CreateTableReadSessionResponse - Class in com.aliyun.odps.storage.internal.models

CreateTableReadSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

createTableReadStream(TableIdentifier, InputSplit, CreateTableReadStreamRequest, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

CreateTableReadStreamRequest - Class in com.aliyun.odps.storage.internal.models

CreateTableReadStreamRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

createTableWriteSession(TableIdentifier, CreateTableWriteSessionRequest) - Method in class com.aliyun.odps.storage.internal.StorageStub

createTableWriteSessionBuilder(TableIdentifier) - Method in class com.aliyun.odps.storage.MaxStorageClient

Creates a new builder for a table write session.

CreateTableWriteSessionRequest - Class in com.aliyun.odps.storage.internal.models

CreateTableWriteSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionRequest

CreateTableWriteSessionResponse - Class in com.aliyun.odps.storage.internal.models

CreateTableWriteSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

createTableWriteStream(TableIdentifier, String, CreateWriteStreamRequest, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

createVectorSchemaRoot() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

Creates a new VectorSchemaRoot instance that is compatible with this writer.

createWriterBuilder(String, long) - Method in class com.aliyun.odps.storage.write.TableWriteSession

Creates a new builder for a writer for this write session.

CreateWriteStreamRequest - Class in com.aliyun.odps.storage.internal.models

CreateWriteStreamRequest() - Constructor for class com.aliyun.odps.storage.internal.models.CreateWriteStreamRequest

CreateWriteStreamResponse - Class in com.aliyun.odps.storage.internal.models

CreateWriteStreamResponse() - Constructor for class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

credentialsProvider(ICredentialsProvider) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the credentials provider for authentication.

D

data(byte[]) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

DataFormat - Class in com.aliyun.odps.storage.models

Data format configuration for read/write operations.

DataFormat.Builder - Class in com.aliyun.odps.storage.models

Builder class for constructing DataFormat instances.

delete(Record) - Method in class com.aliyun.odps.storage.write.DeltaTableRecordWriter

DeltaTableRecordWriter - Class in com.aliyun.odps.storage.write

DeltaTableRecordWriter(TableArrowWriter, long) - Constructor for class com.aliyun.odps.storage.write.DeltaTableRecordWriter

deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class com.aliyun.odps.storage.internal.serializer.ReadSchemaDeserializer

deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class com.aliyun.odps.storage.internal.serializer.WriteSchemaDeserializer

deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class com.aliyun.odps.storage.models.SplitMode.SplitModeDeserializer

deserialize(JsonElement, Type, JsonDeserializationContext) - Method in class com.aliyun.odps.storage.models.TimestampUnit.TimestampUnitDeserializer

DiskSpillingInputStream - Class in com.aliyun.odps.storage.internal.io

一个将输入流缓存到临时磁盘文件的可重复读流。

distributionKey(String) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

download(Blob) - Method in interface com.aliyun.odps.storage.BlobManager

Downloads a single blob from MaxCompute storage.

download(Blob) - Method in class com.aliyun.odps.storage.internal.BlobManagerImpl

E

enableFilterFallback(boolean) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets whether to fallback to no filter if specific filtering fails.

endpoint(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the MaxCompute service endpoint.

executeWithRetry(Callable<T>) - Method in class com.aliyun.odps.storage.internal.retry.RetryHandler

Executes an action with retry logic.

executeWithRetry(Callable<T>, IntConsumer) - Method in class com.aliyun.odps.storage.internal.retry.RetryHandler

Executes an action with retry logic and error code handler.

ExponentialBackoffPolicy - Class in com.aliyun.odps.storage.internal.retry

A retry policy with exponential backoff and jitter.

F

flush() - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

flush() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

fromString(String) - Static method in enum com.aliyun.odps.storage.models.SessionStatus

Converts a string to SessionStatus.

fromString(String) - Static method in enum com.aliyun.odps.storage.models.SplitMode

fromString(String) - Static method in enum com.aliyun.odps.storage.models.TimestampUnit

fromValue(String) - Static method in enum com.aliyun.odps.storage.write.WriteMode

G

getAllColumns() - Method in class com.aliyun.odps.storage.internal.models.ReadSchema

getAllColumns() - Method in class com.aliyun.odps.storage.internal.models.WriteSchema

getAllocator() - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

getAllocator() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getAllocator() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

getAllocator() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getArrowOptions() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getArrowSchema() - Method in class com.aliyun.odps.storage.read.InstanceReadSession

Gets the Arrow schema for the data in this read session.

getArrowSchema() - Method in class com.aliyun.odps.storage.read.TableReadSession

Gets the Arrow schema for the data in this read session.

getAsRecordReader() - Method in class com.aliyun.odps.storage.read.ArrowReaderImpl

getAsRecordWriter(long) - Method in class com.aliyun.odps.storage.write.TableArrowWriter

getAsyncQueue() - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

getAsyncQueue() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getBlobChecksumType() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getBlobColumns() - Method in class com.aliyun.odps.storage.internal.models.ReadSchema

getBlobReference() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

getBlobReferences() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteRequest

getBlobReferences() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

getBody() - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getBufferSize() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getCachedSize() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

getColumnId() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getColumns() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

getColumns() - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

getConnectTimeout() - Method in class com.aliyun.odps.storage.settings.HttpSettings

Gets the connection timeout duration.

getCredentialsProvider() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the credential provider.

getDataColumns() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

getDataFormat() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

getDataSchema() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getDataSchema() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

getDownloadId() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

getEndpoint() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the endpoint.

getEndTimeStamp() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Gets the end timestamp.

getEndVersion() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Gets the end version.

getErrorCode() - Method in exception com.aliyun.odps.storage.ServiceException

Gets the service-defined business error code.

getEstimatedRowCount() - Method in class com.aliyun.odps.storage.models.SessionStats

Gets the estimated row count.

getEstimatedSize() - Method in class com.aliyun.odps.storage.models.SessionStats

Gets the estimated data size in bytes.

getExecutorService() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getExpirationTime() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getFailedBlobRef() - Method in exception com.aliyun.odps.storage.exceptions.BlobDownloadException

getFile() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

getFilterPredicate() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getFirstHeader(String) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getFlags() - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionRequest

getHeaders() - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getHttpSettings() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the HTTP settings.

getHttpStatus() - Method in exception com.aliyun.odps.storage.ServiceException

Gets the HTTP status code.

getId() - Method in enum com.aliyun.odps.storage.internal.models.BlobWriteItem.ChecksumType

getId() - Method in class com.aliyun.odps.storage.read.InstanceReadSession

Gets the unique identifier of this read session.

getId() - Method in class com.aliyun.odps.storage.read.TableReadSession

Gets the unique identifier of this read session.

getId() - Method in class com.aliyun.odps.storage.write.TableWriteSession

Gets the unique identifier of this write session.

getIncrementalReadOptions() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getIncrementalReadOptions() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getInputSplit() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getInputStream() - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getInstance() - Method in class com.aliyun.odps.storage.read.InstanceReadSessionBuilder

Gets the instance identifier for this builder.

getInstanceReadSession(InstanceIdentifier, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

getJavaVersion() - Static method in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

getKeepAliveDuration() - Method in class com.aliyun.odps.storage.settings.HttpSettings

Gets the keep-alive duration for idle connections.

getLastRequestId() - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

Returns the request ID of the last write (flush) for this stream.

getLastRequestId() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

Returns the request ID of the last successful write (flush).

getLatestVersion() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getLimit() - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

getMavenVersion() - Static method in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

getMaxBatchRawSize() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

getMaxBatchRows() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

getMaxIdleConnections() - Method in class com.aliyun.odps.storage.settings.HttpSettings

Gets the maximum number of idle connections to keep in the connection pool.

getMemberName() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getMessage() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getMode() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Gets the mode.

getOdpsType() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getPartialPartitionSpec() - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionRequest

getPartition() - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

getPrecision() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getProject() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the project.

getProxyConfig() - Method in class com.aliyun.odps.storage.settings.HttpSettings

Gets the proxy configuration, if any.

getQueryId() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

getQuota() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the quota.

getQuotaName() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

getReadTimeout() - Method in class com.aliyun.odps.storage.settings.HttpSettings

Gets the read timeout duration.

getRecordCount() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

getRecordCount() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getRecordCount() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamResponse

getRecordCount() - Method in class com.aliyun.odps.storage.read.InstanceReadSession

getRegion() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the region.

getRequestId() - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getRequestId() - Method in exception com.aliyun.odps.storage.ServiceException

Gets the unique ID for this request.

getRequiredBucketIds() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getRequiredDataColumns() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getRequiredPartitionColumns() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getRequiredPartitions() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getRetryHandler() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the retry handler.

getRetryWaitTime(int) - Method in class com.aliyun.odps.storage.internal.retry.ExponentialBackoffPolicy

getRetryWaitTime(int) - Method in class com.aliyun.odps.storage.internal.retry.InfiniteExponentialBackoffPolicy

getRetryWaitTime(int) - Method in class com.aliyun.odps.storage.internal.retry.NoRetryPolicy

getRetryWaitTime(int) - Method in interface com.aliyun.odps.storage.internal.retry.RetryPolicy

Calculates the wait time before the next retry attempt.

getRouteToken() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getRouteToken() - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

getRouteToken() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

getRouteToken() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionResponse

getScale() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getSchema() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

getSchemaVersion() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest

getSessionId() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

getSessionId() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getSessionId() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getSessionStats() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSessionStatus() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSessionType() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSize() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

getSkipRowNum() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

getSpecifiedLength() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getSplitBucketId() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSplitMaxFileNum() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getSplitMode() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSplitMode() - Method in class com.aliyun.odps.storage.settings.SplitOptions

Gets the split mode.

getSplitNumber() - Method in class com.aliyun.odps.storage.settings.SplitOptions

Gets the split number.

getSplitOptions() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

getSplitOptions() - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

getSplits() - Method in class com.aliyun.odps.storage.read.TableReadSession

Gets the input splits for this read session.

getSplitsCount() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSplitUnit() - Method in class com.aliyun.odps.storage.settings.SplitOptions

Gets the split unit.

getStartTimeStamp() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Gets the start timestamp.

getStartVersion() - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Gets the start version.

getStaticPartitionSpec() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getStatus() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionResponse

getStatus() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamResponse

getStatusCode() - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

getStorageStub() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getStorageStub() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getStreamId() - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest

getStreamId() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamRequest

getStreamId() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

getStreamId() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getStreamIds() - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

getStreams() - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionResponse

getStreams() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionResponse

getStreamVersion() - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest

getStreamVersion() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamRequest

getStreamVersion() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

getStreamVersion() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getStreamVersions() - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

getSubTypes() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getSupportedDataFormat() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

getSvnRevision() - Static method in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

getSystemColumns() - Method in class com.aliyun.odps.storage.internal.models.ReadSchema

getSystemColumns() - Method in class com.aliyun.odps.storage.internal.models.WriteSchema

getTable() - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Gets the table identifier for this builder.

getTableId() - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

getTableId() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getTableId() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getTableIdentifier() - Method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest

getTableIdentifier() - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

getTableIdentifier() - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest

getTableIdentifier() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest

getTableIdentifier() - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

getTableReadSession(TableIdentifier, String, boolean) - Method in class com.aliyun.odps.storage.internal.StorageStub

GetTableReadSessionRequest - Class in com.aliyun.odps.storage.internal.models

GetTableReadSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest

GetTableReadSessionRequest.GetTableReadSessionRequestBuilder - Class in com.aliyun.odps.storage.internal.models

GetTableReadSessionResponse - Class in com.aliyun.odps.storage.internal.models

GetTableReadSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.GetTableReadSessionResponse

getTableSchema() - Method in class com.aliyun.odps.storage.read.ArrowReaderImpl

getTableSchema() - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

getTableSchema() - Method in class com.aliyun.odps.storage.read.InstanceReadSession

getTableSchema() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

getTableSchema() - Method in class com.aliyun.odps.storage.read.TableReadSession

getTableWriteSession(TableIdentifier, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

GetTableWriteSessionRequest - Class in com.aliyun.odps.storage.internal.models

GetTableWriteSessionRequest() - Constructor for class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest

GetTableWriteSessionRequest.GetTableWriteSessionRequestBuilder - Class in com.aliyun.odps.storage.internal.models

GetTableWriteSessionResponse - Class in com.aliyun.odps.storage.internal.models

GetTableWriteSessionResponse() - Constructor for class com.aliyun.odps.storage.internal.models.GetTableWriteSessionResponse

getTaskName() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

getTotalBytes() - Method in class com.aliyun.odps.storage.internal.io.RawArrowRequestBody

getTunnelEndpoint() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the tunnel endpoint.

getType() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getType() - Method in class com.aliyun.odps.storage.models.DataFormat

Gets the data format type.

getTypeName() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

getUserAgent() - Method in class com.aliyun.odps.storage.internal.StubSettings

Gets the user agent.

getValue() - Method in enum com.aliyun.odps.storage.write.WriteMode

getVersion() - Method in class com.aliyun.odps.storage.models.DataFormat

Gets the data format version.

getWarningMessage() - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

getWarningMessage() - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamResponse

getWarningMessage() - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

getWarningMessage() - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionResponse

getWrappedInputStream() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

getWriteMode() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

getWriteMode() - Method in class com.aliyun.odps.storage.write.TableWriteSession

Gets the write mode of this session.

getWriteSchema() - Method in class com.aliyun.odps.storage.write.TableArrowWriter

getWriteStream(GetWriteStreamRequest, String) - Method in class com.aliyun.odps.storage.internal.StorageStub

GetWriteStreamRequest - Class in com.aliyun.odps.storage.internal.models

GetWriteStreamRequest() - Constructor for class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

GetWriteStreamRequest.GetWriteStreamRequestBuilder - Class in com.aliyun.odps.storage.internal.models

GetWriteStreamResponse - Class in com.aliyun.odps.storage.internal.models

GetWriteStreamResponse() - Constructor for class com.aliyun.odps.storage.internal.models.GetWriteStreamResponse

H

hasNext() - Method in class com.aliyun.odps.storage.internal.io.BlobDataIteratorImpl

HTML - Static variable in class com.aliyun.odps.storage.internal.HttpClient

HttpClient - Class in com.aliyun.odps.storage.internal

HTTP client for making requests to the MaxCompute Storage API.

HttpClient(StubSettings) - Constructor for class com.aliyun.odps.storage.internal.HttpClient

Constructs a new HttpClient with the provided settings.

HttpResponse - Class in com.aliyun.odps.storage.internal.models

HttpResponse() - Constructor for class com.aliyun.odps.storage.internal.models.HttpResponse

httpSettings(HttpSettings) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the HTTP settings for connection management.

HttpSettings - Class in com.aliyun.odps.storage.settings

Configuration class for HTTP connection settings used by the MaxCompute Storage API client.

HttpSettings.HttpSettingsBuilder - Class in com.aliyun.odps.storage.settings

I

IncrementalReadOptions - Class in com.aliyun.odps.storage.settings

Configuration class for incremental read options used by the MaxCompute Storage API client.

IncrementalReadOptions.Builder - Class in com.aliyun.odps.storage.settings

Builder class for constructing IncrementalReadOptions instances.

InfiniteExponentialBackoffPolicy - Class in com.aliyun.odps.storage.internal.retry

A retry policy with infinite exponential backoff and jitter.

INSTANCE - Static variable in class com.aliyun.odps.storage.internal.retry.ExponentialBackoffPolicy

INSTANCE - Static variable in class com.aliyun.odps.storage.internal.retry.InfiniteExponentialBackoffPolicy

INSTANCE - Static variable in class com.aliyun.odps.storage.internal.retry.NoRetryPolicy

InstanceReaderBuilder - Class in com.aliyun.odps.storage.read

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

InstanceReaderBuilder(StorageStub, InstanceIdentifier, String, TableSchema, BufferAllocator) - Constructor for class com.aliyun.odps.storage.read.InstanceReaderBuilder

InstanceReadSession - Class in com.aliyun.odps.storage.read

Implementation of a read session for the MaxCompute Storage API for Instances.

InstanceReadSession(StorageStub, InstanceIdentifier, BufferAllocator, CreateInstanceReadSessionResponse) - Constructor for class com.aliyun.odps.storage.read.InstanceReadSession

Constructs a new InstanceReadSession with the provided parameters.

InstanceReadSessionBuilder - Class in com.aliyun.odps.storage.read

Implementation of a builder for Instance Read Session in the MaxCompute Storage API.

InstanceReadSessionBuilder(StorageStub, BufferAllocator, InstanceIdentifier) - Constructor for class com.aliyun.odps.storage.read.InstanceReadSessionBuilder

Constructs a new InstanceReadSessionBuilder with the provided parameters.

intercept(Interceptor.Chain) - Method in class com.aliyun.odps.storage.internal.SignatureInterceptor

IOUtils - Class in com.aliyun.odps.storage.internal.utils

isAsync() - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

isAsync() - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

isAutoFlushEnabled() - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

isClosed() - Method in class com.aliyun.odps.storage.internal.io.LimitedInputStream

isCrossPartition() - Method in class com.aliyun.odps.storage.settings.SplitOptions

Checks if cross-partition splits are allowed.

isDataColumnsUnordered() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

isEnableLargeString() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

isEnableLimit() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionRequest

isEnableLimit() - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

isFilterPredicateFallback() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

isIncrementalRead() - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

isNullable() - Method in class com.aliyun.odps.storage.internal.data.ColumnTypeInfo

J

javaVersion - Static variable in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

JSON - Static variable in class com.aliyun.odps.storage.internal.HttpClient

L

LimitedInputStream - Class in com.aliyun.odps.storage.internal.io

一个 InputStream 包装器，它只允许从底层流中读取固定数量的字节。 它的 close() 方法不会关闭底层流。

LimitedInputStream(InputStream, long) - Constructor for class com.aliyun.odps.storage.internal.io.LimitedInputStream

M

mark(int) - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

markSupported() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

mavenVersion - Static variable in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

MaxStorageClient - Class in com.aliyun.odps.storage

Implementation of the MaxCompute Storage API client.

MaxStorageClient(MaxStorageClient.Builder) - Constructor for class com.aliyun.odps.storage.MaxStorageClient

Constructs a new MaxStorageClient with the provided builder configuration.

MaxStorageClient.Builder - Class in com.aliyun.odps.storage

Builder class for constructing MaxStorageClient instances.

MaxStorageException - Exception in com.aliyun.odps.storage

Exception thrown when an error occurs during MaxCompute Storage API operations.

MaxStorageException() - Constructor for exception com.aliyun.odps.storage.MaxStorageException

MaxStorageException(Exception) - Constructor for exception com.aliyun.odps.storage.MaxStorageException

MaxStorageException(String) - Constructor for exception com.aliyun.odps.storage.MaxStorageException

MaxStorageException(String, Throwable) - Constructor for exception com.aliyun.odps.storage.MaxStorageException

N

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest

newBuilder() - Static method in class com.aliyun.odps.storage.internal.StubSettings

Creates a new builder for constructing StubSettings instances.

newBuilder() - Static method in class com.aliyun.odps.storage.models.DataFormat

Creates a new builder for constructing DataFormat instances.

newBuilder() - Static method in class com.aliyun.odps.storage.models.SessionStats

Creates a new builder for constructing SessionStats instances.

newBuilder() - Static method in class com.aliyun.odps.storage.settings.HttpSettings

newBuilder() - Static method in class com.aliyun.odps.storage.settings.IncrementalReadOptions

Creates a new builder for constructing IncrementalReadOptions instances.

newBuilder() - Static method in class com.aliyun.odps.storage.settings.SplitOptions

newRecord(boolean) - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

Record can be reused, and recommend reuse it.

newRepeatableInputStream(InputStream) - Static method in class com.aliyun.odps.storage.internal.utils.IOUtils

将一个输入流包装成可重复读的流，同时尽可能地优化性能。

next() - Method in class com.aliyun.odps.storage.internal.io.BlobDataIteratorImpl

next() - Method in interface com.aliyun.odps.storage.read.BlobDataIterator

NoRetryPolicy - Class in com.aliyun.odps.storage.internal.retry

A retry policy that never retries failed operations.

O

OCTET_STREAM - Static variable in class com.aliyun.odps.storage.internal.HttpClient

OkHttpProxyHelper - Class in com.aliyun.odps.storage.internal.utils

OkHttpProxyHelper() - Constructor for class com.aliyun.odps.storage.internal.utils.OkHttpProxyHelper

onRetryLog(Exception, int, long) - Method in interface com.aliyun.odps.storage.internal.retry.RetryHandler.RetryLogger

Called when a retry attempt is about to be made.

openBlobManager() - Method in class com.aliyun.odps.storage.MaxStorageClient

OPERATION_COLUMN_NAME - Static variable in class com.aliyun.odps.storage.internal.Constants

OPERATION_DELETE - Static variable in class com.aliyun.odps.storage.internal.Constants

OPERATION_UPSERT - Static variable in class com.aliyun.odps.storage.internal.Constants

P

partitionValues(List<String>) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

preview(TableIdentifier, String, List<String>, Integer) - Method in class com.aliyun.odps.storage.internal.StorageStub

previewTable(TableIdentifier, PartitionSpec, List<String>, Integer) - Method in class com.aliyun.odps.storage.MaxStorageClient

Previews data from a table with the specified filters and limit.

project(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the MaxCompute project name.

Q

quota(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the MaxCompute quota.

R

RawArrowRequestBody - Class in com.aliyun.odps.storage.internal.io

RawArrowRequestBody(List<byte[]>, Schema, IpcOption) - Constructor for class com.aliyun.odps.storage.internal.io.RawArrowRequestBody

read() - Method in class com.aliyun.odps.storage.internal.io.CrcStrippedInputStream

read(byte[], int, int) - Method in class com.aliyun.odps.storage.internal.io.CrcStrippedInputStream

read() - Method in class com.aliyun.odps.storage.internal.io.LimitedInputStream

read(byte[], int, int) - Method in class com.aliyun.odps.storage.internal.io.LimitedInputStream

read() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

read(byte[], int, int) - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

readBlobs(List<String>) - Method in class com.aliyun.odps.storage.internal.StorageStub

readFully(InputStream, byte[], int, int) - Static method in class com.aliyun.odps.storage.internal.utils.IOUtils

readLittleEndianLong(InputStream) - Static method in class com.aliyun.odps.storage.internal.utils.IOUtils

readNBytes(InputStream, int) - Static method in class com.aliyun.odps.storage.internal.utils.IOUtils

从输入流中精确读取 len 个字节。 这个方法会阻塞，直到 len 个字节被读取，或者流结束，或者发生 I/O 错误。

ReadSchema - Class in com.aliyun.odps.storage.internal.models

ReadSchema() - Constructor for class com.aliyun.odps.storage.internal.models.ReadSchema

ReadSchemaDeserializer - Class in com.aliyun.odps.storage.internal.serializer

ReadSchemaDeserializer() - Constructor for class com.aliyun.odps.storage.internal.serializer.ReadSchemaDeserializer

region(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the MaxCompute region.

RepeatableFileInputStream - Class in com.aliyun.odps.storage.internal.io

A repeatable input stream that can reset to a marked position.

RepeatableFileInputStream(File) - Constructor for class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

RepeatableFileInputStream(FileInputStream) - Constructor for class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

RepeatableFileInputStream(FileInputStream, File) - Constructor for class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

request(Request) - Method in class com.aliyun.odps.storage.internal.HttpClient

Makes a generic, one-time request (used for metadata operations).

request(String, String, Map<String, String>, Map<String, String>, String) - Method in class com.aliyun.odps.storage.internal.HttpClient

Makes a generic, one-time request (used for metadata operations).

requestWithoutRetry(Request) - Method in class com.aliyun.odps.storage.internal.HttpClient

Makes a generic, one-time request without automatic retry.

reset() - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

RetryHandler - Class in com.aliyun.odps.storage.internal.retry

Retry handler for executing operations with automatic retry logic.

RetryHandler() - Constructor for class com.aliyun.odps.storage.internal.retry.RetryHandler

RetryHandler(RetryPolicy, RetryHandler.RetryLogger) - Constructor for class com.aliyun.odps.storage.internal.retry.RetryHandler

RetryHandler(RetryHandler.RetryLogger) - Constructor for class com.aliyun.odps.storage.internal.retry.RetryHandler

RetryHandler.RetryLogger - Interface in com.aliyun.odps.storage.internal.retry

Functional interface for logging retry attempts.

RetryPolicy - Interface in com.aliyun.odps.storage.internal.retry

Retry policy interface for determining whether and how to retry failed operations.

revision - Static variable in class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

ROUTE_TOKEN_HEADER - Static variable in class com.aliyun.odps.storage.internal.Constants

S

serialize(ArrowOptions, Type, JsonSerializationContext) - Method in class com.aliyun.odps.storage.internal.serializer.ArrowOptionsSerializer

serialize(SplitMode, Type, JsonSerializationContext) - Method in class com.aliyun.odps.storage.models.SplitMode.SplitModeSerializer

serialize(TimestampUnit, Type, JsonSerializationContext) - Method in class com.aliyun.odps.storage.models.TimestampUnit.TimestampUnitSerializer

serializeTo(OutputStream) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem

Serializes this BlobWriteItem directly into the given OutputStream, avoiding intermediate byte array allocation for the item itself.

ServiceException - Exception in com.aliyun.odps.storage

Represents a specific, actionable error returned from the server.

ServiceException(int, String, String, String) - Constructor for exception com.aliyun.odps.storage.ServiceException

Constructs a new ServiceException.

ServiceException(int, String, String, String, Throwable) - Constructor for exception com.aliyun.odps.storage.ServiceException

SessionStats - Class in com.aliyun.odps.storage.models

Statistics information for a read/write session.

SessionStats.Builder - Class in com.aliyun.odps.storage.models

Builder class for constructing SessionStats instances.

SessionStatus - Enum in com.aliyun.odps.storage.models

Enumeration of session statuses for read/write operations.

setArrowOptions(ArrowOptions) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setBlobColumns(List<Column>) - Method in class com.aliyun.odps.storage.internal.models.ReadSchema

setBlobReference(String) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

setBlobReferences(List<String>) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteRequest

setBody(String) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

setColumns(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

setColumns(List<String>) - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

setCrossPartition(boolean) - Method in class com.aliyun.odps.storage.settings.SplitOptions

Sets whether cross-partition splits are allowed.

setDataColumns(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setDataColumnsUnordered(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setDataFormat(DataFormat) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setDataSchema(ReadSchema) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setDataSchema(WriteSchema) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

setEnableLargeString(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setEnableLimit(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadSessionRequest

setEnableLimit(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

setExpirationTime(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setFilterPredicate(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setFilterPredicateFallback(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setFlags(Map<String, String>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionRequest

setHeaders(Map<String, List<String>>) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

setIncrementalRead(boolean) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setIncrementalReadOptions(IncrementalReadOptions) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setIncrementalReadOptions(IncrementalReadOptions) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setInputStream(InputStream) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

setLatestVersion(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setLimit(Integer) - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

setMaxBatchRawSize(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setMaxBatchRows(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setMessage(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setPartialPartitionSpec(PartitionSpec) - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionRequest

setPartition(String) - Method in class com.aliyun.odps.storage.internal.models.TablePreviewRequest

setQueryId(long) - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

setRecordCount(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setRequestId(String) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

setRequiredBucketIds(List<Integer>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setRequiredDataColumns(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setRequiredPartitionColumns(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setRequiredPartitions(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setRouteToken(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setRouteToken(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

setRouteToken(String) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

setRouteToken(String) - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionResponse

setSchemaVersion(Long) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

setSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

setSessionStats(SessionStats) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSessionStatus(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSessionType(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSize(long) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

setSkipRowNum(long) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadStreamRequest

setSplitBucketId(List<Integer>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSplitMaxFileNum(int) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setSplitMode(SplitMode) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSplitMode(SplitMode) - Method in class com.aliyun.odps.storage.settings.SplitOptions

Sets the split mode.

setSplitNumber(long) - Method in class com.aliyun.odps.storage.settings.SplitOptions

Sets the split number.

setSplitOptions(SplitOptions) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionRequest

setSplitsCount(int) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSplitUnit(String) - Method in class com.aliyun.odps.storage.settings.SplitOptions

Sets the split unit.

setStatusCode(int) - Method in class com.aliyun.odps.storage.internal.models.HttpResponse

setStreamId(String) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamRequest

setStreamVersion(long) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamRequest

setSupportedDataFormat(List<DataFormat>) - Method in class com.aliyun.odps.storage.internal.models.CreateTableReadSessionResponse

setSystemColumns(List<Column>) - Method in class com.aliyun.odps.storage.internal.models.ReadSchema

setSystemColumns(List<Column>) - Method in class com.aliyun.odps.storage.internal.models.WriteSchema

setTableId(String) - Method in class com.aliyun.odps.storage.internal.models.CreateWriteStreamResponse

setTaskName(String) - Method in class com.aliyun.odps.storage.internal.models.CreateInstanceReadStreamRequest

setWarningMessage(String) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteResponse

setWarningMessage(String) - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamResponse

setWarningMessage(String) - Method in class com.aliyun.odps.storage.internal.models.CreateTableWriteSessionResponse

shouldRetry(Exception, int) - Method in class com.aliyun.odps.storage.internal.retry.ExponentialBackoffPolicy

shouldRetry(Exception, int) - Method in class com.aliyun.odps.storage.internal.retry.InfiniteExponentialBackoffPolicy

shouldRetry(Exception, int) - Method in class com.aliyun.odps.storage.internal.retry.NoRetryPolicy

shouldRetry(Exception, int) - Method in interface com.aliyun.odps.storage.internal.retry.RetryPolicy

Determines whether an operation should be retried based on the exception and attempt count.

shutdown() - Method in class com.aliyun.odps.storage.internal.HttpClient

SignatureInterceptor - Class in com.aliyun.odps.storage.internal

SignatureInterceptor(ICredentialsProvider) - Constructor for class com.aliyun.odps.storage.internal.SignatureInterceptor

skip(long) - Method in class com.aliyun.odps.storage.internal.io.RepeatableFileInputStream

SplitMode - Enum in com.aliyun.odps.storage.models

Enumeration of split modes for table read operations.

SplitMode.SplitModeDeserializer - Class in com.aliyun.odps.storage.models

SplitMode.SplitModeSerializer - Class in com.aliyun.odps.storage.models

SplitModeDeserializer() - Constructor for class com.aliyun.odps.storage.models.SplitMode.SplitModeDeserializer

SplitModeSerializer() - Constructor for class com.aliyun.odps.storage.models.SplitMode.SplitModeSerializer

SplitOptions - Class in com.aliyun.odps.storage.settings

Configuration class for data split options used when reading from MaxCompute tables.

SplitOptions.SplitOptionsBuilder - Class in com.aliyun.odps.storage.settings

StorageStub - Class in com.aliyun.odps.storage.internal

The internal stub for communicating with the MaxCompute Storage V2 API endpoint.

StorageStub(StubSettings) - Constructor for class com.aliyun.odps.storage.internal.StorageStub

Constructs a new StorageStub with the provided settings.

streamDownload(String, String, Map<String, String>, Map<String, String>, String) - Method in class com.aliyun.odps.storage.internal.HttpClient

Stream download request (replaces connect + getInputStream).

streamUpload(String, String, Map<String, String>, Map<String, String>, RequestBody) - Method in class com.aliyun.odps.storage.internal.HttpClient

Uploads data using a stream.

StubSettings - Class in com.aliyun.odps.storage.internal

Configuration class for StubSettings used by the MaxCompute Storage API client.

StubSettings() - Constructor for class com.aliyun.odps.storage.internal.StubSettings

StubSettings.StubSettingsBuilder - Class in com.aliyun.odps.storage.internal

SvnRevisionUtils - Class in com.aliyun.odps.storage.internal.utils

SvnRevisionUtils() - Constructor for class com.aliyun.odps.storage.internal.utils.SvnRevisionUtils

T

TableArrowBatchBlobWriter - Class in com.aliyun.odps.storage.write

TableArrowWriter - Class in com.aliyun.odps.storage.write

A buffered ArrowWriter implementation.

tableBatchWriteBlob(TableIdentifier, String, String, long, List<BlobWriteItem>) - Method in class com.aliyun.odps.storage.internal.StorageStub

TablePreviewRequest - Class in com.aliyun.odps.storage.internal.models

Request body for table preview operation.

TablePreviewRequest() - Constructor for class com.aliyun.odps.storage.internal.models.TablePreviewRequest

TableReaderBuilder - Class in com.aliyun.odps.storage.read

TableReadSession - Class in com.aliyun.odps.storage.read

Implementation of TableReadSession for the MaxCompute Storage API.

TableReadSession(StorageStub, TableIdentifier, BufferAllocator, CreateTableReadSessionResponse, TableReadSessionBuilder) - Constructor for class com.aliyun.odps.storage.read.TableReadSession

Constructs a new TableReadSession with the provided parameters.

TableReadSessionBuilder - Class in com.aliyun.odps.storage.read

Implementation of TableReadSessionBuilder for the MaxCompute Storage API.

TableReadSessionBuilder(StorageStub, BufferAllocator, TableIdentifier) - Constructor for class com.aliyun.odps.storage.read.TableReadSessionBuilder

Constructs a new TableReadSessionBuilder with the provided parameters.

tableWriteBlob(TableIdentifier, String, String, long, PartitionSpec, long, InputStream) - Method in class com.aliyun.odps.storage.internal.StorageStub

TableWriterBuilder - Class in com.aliyun.odps.storage.write

This builder creates Arrow writers that can write data to MaxCompute tables using the Arrow columnar format.

TableWriteSession - Class in com.aliyun.odps.storage.write

This class represents a write session for a MaxCompute table, allowing clients to write data in a distributed manner using Arrow format.

TableWriteSessionBuilder - Class in com.aliyun.odps.storage.write

This builder allows configuration of various write session settings including: Partition specifications for writing data to specific partitions Overwrite mode for replacing existing data Write mode (Batch or Streaming)

TableWriteSessionBuilder(StorageStub, BufferAllocator, TableIdentifier) - Constructor for class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Constructs a new TableWriteSessionBuilder with the provided parameters.

TimestampUnit - Enum in com.aliyun.odps.storage.models

TimestampUnit.TimestampUnitDeserializer - Class in com.aliyun.odps.storage.models

TimestampUnit.TimestampUnitSerializer - Class in com.aliyun.odps.storage.models

TimestampUnitDeserializer() - Constructor for class com.aliyun.odps.storage.models.TimestampUnit.TimestampUnitDeserializer

TimestampUnitSerializer() - Constructor for class com.aliyun.odps.storage.models.TimestampUnit.TimestampUnitSerializer

toString() - Method in exception com.aliyun.odps.storage.ClientException

toString() - Method in enum com.aliyun.odps.storage.models.SessionStatus

Converts SessionStatus to string.

toString() - Method in enum com.aliyun.odps.storage.models.SplitMode

toString() - Method in enum com.aliyun.odps.storage.models.TimestampUnit

toString() - Method in exception com.aliyun.odps.storage.ServiceException

transferTo(InputStream, OutputStream) - Static method in class com.aliyun.odps.storage.internal.utils.IOUtils

tunnelEndpoint(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Sets the MaxCompute tunnel endpoint.

U

uploadBlob(long, InputStream) - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

uploadBlob(long, InputStream) - Method in class com.aliyun.odps.storage.write.TableArrowWriter

userAgent(String) - Method in class com.aliyun.odps.storage.MaxStorageClient.Builder

Appends a custom string to the 'User-Agent' header for all MaxStorage requests.

V

valueOf(String) - Static method in enum com.aliyun.odps.storage.internal.models.BlobWriteItem.ChecksumType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.storage.models.SessionStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.storage.models.SplitMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.storage.models.TimestampUnit

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.aliyun.odps.storage.write.WriteMode

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.aliyun.odps.storage.internal.models.BlobWriteItem.ChecksumType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.storage.models.SessionStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.storage.models.SplitMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.storage.models.TimestampUnit

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.aliyun.odps.storage.write.WriteMode

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForNextRetry(int) - Method in class com.aliyun.odps.storage.internal.retry.NoRetryPolicy

waitForNextRetry(int) - Method in interface com.aliyun.odps.storage.internal.retry.RetryPolicy

Waits for the configured retry delay before the next attempt.

withArrowOptions(ArrowOptions) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the Arrow options for data processing.

withAsync(boolean) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withAsync(boolean) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withAsyncQueue(BlockingQueue<Object>) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withAsyncQueue(BlockingQueue<Object>) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withAutoFlushEnabled(boolean) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withBatchBlobUploadEnabled(boolean) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withBlobChecksumType(BlobWriteItem.ChecksumType) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withBucketIds(List<Integer>) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the required bucket IDs to read from the table.

withBufferSize(long) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withChecksum(BlobWriteItem.ChecksumType) - Method in class com.aliyun.odps.storage.internal.models.BlobWriteItem.Builder

Sets the checksum, automatically calculated from the provided data.

withColumns(List<String>) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withColumns(List<String>) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the required data columns to read from the table.

withConnectTimeout(Duration) - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Sets the connection timeout duration.

withCount(long) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withCredentialsProvider(ICredentialsProvider) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the credential provider.

withCrossPartition(boolean) - Method in class com.aliyun.odps.storage.settings.SplitOptions.SplitOptionsBuilder

Sets whether cross-partition splits are allowed.

withDataColumns(List<String>) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withDataColumnsUnordered(boolean) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withDataFormat(DataFormat) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withEnableLimit(boolean) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withEnableLimit(boolean) - Method in class com.aliyun.odps.storage.read.InstanceReadSessionBuilder

withEndpoint(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the endpoint.

withEndTimeStamp(String) - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Sets the end timestamp.

withEndVersion(long) - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Sets the end version.

withEstimatedRowCount(long) - Method in class com.aliyun.odps.storage.models.SessionStats.Builder

Sets the estimated row count.

withEstimatedSize(long) - Method in class com.aliyun.odps.storage.models.SessionStats.Builder

Sets the estimated data size in bytes.

withExecutorService(ExecutorService) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withFilter(String) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the filter for server-side data filtering.

withHttpSettings(HttpSettings) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the HTTP settings.

withIncrementalReadEnabled(boolean) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets whether to enable incremental read mode for the session.

withIncrementalReadOptions(IncrementalReadOptions) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the incremental read options for the read session.

withKeepAliveDuration(Duration) - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Sets the keep-alive duration for idle connections.

withMaxBatchRawSize(long) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withMaxBatchRows(long) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withMaxFilesPerSplit(int) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the maximum number of files per split for reading.

withMaxIdleConnections(int) - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Sets the maximum number of idle connections to keep in the connection pool.

withMode(String) - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Sets the mode for incremental read.

withOffset(long) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withOverwrite(boolean) - Method in class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Sets whether to overwrite existing data when writing to the table.

withPartition(PartitionSpec) - Method in class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Sets the partition specification for writing data to a specific partition.

withPartitionColumns(List<String>) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the required partition columns to read from the table.

withPartitions(List<PartitionSpec>) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the required partitions to read from the table.

withProject(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the current project.

withProxyConfig(ProxyConfig) - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Sets the proxy configuration.

withQueryId(long) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withQuota(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the quota.

withReadTimeout(Duration) - Method in class com.aliyun.odps.storage.settings.HttpSettings.HttpSettingsBuilder

Sets the read timeout duration.

withRegion(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the region.

withResume(boolean) - Method in class com.aliyun.odps.storage.write.TableWriterBuilder

withRetryHandler(RetryHandler) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the retry handler.

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest.AbortTableWriteSessionRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest.CloseWriteStreamRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest.GetTableReadSessionRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest.GetTableWriteSessionRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest.GetWriteStreamRequestBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.read.InstanceReadSessionBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

withSessionId(String) - Method in class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Set the sessionId to reload write session.

withSessionReadyTimeout(long) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the maximum time to wait for the session to be ready.

withSkipRowNum(long) - Method in class com.aliyun.odps.storage.read.TableReaderBuilder

withSplitMode(SplitMode) - Method in class com.aliyun.odps.storage.settings.SplitOptions.SplitOptionsBuilder

Sets the split mode.

withSplitOptions(SplitOptions) - Method in class com.aliyun.odps.storage.read.TableReadSessionBuilder

Sets the split options for parallel processing.

withSplitRowCount(long) - Method in class com.aliyun.odps.storage.settings.SplitOptions.SplitOptionsBuilder

Sets the split row count

withSplitSize(long) - Method in class com.aliyun.odps.storage.settings.SplitOptions.SplitOptionsBuilder

Sets the split raw size, unit Byte

withStartTimeStamp(String) - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Sets the start timestamp.

withStartVersion(long) - Method in class com.aliyun.odps.storage.settings.IncrementalReadOptions.Builder

Sets the start version.

withStreamId(String) - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest.CloseWriteStreamRequestBuilder

withStreamId(String) - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest.GetWriteStreamRequestBuilder

withStreamIds(List<String>) - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder

withStreamVersion(Long) - Method in class com.aliyun.odps.storage.internal.models.CloseWriteStreamRequest.CloseWriteStreamRequestBuilder

withStreamVersion(Long) - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest.GetWriteStreamRequestBuilder

withStreamVersions(List<Long>) - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder

withTableIdentifier(TableIdentifier) - Method in class com.aliyun.odps.storage.internal.models.AbortTableWriteSessionRequest.AbortTableWriteSessionRequestBuilder

withTableIdentifier(TableIdentifier) - Method in class com.aliyun.odps.storage.internal.models.CommitTableWriteSessionRequest.CommitTableWriteSessionRequestBuilder

withTableIdentifier(TableIdentifier) - Method in class com.aliyun.odps.storage.internal.models.GetTableReadSessionRequest.GetTableReadSessionRequestBuilder

withTableIdentifier(TableIdentifier) - Method in class com.aliyun.odps.storage.internal.models.GetTableWriteSessionRequest.GetTableWriteSessionRequestBuilder

withTableIdentifier(TableIdentifier) - Method in class com.aliyun.odps.storage.internal.models.GetWriteStreamRequest.GetWriteStreamRequestBuilder

withTaskName(String) - Method in class com.aliyun.odps.storage.read.InstanceReaderBuilder

withTunnelEndpoint(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the tunnelEndpoint.

withType(String) - Method in class com.aliyun.odps.storage.models.DataFormat.Builder

Sets the data format type.

withUserAgent(String) - Method in class com.aliyun.odps.storage.internal.StubSettings.StubSettingsBuilder

Sets the request user agent

withVersion(String) - Method in class com.aliyun.odps.storage.models.DataFormat.Builder

Sets the data format version.

withWriteMode(WriteMode) - Method in class com.aliyun.odps.storage.write.TableWriteSessionBuilder

Sets the write mode for the session.

wrapForCompression(OutputStream, CompressionCodec) - Method in class com.aliyun.odps.storage.internal.StorageStub

Wraps a target OutputStream with a compression layer.

write(Record) - Method in class com.aliyun.odps.storage.write.AppendTableRecordWriter

write(Record) - Method in class com.aliyun.odps.storage.write.DeltaTableRecordWriter

writeBatch(VectorSchemaRoot) - Method in class com.aliyun.odps.storage.write.TableArrowBatchBlobWriter

writeBatch(VectorSchemaRoot) - Method in class com.aliyun.odps.storage.write.TableArrowWriter

writeBlobs(List<BlobWriteItem>) - Static method in class com.aliyun.odps.storage.internal.models.BlobWriteItem

A highly efficient utility method to serialize a list of BlobWriteItems into a single byte stream.

WriteMode - Enum in com.aliyun.odps.storage.write

Enum representing the write mode for table write sessions.

WriteSchema - Class in com.aliyun.odps.storage.internal.models

WriteSchema() - Constructor for class com.aliyun.odps.storage.internal.models.WriteSchema

WriteSchemaDeserializer - Class in com.aliyun.odps.storage.internal.serializer

WriteSchemaDeserializer() - Constructor for class com.aliyun.odps.storage.internal.serializer.WriteSchemaDeserializer

writeTable(TableIdentifier, String, String, long, long, RequestBody, String, String, Long) - Method in class com.aliyun.odps.storage.internal.StorageStub

writeTo(BufferedSink) - Method in class com.aliyun.odps.storage.internal.io.RawArrowRequestBody

A B C D E F G H I J L M N O P Q R S T U V W