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

Interface Summary

Interface	Description
EventParser<T>	Parse a CDC change event to a list of DataFields or CdcRecord.
EventParser.Factory<T>	Factory to create an EventParser.

Class Summary

Class	Description
CaseSensitiveUtils	Add convert operator if the catalog is case-insensitive.
CdcDynamicBucketSink	CdcDynamicBucketSinkBase for CdcRecord.
CdcDynamicBucketSinkBase<T>	CDC sink for dynamic bucket table.
CdcDynamicBucketWriteOperator	A PrepareCommitOperator to write CdcRecord with bucket.
CdcDynamicTableParsingProcessFunction<T>	A ProcessFunction to parse CDC change event to either a list of DataFields or CdcRecord and send them to different side outputs according to table name.
CdcFixedBucketChannelComputerBase<T>	ChannelComputer for distributing CDC records into writers for fixed-bucket mode tables.
CdcFixedBucketSink	A FlinkSink for fixed-bucket table which accepts CdcRecord and waits for a schema change if necessary.
CdcMultiplexRecord	A data change message from the CDC source.
CdcMultiplexRecordChannelComputer	ChannelComputer for CdcMultiplexRecord.
CdcMultiTableParsingProcessFunction<T>	A ProcessFunction to parse CDC change event to either a list of DataFields or CdcRecord and send them to different side outputs according to table name.
CdcParsingProcessFunction<T>	A ProcessFunction to parse CDC change event to either a list of DataFields or CdcRecord and send them to different downstreams.
CdcRecord	A data change message from the CDC source.
CdcRecordChannelComputer	CdcFixedBucketChannelComputerBase for CdcRecord.
CdcRecordKeyAndBucketExtractor	KeyAndBucketExtractor for CdcRecord.
CdcRecordPartitionKeyExtractor	A PartitionKeyExtractor to InternalRow.
CdcRecordStoreMultiWriteOperator	A PrepareCommitOperator to write CdcRecord.
CdcRecordStoreWriteOperator	A PrepareCommitOperator to write CdcRecord.
CdcRecordUtils	Utils for CdcRecord.
CdcSinkBuilder<T>	Builder for sink when syncing records into one Paimon table.
CdcUnawareBucketSink	CDC Sink for unaware bucket table.
CdcUnawareBucketWriteOperator	A PrepareCommitOperator to write CdcRecord to unaware-bucket mode table.
FlinkCdcMultiTableSink	A FlinkSink which accepts CdcRecord and waits for a schema change if necessary.
FlinkCdcSyncDatabaseSinkBuilder<T>	Builder for CDC FlinkWriteSink when syncing the whole database into one Paimon database.
MultiTableUpdatedDataFieldsProcessFunction	A ProcessFunction to handle schema changes.
NewTableSchemaBuilder	Build schema for new table found in database synchronization.
RichCdcMultiplexRecord	Compared to CdcMultiplexRecord, this contains schema information.
RichCdcMultiplexRecordEventParser	EventParser for RichCdcMultiplexRecord.
RichCdcRecord	A change message contains schema and data.
RichCdcRecord.Builder	Builder for RichCdcRecord.
RichCdcSinkBuilder	DataStream API for building Flink Sink for RichCdcRecord to write with schema evolution.
RichEventParser	A EventParser for RichCdcRecord.
UpdatedDataFieldsProcessFunction	A ProcessFunction to handle schema changes.
UpdatedDataFieldsProcessFunctionBase<I,O>	Base class for update data fields process function.

Enum Summary

Enum	Description
UpdatedDataFieldsProcessFunctionBase.ConvertAction	Return type of UpdatedDataFieldsProcessFunctionBase.canConvert(DataType, DataType).