public class TableWriterBuilder extends Object
This builder creates Arrow writers that can write data to MaxCompute tables using the Arrow columnar format. The writer supports various compression codecs for efficient data transfer.
TableArrowWriter| Modifier and Type | Method and Description |
|---|---|
ArrowWriter |
build()
Builds and returns a new ArrowWriter instance with the configured settings.
|
org.apache.arrow.memory.BufferAllocator |
getAllocator() |
BlobWriteItem.ChecksumType |
getBlobChecksumType() |
long |
getBufferSize() |
ExecutorService |
getExecutorService() |
String |
getSessionId() |
PartitionSpec |
getStaticPartitionSpec() |
StorageStub |
getStorageStub() |
String |
getStreamId() |
long |
getStreamVersion() |
TableIdentifier |
getTableId() |
WriteMode |
getWriteMode() |
boolean |
isAutoFlushEnabled() |
TableWriterBuilder |
withAutoFlushEnabled(boolean enabled) |
TableWriterBuilder |
withBatchBlobUploadEnabled(boolean enabled) |
TableWriterBuilder |
withBlobChecksumType(BlobWriteItem.ChecksumType blobChecksumType) |
TableWriterBuilder |
withBufferSize(long bufferSize) |
TableWriterBuilder |
withExecutorService(ExecutorService executorService) |
TableWriterBuilder |
withResume(boolean resume) |
public TableWriterBuilder withBufferSize(long bufferSize)
public TableWriterBuilder withBatchBlobUploadEnabled(boolean enabled)
public TableWriterBuilder withBlobChecksumType(BlobWriteItem.ChecksumType blobChecksumType)
public TableWriterBuilder withAutoFlushEnabled(boolean enabled)
public TableWriterBuilder withResume(boolean resume)
public TableWriterBuilder withExecutorService(ExecutorService executorService)
public ArrowWriter build()
This method makes an API call to the MaxCompute service to create a write stream with the specified configuration. The writer can then be used to write Arrow data to the table.
MaxStorageException - if unable to create the writerpublic TableIdentifier getTableId()
public PartitionSpec getStaticPartitionSpec()
public String getSessionId()
public StorageStub getStorageStub()
public org.apache.arrow.memory.BufferAllocator getAllocator()
public long getBufferSize()
public String getStreamId()
public long getStreamVersion()
public BlobWriteItem.ChecksumType getBlobChecksumType()
public boolean isAutoFlushEnabled()
public ExecutorService getExecutorService()
public WriteMode getWriteMode()
Copyright © 2026 Alibaba Cloud Computing. All rights reserved.