Class MaxComputeWriteOptions
- java.lang.Object
-
- org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeWriteOptions
-
- All Implemented Interfaces:
Serializable
public class MaxComputeWriteOptions extends Object implements Serializable
extended options for maxcompute.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classMaxComputeWriteOptions.Builderbuilder for maxcompute write options.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static MaxComputeWriteOptions.Builderbuilder()StringgetCompressAlgorithm()intgetFlushConcurrent()longgetMaxBufferSize()intgetNumCommitThread()longgetSlotBufferSize()
-
-
-
Method Detail
-
builder
public static MaxComputeWriteOptions.Builder builder()
-
getFlushConcurrent
public int getFlushConcurrent()
-
getMaxBufferSize
public long getMaxBufferSize()
-
getSlotBufferSize
public long getSlotBufferSize()
-
getNumCommitThread
public int getNumCommitThread()
-
getCompressAlgorithm
public String getCompressAlgorithm()
-
-