Uses of Interface
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

Classes in org.apache.paimon.flink.sink that implement StoreSinkWriteState

Modifier and Type	Class and Description
class	NoopStoreSinkWriteState A StoreSinkWriteState which stores nothing.
class	StoreSinkWriteStateImpl Default implementation for StoreSinkWriteState.

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 that return StoreSinkWriteState

Modifier and Type	Method and Description
protected StoreSinkWriteState	TableWriteOperator.createState(org.apache.flink.runtime.state.StateInitializationContext context, StoreSinkWriteState.StateValueFilter stateFilter)

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) TODO: The argument list has become too complicated.
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) TODO: The argument list has become too complicated.

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)