org.apache.paimon.flink.sink.cdc

Class CdcUnawareBucketSink

java.lang.Object

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

org.apache.paimon.flink.sink.FlinkWriteSink<CdcRecord>

org.apache.paimon.flink.sink.cdc.CdcUnawareBucketSink

All Implemented Interfaces:

Serializable

public class CdcUnawareBucketSink
extends FlinkWriteSink<CdcRecord>

CDC Sink for unaware bucket table. It should not add compaction node, because the compaction may have old schema.

See Also:

Serialized Form

Field Summary

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

table

Constructor Summary

Constructors

Constructor and Description
CdcUnawareBucketSink(FileStoreTable table, Integer parallelism)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<CdcRecord,Committable>	createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
org.apache.flink.streaming.api.datastream.DataStream<Committable>	doWrite(org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> input, String initialCommitUser, Integer parallelism)

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, isStreaming, isStreaming, sinkFrom, sinkFrom

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcUnawareBucketSink

public CdcUnawareBucketSink(FileStoreTable table,
                            Integer parallelism)

Method Detail

createWriteOperatorFactory

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

Specified by:

createWriteOperatorFactory in class FlinkSink<CdcRecord>

doWrite

public org.apache.flink.streaming.api.datastream.DataStream<Committable> doWrite(org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> input,
                                                                                 String initialCommitUser,
                                                                                 @Nullable
                                                                                 Integer parallelism)

Overrides:

doWrite in class FlinkSink<CdcRecord>