Package org.apache.flink.cdc.connectors.maxcompute.options

Class MaxComputeWriteOptions.Builder

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeWriteOptions.Builder

Enclosing class:

MaxComputeWriteOptions

public static class MaxComputeWriteOptions.Builder
extends Object

builder for maxcompute write options.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
MaxComputeWriteOptions	build()
MaxComputeWriteOptions.Builder	withCompressAlgorithm(CompressAlgorithm compressAlgorithm)
MaxComputeWriteOptions.Builder	withFlushConcurrent(int flushConcurrent)
MaxComputeWriteOptions.Builder	withMaxBufferSize(long maxBufferSize)
MaxComputeWriteOptions.Builder	withNumCommitThread(int numCommitThread)
MaxComputeWriteOptions.Builder	withSlotBufferSize(long slotBufferSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

withFlushConcurrent

public MaxComputeWriteOptions.Builder withFlushConcurrent(int flushConcurrent)

withMaxBufferSize

public MaxComputeWriteOptions.Builder withMaxBufferSize(long maxBufferSize)

withSlotBufferSize

public MaxComputeWriteOptions.Builder withSlotBufferSize(long slotBufferSize)

withNumCommitThread

public MaxComputeWriteOptions.Builder withNumCommitThread(int numCommitThread)

withCompressAlgorithm

public MaxComputeWriteOptions.Builder withCompressAlgorithm(CompressAlgorithm compressAlgorithm)

build

public MaxComputeWriteOptions build()