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

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.OneInputStreamOperator<InternalRow,Committable>	FixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable>	UnawareBucketCompactionSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable>	RewriteFileIndexSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	RowDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperator<T,Committable>	FlinkSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable>	CompactorSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	RowUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

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

Constructor and Description
DynamicBucketRowWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
RowDataStoreWriteOperator(FileStoreTable table, LogSinkFunction logSinkFunction, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
StoreCompactOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
TableWriteOperator(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.OneInputStreamOperator<CdcRecord,Committable>	CdcFixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable>	CdcUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable>	CdcDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

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

Constructor and Description
CdcDynamicBucketWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
CdcRecordStoreWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
CdcUnawareBucketWriteOperator(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.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	GlobalDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)