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

Packages that use StoreSinkWrite.WithWriteBufferProvider

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

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

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcMultiplexRecord,MultiTableCommittable>	FlinkCdcMultiTableSink.createWriteOperator(StoreSinkWrite.WithWriteBufferProvider writeProvider, String commitUser)
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkCdcMultiTableSink.sinkFrom(org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord> input, String commitUser, StoreSinkWrite.WithWriteBufferProvider sinkProvider)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type StoreSinkWrite.WithWriteBufferProvider

Constructor and Description
CdcRecordStoreMultiWriteOperator(Catalog.Loader catalogLoader, StoreSinkWrite.WithWriteBufferProvider storeSinkWriteProvider, String initialCommitUser, Options options)