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

Packages that use org.apache.paimon.flink.action.cdc

Package	Description
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.format
org.apache.paimon.flink.action.cdc.format.canal
org.apache.paimon.flink.action.cdc.format.debezium
org.apache.paimon.flink.action.cdc.format.json
org.apache.paimon.flink.action.cdc.format.maxwell
org.apache.paimon.flink.action.cdc.format.ogg
org.apache.paimon.flink.action.cdc.kafka
org.apache.paimon.flink.action.cdc.mongodb
org.apache.paimon.flink.action.cdc.mongodb.strategy
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres
org.apache.paimon.flink.action.cdc.pulsar
org.apache.paimon.flink.action.cdc.schema
org.apache.paimon.flink.action.cdc.serialization
org.apache.paimon.flink.action.cdc.watermark
org.apache.paimon.flink.sink.cdc

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc

Class and Description
CdcMetadataConverter A functional interface for converting CDC metadata.
CdcMetadataProcessor Enumerates the metadata processing behaviors for CDC related data.
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
Expression Produce a computation result for computed column.
Expression.ExpressionCreator Expression creator.
Expression.ExpressionFunction Expression function.
Expression.ReferencedField Referenced field in expression input parameters.
Expression.TemporalExpressionBase Expression to handle temporal value.
MessageQueueSchemaUtils.ConsumerWrapper Wrap the consumer for different message queues.
SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncJobHandler Provide different function according to CDC source type.
SyncJobHandler.SourceType CDC source type.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionBase.SchemaRetrievalException Custom exception to indicate issues with schema retrieval.
TypeMapping Utility that holds data type mapping options.
TypeMapping.TypeMappingMode Describe how to map MySQL data type to Paimon data type.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format

Class and Description
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format.canal

Class and Description
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format.debezium

Class and Description
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format.json

Class and Description
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format.maxwell

Class and Description
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.format.ogg

Class and Description
ComputedColumn A Computed column's value is computed from input columns.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.kafka

Class and Description
CdcSourceRecord A data change record from the CDC source.
MessageQueueSchemaUtils.ConsumerWrapper Wrap the consumer for different message queues.
MessageQueueSyncTableActionBase Base Action for synchronizing one message queue topic into one Paimon table.
SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
SyncDatabaseActionFactoryBase Base ActionFactory for synchronizing into database.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase Base ActionFactory for synchronizing into one Paimon table.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.mongodb

Class and Description
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
SyncDatabaseActionFactoryBase Base ActionFactory for synchronizing into database.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase Base ActionFactory for synchronizing into one Paimon table.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.mongodb.strategy

Class and Description
ComputedColumn A Computed column's value is computed from input columns.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.mysql

Class and Description
CdcMetadataConverter A functional interface for converting CDC metadata.
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
JdbcToPaimonTypeVisitor jdbc to paimon data type visitor.
SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
SyncDatabaseActionFactoryBase Base ActionFactory for synchronizing into database.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase Base ActionFactory for synchronizing into one Paimon table.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.postgres

Class and Description
CdcMetadataConverter A functional interface for converting CDC metadata.
CdcSourceRecord A data change record from the CDC source.
ComputedColumn A Computed column's value is computed from input columns.
JdbcToPaimonTypeVisitor jdbc to paimon data type visitor.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase Base ActionFactory for synchronizing into one Paimon table.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.pulsar

Class and Description
CdcSourceRecord A data change record from the CDC source.
MessageQueueSchemaUtils.ConsumerWrapper Wrap the consumer for different message queues.
MessageQueueSyncTableActionBase Base Action for synchronizing one message queue topic into one Paimon table.
SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
SyncDatabaseActionFactoryBase Base ActionFactory for synchronizing into database.
SynchronizationActionBase Base Action for table/database synchronizing job.
SynchronizationActionFactoryBase Base ActionFactory for table/database synchronizing job.
SyncTableActionBase Base Action for synchronizing into one Paimon table.
SyncTableActionFactoryBase Base ActionFactory for synchronizing into one Paimon table.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.schema

Class and Description
JdbcToPaimonTypeVisitor jdbc to paimon data type visitor.
TypeMapping Utility that holds data type mapping options.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.serialization

Class and Description
CdcSourceRecord A data change record from the CDC source.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.action.cdc.watermark

Class and Description
CdcSourceRecord A data change record from the CDC source.

Classes in org.apache.paimon.flink.action.cdc used by org.apache.paimon.flink.sink.cdc

Class and Description
CdcMetadataConverter A functional interface for converting CDC metadata.
TableNameConverter Used to convert a MySQL source table name to corresponding Paimon table name.