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

Packages that use StoreSinkWrite.Provider

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

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

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

Modifier and Type	Field and Description
protected StoreSinkWrite.Provider	TableWriteOperator.Factory.storeSinkWriteProvider

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<InternalRow,Committable>	RowUnawareBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<UnawareAppendCompactionTask,Committable>	UnawareBucketCompactionSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.table.data.RowData,Committable>	CompactorSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<ManifestEntry,Committable>	RewriteFileIndexSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<T,Committable>	FlinkSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	RowDynamicBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<InternalRow,Committable>	FixedBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)

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

Constructor and Description
Factory(FileStoreTable table, LogSinkFunction logSinkFunction, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser, boolean fullCompaction)
RowDataStoreWriteOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Committable> parameters, FileStoreTable table, LogSinkFunction logSinkFunction, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
TableWriteOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Committable> parameters, FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)

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

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<CdcRecord,Committable>	CdcFixedBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable>	CdcDynamicBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<CdcRecord,Committable>	CdcUnawareBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)

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

Constructor and Description
CdcRecordStoreWriteOperator(org.apache.flink.streaming.api.operators.StreamOperatorParameters<Committable> parameters, FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
Factory(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)

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

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	GlobalDynamicBucketSink.createWriteOperatorFactory(StoreSinkWrite.Provider writeProvider, String commitUser)