com.aliyun.odps.storage.read

Class InstanceReadSessionBuilder

java.lang.Object

com.aliyun.odps.storage.read.InstanceReadSessionBuilder

public class InstanceReadSessionBuilder
extends Object

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

This builder allows configuration of instance read session settings including:

• Data column selection
• Split options for parallel processing
• Arrow-specific options
• Filter predicates for data filtering

Constructor Summary

Constructors

Constructor and Description
InstanceReadSessionBuilder(StorageStub storageStub, org.apache.arrow.memory.BufferAllocator allocator, InstanceIdentifier instance) Constructs a new InstanceReadSessionBuilder with the provided parameters.

Method Summary

Modifier and Type	Method and Description
InstanceReadSession	build() Builds and returns a new InstanceReadSession instance with the configured settings.
InstanceIdentifier	getInstance() Gets the instance identifier for this builder.
InstanceReadSessionBuilder	withEnableLimit(boolean enableLimit)
InstanceReadSessionBuilder	withSessionId(String sessionId)

Methods inherited from class java.lang.Object

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

Constructor Detail

InstanceReadSessionBuilder

public InstanceReadSessionBuilder(StorageStub storageStub,
                                  org.apache.arrow.memory.BufferAllocator allocator,
                                  InstanceIdentifier instance)

Constructs a new InstanceReadSessionBuilder with the provided parameters.

Parameters:

storageStub - The storage stub for communicating with the MaxCompute service

allocator - The buffer allocator for Arrow memory management

instance - The identifier of the instance to read from

Throws:

IllegalArgumentException - if instance is null

Method Detail

withSessionId

public InstanceReadSessionBuilder withSessionId(String sessionId)

withEnableLimit

public InstanceReadSessionBuilder withEnableLimit(boolean enableLimit)

build

public InstanceReadSession build()

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

This method makes an API call to the MaxCompute service to create a read session with the specified configuration. The session can then be used to read data from the instance in a distributed manner.

Returns:

A new InstanceReadSession instance

getInstance

public InstanceIdentifier getInstance()

Gets the instance identifier for this builder.

Returns:

The instance identifier.