org.apache.paimon.flink.sink

Class FlinkWriteSink<T>

java.lang.Object

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

org.apache.paimon.flink.sink.FlinkWriteSink<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

CdcFixedBucketSink, DynamicBucketSink, FixedBucketSink, GlobalDynamicBucketSink, RewriteFileIndexSink, UnawareBucketSink

public abstract class FlinkWriteSink<T>
extends FlinkSink<T>

A FlinkSink to write records.

See Also:

Serialized Form

Field Summary

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

table

Constructor Summary

Constructors

Constructor and Description
FlinkWriteSink(FileStoreTable table, Map<String,String> overwritePartition)

Method Summary

Modifier and Type	Method and Description
protected CommittableStateManager<ManifestCommittable>	createCommittableStateManager()
protected Committer.Factory<Committable,ManifestCommittable>	createCommitterFactory()

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

assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertBatchAdaptiveParallelism, assertStreamingConfiguration, configureGlobalCommitter, createWriteOperator, 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

FlinkWriteSink

public FlinkWriteSink(FileStoreTable table,
                      @Nullable
                      Map<String,String> overwritePartition)

Method Detail

createCommitterFactory

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

Specified by:

createCommitterFactory in class FlinkSink<T>

createCommittableStateManager

protected CommittableStateManager<ManifestCommittable> createCommittableStateManager()

Specified by:

createCommittableStateManager in class FlinkSink<T>