public class CdcFixedBucketSink extends FlinkWriteSink<CdcRecord>
FlinkSink
for fixed-bucket table which accepts CdcRecord
and waits for a schema
change if necessary.Constructor and Description |
---|
CdcFixedBucketSink(FileStoreTable table) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
createCommittableStateManager, createCommitterFactory
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public CdcFixedBucketSink(FileStoreTable table)
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.