Uses of Class
org.apache.paimon.flink.sink.StoreSinkWriteState

Packages that use StoreSinkWriteState

Package	Description
org.apache.paimon.flink.sink

Uses of StoreSinkWriteState in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as StoreSinkWriteState

Modifier and Type	Field and Description
protected StoreSinkWriteState	StoreSinkWriteImpl.state

Methods in org.apache.paimon.flink.sink with parameters of type StoreSinkWriteState

Modifier and Type	Method and Description
StoreSinkWrite	StoreSinkWrite.WithWriteBufferProvider.provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, MemoryPoolFactory memoryPoolFactory, org.apache.flink.metrics.MetricGroup metricGroup)
StoreSinkWrite	StoreSinkWrite.Provider.provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)

Constructors in org.apache.paimon.flink.sink with parameters of type StoreSinkWriteState

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