org.apache.paimon.flink.sink

Class GlobalFullCompactionSinkWrite

java.lang.Object

org.apache.paimon.flink.sink.StoreSinkWriteImpl

org.apache.paimon.flink.sink.GlobalFullCompactionSinkWrite

All Implemented Interfaces:

StoreSinkWrite

public class GlobalFullCompactionSinkWrite
extends StoreSinkWriteImpl

StoreSinkWrite for execute full compaction globally. All writers will be full compaction at the same time (in the specified checkpoint).

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.flink.sink.StoreSinkWrite

StoreSinkWrite.Provider, StoreSinkWrite.WithWriteBufferProvider

Field Summary

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

commitUser, state, write

Constructor Summary

Constructors

Constructor and Description
GlobalFullCompactionSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, int deltaCommits, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

Modifier and Type	Method and Description
void	compact(BinaryRow partition, int bucket, boolean fullCompaction)
List<Committable>	prepareCommit(boolean waitCompaction, long checkpointId)
void	snapshotState()
SinkRecord	write(InternalRow rowData)
SinkRecord	write(InternalRow rowData, int bucket)

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

close, getWrite, notifyNewFiles, replace, streamingMode, toLogRecord, withCompactExecutor, withInsertOnly

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GlobalFullCompactionSinkWrite

public GlobalFullCompactionSinkWrite(FileStoreTable table,
                                     String commitUser,
                                     StoreSinkWriteState state,
                                     org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager,
                                     boolean ignorePreviousFiles,
                                     boolean waitCompaction,
                                     int deltaCommits,
                                     boolean isStreaming,
                                     @Nullable
                                     MemorySegmentPool memoryPool,
                                     org.apache.flink.metrics.MetricGroup metricGroup)

Method Detail

write

@Nullable
public SinkRecord write(InternalRow rowData)
                           throws Exception

Specified by:

write in interface StoreSinkWrite

Overrides:

write in class StoreSinkWriteImpl

Throws:

Exception

write

@Nullable
public SinkRecord write(InternalRow rowData,
                                  int bucket)
                           throws Exception

Specified by:

write in interface StoreSinkWrite

Overrides:

write in class StoreSinkWriteImpl

Throws:

Exception

compact

public void compact(BinaryRow partition,
                    int bucket,
                    boolean fullCompaction)
             throws Exception

Specified by:

compact in interface StoreSinkWrite

Overrides:

compact in class StoreSinkWriteImpl

Throws:

Exception

prepareCommit

public List<Committable> prepareCommit(boolean waitCompaction,
                                       long checkpointId)
                                throws IOException

Specified by:

prepareCommit in interface StoreSinkWrite

Overrides:

prepareCommit in class StoreSinkWriteImpl

Throws:

IOException

snapshotState

public void snapshotState()
                   throws Exception

Specified by:

snapshotState in interface StoreSinkWrite

Overrides:

snapshotState in class StoreSinkWriteImpl

Throws:

Exception