org.apache.paimon.flink.sink

Class UnawareBucketCompactionSink

java.lang.Object

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

org.apache.paimon.flink.sink.UnawareBucketCompactionSink

All Implemented Interfaces:

Serializable

public class UnawareBucketCompactionSink
extends FlinkSink<UnawareAppendCompactionTask>

Compaction Sink for unaware-bucket table.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UnawareBucketCompactionSink(FileStoreTable table)

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.OneInputStreamOperator<UnawareAppendCompactionTask,Committable>	createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
static org.apache.flink.streaming.api.datastream.DataStreamSink<?>	sink(FileStoreTable table, org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input)

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

UnawareBucketCompactionSink

public UnawareBucketCompactionSink(FileStoreTable table)

Method Detail

sink

public static org.apache.flink.streaming.api.datastream.DataStreamSink<?> sink(FileStoreTable table,
                                                                               org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input)

createWriteOperator

protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable> createWriteOperator(StoreSinkWrite.Provider writeProvider,
                                                                                                                                       String commitUser)

Specified by:

createWriteOperator in class FlinkSink<UnawareAppendCompactionTask>

createCommitterFactory

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

Specified by:

createCommitterFactory in class FlinkSink<UnawareAppendCompactionTask>

createCommittableStateManager

protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()

Specified by:

createCommittableStateManager in class FlinkSink<UnawareAppendCompactionTask>