Uses of Class
org.apache.paimon.flink.action.cdc.SynchronizationActionBase

Packages that use SynchronizationActionBase

Package	Description
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.kafka
org.apache.paimon.flink.action.cdc.mongodb
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres
org.apache.paimon.flink.action.cdc.pulsar

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc

Classes in org.apache.paimon.flink.action.cdc with type parameters of type SynchronizationActionBase

Modifier and Type	Class and Description
class	SynchronizationActionFactoryBase<T extends SynchronizationActionBase> Base ActionFactory for table/database synchronizing job.

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc

Modifier and Type	Class and Description
class	MessageQueueSyncTableActionBase Base Action for synchronizing one message queue topic into one Paimon table.
class	SyncDatabaseActionBase Base Action for synchronizing into one Paimon database.
class	SyncTableActionBase Base Action for synchronizing into one Paimon table.

Methods in org.apache.paimon.flink.action.cdc that return SynchronizationActionBase

Modifier and Type	Method and Description
SynchronizationActionBase	SynchronizationActionBase.withMetadataColumns(List<String> metadataColumns)
SynchronizationActionBase	SynchronizationActionBase.withTableConfig(Map<String,String> tableConfig)
SynchronizationActionBase	SynchronizationActionBase.withTypeMapping(TypeMapping typeMapping)

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.kafka

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.kafka

Modifier and Type	Class and Description
class	KafkaSyncDatabaseAction Synchronize database from Kafka.
class	KafkaSyncTableAction Synchronize table from Kafka.

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.mongodb

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.mongodb

Modifier and Type	Class and Description
class	MongoDBSyncDatabaseAction An action class responsible for synchronizing MongoDB databases with a target system.
class	MongoDBSyncTableAction Represents an action to synchronize a specific MongoDB table with a target system.

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.mysql

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.mysql

Modifier and Type	Class and Description
class	MySqlSyncDatabaseAction An Action which synchronize the whole MySQL database into one Paimon database.
class	MySqlSyncTableAction An Action which synchronize one or multiple MySQL tables into one Paimon table.

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.postgres

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.postgres

Modifier and Type	Class and Description
class	PostgresSyncTableAction An Action which synchronize one or multiple PostgreSQL tables into one Paimon table.

Uses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.pulsar

Subclasses of SynchronizationActionBase in org.apache.paimon.flink.action.cdc.pulsar

Modifier and Type	Class and Description
class	PulsarSyncDatabaseAction Synchronize database from Pulsar.
class	PulsarSyncTableAction Synchronize table from Pulsar.