public class CdcUnawareBucketSink extends FlinkWriteSink<CdcRecord>
Constructor and Description |
---|
CdcUnawareBucketSink(FileStoreTable table,
Integer parallelism) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable> |
createWriteOperator(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) |
createCommittableStateManager, createCommitterFactory
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, isStreaming, isStreaming, sinkFrom, sinkFrom
public CdcUnawareBucketSink(FileStoreTable table, Integer parallelism)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
createWriteOperator
in class FlinkSink<CdcRecord>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.