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

Packages that use PrepareCommitOperator

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

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

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

Modifier and Type	Class and Description
class	AppendBypassCompactWorkerOperator A AppendCompactWorkerOperator to bypass Committable inputs.
class	AppendCompactWorkerOperator<IN> An abstract Operator to execute UnawareAppendCompactionTask passed from BucketUnawareCompactSource for compacting table.
class	AppendOnlyMultiTableCompactionWorkerOperator Operator to execute UnawareAppendCompactionTask passed for support compacting multi unaware bucket tables in combined mode.
class	AppendOnlySingleTableCompactionWorkerOperator Operator to execute UnawareAppendCompactionTask passed from BucketUnawareCompactSource for compacting single unaware bucket tables in divided mode.
class	DynamicBucketRowWriteOperator A PrepareCommitOperator to write InternalRow with bucket.
class	MultiTablesStoreCompactOperator A dedicated operator for manual triggered compaction.
class	RowDataStoreWriteOperator A PrepareCommitOperator to write InternalRow.
class	StoreCompactOperator A dedicated operator for manual triggered compaction.
class	TableWriteOperator<IN> An abstract class for table write operator.

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

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

Modifier and Type	Class and Description
class	CdcDynamicBucketWriteOperator A PrepareCommitOperator to write CdcRecord with bucket.
class	CdcRecordStoreMultiWriteOperator A PrepareCommitOperator to write CdcRecord.
class	CdcRecordStoreWriteOperator A PrepareCommitOperator to write CdcRecord.
class	CdcUnawareBucketWriteOperator A PrepareCommitOperator to write CdcRecord to unaware-bucket mode table.