public class CompactorSink extends FlinkSink<org.apache.flink.table.data.RowData>
FlinkSink
for dedicated compact jobs.Constructor and Description |
---|
CompactorSink(FileStoreTable table,
boolean fullCompaction) |
Modifier and Type | Method and Description |
---|---|
protected CommittableStateManager<ManifestCommittable> |
createCommittableStateManager() |
protected Committer.Factory<Committable,ManifestCommittable> |
createCommitterFactory() |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> |
createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, doCommit, doWrite, isStreaming, isStreaming, sinkFrom, sinkFrom
public CompactorSink(FileStoreTable table, boolean fullCompaction)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
createWriteOperator
in class FlinkSink<org.apache.flink.table.data.RowData>
protected Committer.Factory<Committable,ManifestCommittable> createCommitterFactory()
createCommitterFactory
in class FlinkSink<org.apache.flink.table.data.RowData>
protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()
createCommittableStateManager
in class FlinkSink<org.apache.flink.table.data.RowData>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.