Package org.apache.paimon.flink.action.cdc

Interface Summary

Interface	Description
CdcMetadataConverter	A functional interface for converting CDC metadata.
Expression	Produce a computation result for computed column.
Expression.ExpressionCreator	Expression creator.
JdbcToPaimonTypeVisitor	jdbc to paimon data type visitor.
MessageQueueSchemaUtils.ConsumerWrapper	Wrap the consumer for different message queues.

Class Summary

Class	Description
CdcActionCommonUtils	Common utils for CDC Action.
CdcMetadataConverter.DatabaseNameConverter	Name of the database that contain the row.
CdcMetadataConverter.OpTsConverter	It indicates the time that the change was made in the database.
CdcMetadataConverter.SchemaNameConverter	Name of the schema that contain the row.
CdcMetadataConverter.TableNameConverter	Name of the table that contain the row.
CdcSourceRecord	A data change record from the CDC source.
ComputedColumn	A Computed column's value is computed from input columns.
ComputedColumnUtils	Utility methods for ComputedColumn, such as build.
Expression.CastExpression	Get constant value.
Expression.DateFormat	Convert the temporal value to desired formatted string.
Expression.ReferencedField	Referenced field in expression input parameters.
Expression.Substring	Get substring using String.substring(int).
Expression.TemporalExpressionBase<T>	Expression to handle temporal value.
Expression.TemporalToIntConverter	Convert the temporal value to an integer.
Expression.TruncateComputer	Truncate numeric/decimal/string value.
MessageQueueSchemaUtils	Utility class to build schema by trying to read and parse records from message queue.
MessageQueueSyncTableActionBase	Base Action for synchronizing one message queue topic into one Paimon table.
SyncDatabaseActionBase	Base Action for synchronizing into one Paimon database.
SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase>	Base ActionFactory for synchronizing into database.
SynchronizationActionBase	Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase<T extends SynchronizationActionBase>	Base ActionFactory for table/database synchronizing job.
SyncJobHandler	Provide different function according to CDC source type.
SyncTableActionBase	Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase	Base ActionFactory for synchronizing into one Paimon table.
TableNameConverter	Used to convert a MySQL source table name to corresponding Paimon table name.
TypeMapping	Utility that holds data type mapping options.

Enum Summary

Enum	Description
CdcMetadataProcessor	Enumerates the metadata processing behaviors for CDC related data.
Expression.ExpressionFunction	Expression function.
SyncJobHandler.SourceType	CDC source type.
TypeMapping.TypeMappingMode	Describe how to map MySQL data type to Paimon data type.

Exception Summary

Exception	Description
SyncTableActionBase.SchemaRetrievalException	Custom exception to indicate issues with schema retrieval.