Uses of Interface
org.apache.paimon.flink.sink.StoreSinkWrite

Packages that use StoreSinkWrite

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc

Uses of StoreSinkWrite in org.apache.paimon.flink

Methods in org.apache.paimon.flink with parameters of type StoreSinkWrite

Modifier and Type	Method and Description
static void	ProcessRecordAttributesUtil.processWithWrite(RecordAttributes recordAttributes, StoreSinkWrite write)

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

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

Modifier and Type	Class and Description
class	AsyncLookupSinkWrite StoreSinkWrite for tables with lookup changelog producer and CoreOptions.LOOKUP_WAIT set to false.
class	GlobalFullCompactionSinkWrite StoreSinkWrite for execute full compaction globally.
class	StoreSinkWriteImpl Default implementation of StoreSinkWrite.

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

Modifier and Type	Field and Description
protected StoreSinkWrite	TableWriteOperator.write

Fields in org.apache.paimon.flink.sink with type parameters of type StoreSinkWrite

Modifier and Type	Field and Description
protected Map<Identifier,StoreSinkWrite>	MultiTablesStoreCompactOperator.writes

Methods in org.apache.paimon.flink.sink that return StoreSinkWrite

Modifier and Type	Method and Description
StoreSinkWrite	TableWriteOperator.getWrite()
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.

Uses of StoreSinkWrite in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type StoreSinkWrite

Modifier and Type	Method and Description
Map<Identifier,StoreSinkWrite>	CdcRecordStoreMultiWriteOperator.writes()