com.aliyun.odps.storage.settings

Class SplitOptions

java.lang.Object

com.aliyun.odps.storage.settings.SplitOptions

public class SplitOptions
extends Object

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

This class defines the strategy for splitting data into chunks for parallel processing. It allows configuration of split mode, unit, number, and whether to allow cross-partition splits.

Example usage:

 SplitOptions splitOptions = SplitOptions.newBuilder()
     .withSplitMode(SplitMode.Size)
     .withSplitUnit("ByteSize")
     .withSplitNumber(256 * 1024 * 1024)
     .withCrossPartition(true)
     .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplitOptions.SplitOptionsBuilder

Method Summary

Modifier and Type	Method and Description
SplitMode	getSplitMode() Gets the split mode.
long	getSplitNumber() Gets the split number.
String	getSplitUnit() Gets the split unit.
boolean	isCrossPartition() Checks if cross-partition splits are allowed.
static SplitOptions.SplitOptionsBuilder	newBuilder()
void	setCrossPartition(boolean crossPartition) Sets whether cross-partition splits are allowed.
void	setSplitMode(SplitMode splitMode) Sets the split mode.
void	setSplitNumber(long splitNumber) Sets the split number.
void	setSplitUnit(String splitUnit) Sets the split unit.

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static SplitOptions.SplitOptionsBuilder newBuilder()

getSplitMode

public SplitMode getSplitMode()

Gets the split mode.

Returns:

The split mode

setSplitMode

public void setSplitMode(SplitMode splitMode)

Sets the split mode.

Parameters:

splitMode - The split mode

getSplitUnit

public String getSplitUnit()

Gets the split unit.

Returns:

The split unit

setSplitUnit

public void setSplitUnit(String splitUnit)

Sets the split unit.

Parameters:

splitUnit - The split unit

getSplitNumber

public long getSplitNumber()

Gets the split number.

Returns:

The split number

setSplitNumber

public void setSplitNumber(long splitNumber)

Sets the split number.

Parameters:

splitNumber - The split number

isCrossPartition

public boolean isCrossPartition()

Checks if cross-partition splits are allowed.

Returns:

true if cross-partition splits are allowed, false otherwise

setCrossPartition

public void setCrossPartition(boolean crossPartition)

Sets whether cross-partition splits are allowed.

Parameters:

crossPartition - true to allow cross-partition splits, false otherwise