Uses of Class
org.apache.paimon.flink.sink.PrepareCommitOperator.Factory

Packages that use PrepareCommitOperator.Factory

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

Uses of PrepareCommitOperator.Factory in org.apache.paimon.flink.sink

Subclasses of PrepareCommitOperator.Factory in org.apache.paimon.flink.sink

Modifier and Type	Class and Description
static class	AppendBypassCompactWorkerOperator.Factory StreamOperatorFactory of AppendBypassCompactWorkerOperator.
protected static class	AppendCompactWorkerOperator.Factory<IN> StreamOperatorFactory of AppendCompactWorkerOperator.
static class	AppendOnlyMultiTableCompactionWorkerOperator.Factory StreamOperatorFactory of AppendOnlyMultiTableCompactionWorkerOperator.
static class	AppendOnlySingleTableCompactionWorkerOperator.Factory StreamOperatorFactory of AppendOnlySingleTableCompactionWorkerOperator.
static class	DynamicBucketRowWriteOperator.Factory StreamOperatorFactory of DynamicBucketRowWriteOperator.
static class	MultiTablesStoreCompactOperator.Factory StreamOperatorFactory of MultiTablesStoreCompactOperator.
static class	PostponeBucketTableWriteOperator.Factory Factory to create PostponeBucketTableWriteOperator.
static class	RowDataStoreWriteOperator.Factory StreamOperatorFactory of RowDataStoreWriteOperator.
static class	StoreCompactOperator.Factory StreamOperatorFactory of StoreCompactOperator.
protected static class	TableWriteOperator.Factory<IN> StreamOperatorFactory of TableWriteOperator.

Uses of PrepareCommitOperator.Factory in org.apache.paimon.flink.sink.cdc

Subclasses of PrepareCommitOperator.Factory in org.apache.paimon.flink.sink.cdc

Modifier and Type	Class and Description
static class	CdcDynamicBucketWriteOperator.Factory StreamOperatorFactory of CdcDynamicBucketWriteOperator.
static class	CdcRecordStoreMultiWriteOperator.Factory StreamOperatorFactory of CdcRecordStoreMultiWriteOperator.
static class	CdcRecordStoreWriteOperator.Factory StreamOperatorFactory of CdcRecordStoreWriteOperator.
static class	CdcUnawareBucketWriteOperator.Factory StreamOperatorFactory of CdcUnawareBucketWriteOperator.