org.apache.paimon.flink.sink.cdc

Class CdcDynamicBucketSink

java.lang.Object

org.apache.paimon.flink.sink.FlinkSink<T>

org.apache.paimon.flink.sink.FlinkWriteSink<org.apache.flink.api.java.tuple.Tuple2<T,Integer>>

org.apache.paimon.flink.sink.DynamicBucketSink<T>

org.apache.paimon.flink.sink.cdc.CdcDynamicBucketSinkBase<CdcRecord>

org.apache.paimon.flink.sink.cdc.CdcDynamicBucketSink

All Implemented Interfaces:

Serializable

public class CdcDynamicBucketSink
extends CdcDynamicBucketSinkBase<CdcRecord>

CdcDynamicBucketSinkBase for CdcRecord.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.sink.FlinkSink

table

Constructor Summary

Constructors

Constructor and Description
CdcDynamicBucketSink(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
protected KeyAndBucketExtractor<CdcRecord>	createExtractor(TableSchema schema)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable>	createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)

Methods inherited from class org.apache.paimon.flink.sink.cdc.CdcDynamicBucketSinkBase

assignerChannelComputer, channelComputer2, extractorFunction

Methods inherited from class org.apache.paimon.flink.sink.DynamicBucketSink

build, createHashBucketAssignerOperator

Methods inherited from class org.apache.paimon.flink.sink.FlinkWriteSink

createCommittableStateManager, createCommitterFactory

Methods inherited from class org.apache.paimon.flink.sink.FlinkSink

assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcDynamicBucketSink

public CdcDynamicBucketSink(FileStoreTable table)

Method Detail

createExtractor

protected KeyAndBucketExtractor<CdcRecord> createExtractor(TableSchema schema)

Specified by:

createExtractor in class CdcDynamicBucketSinkBase<CdcRecord>

createWriteOperatorFactory

protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable> createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider,
                                                                                                                                                                                   String commitUser)

Specified by:

createWriteOperatorFactory in class FlinkSink<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>>