org.apache.paimon.flink.sink

Class CompactorSink

java.lang.Object

org.apache.paimon.flink.sink.FlinkSink<org.apache.flink.table.data.RowData>

org.apache.paimon.flink.sink.CompactorSink

All Implemented Interfaces:

Serializable

public class CompactorSink
extends FlinkSink<org.apache.flink.table.data.RowData>

FlinkSink for dedicated compact jobs.

See Also:

Serialized Form

Field Summary

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

table

Constructor Summary

Constructors

Constructor and Description
CompactorSink(FileStoreTable table, boolean fullCompaction)

Method Summary

Modifier and Type	Method and Description
protected CommittableStateManager<ManifestCommittable>	createCommittableStateManager()
protected Committer.Factory<Committable,ManifestCommittable>	createCommitterFactory()
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.table.data.RowData,Committable>	createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)

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

CompactorSink

public CompactorSink(FileStoreTable table,
                     boolean fullCompaction)

Method Detail

createWriteOperatorFactory

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

Specified by:

createWriteOperatorFactory in class FlinkSink<org.apache.flink.table.data.RowData>

createCommitterFactory

protected Committer.Factory<Committable,ManifestCommittable> createCommitterFactory()

Specified by:

createCommitterFactory in class FlinkSink<org.apache.flink.table.data.RowData>

createCommittableStateManager

protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()

Specified by:

createCommittableStateManager in class FlinkSink<org.apache.flink.table.data.RowData>