org.apache.paimon.flink.sink

Class RewriteFileIndexSink

java.lang.Object

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

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

org.apache.paimon.flink.sink.RewriteFileIndexSink

All Implemented Interfaces:

Serializable

public class RewriteFileIndexSink
extends FlinkWriteSink<ManifestEntry>

File index sink for RewriteFileIndexProcedure.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RewriteFileIndexSink.FileIndexProcessor Does the file index rewrite.

Field Summary

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

table

Constructor Summary

Constructors

Constructor and Description
RewriteFileIndexSink(FileStoreTable table)

Method Summary

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable>	createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

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

createCommittableStateManager, createCommitterFactory

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

assertBatchAdaptiveParallelism, 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

RewriteFileIndexSink

public RewriteFileIndexSink(FileStoreTable table)

Method Detail

createWriteOperator

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

Specified by:

createWriteOperator in class FlinkSink<ManifestEntry>