org.apache.paimon.flink.sink

Class AsyncLookupSinkWrite

java.lang.Object

org.apache.paimon.flink.sink.StoreSinkWriteImpl

org.apache.paimon.flink.sink.AsyncLookupSinkWrite

All Implemented Interfaces:

StoreSinkWrite

public class AsyncLookupSinkWrite
extends StoreSinkWriteImpl

StoreSinkWrite for tables with lookup changelog producer and CoreOptions.LOOKUP_WAIT set to false.

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
AsyncLookupSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)

Method Summary

Modifier and Type	Method and Description
void	snapshotState()

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

close, compact, getWrite, notifyNewFiles, prepareCommit, replace, streamingMode, toLogRecord, withCompactExecutor, withInsertOnly, write, write

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncLookupSinkWrite

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

Method Detail

snapshotState

public void snapshotState()
                   throws Exception

Specified by:

snapshotState in interface StoreSinkWrite

Overrides:

snapshotState in class StoreSinkWriteImpl

Throws:

Exception