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

Packages that use SyncDatabaseActionBase

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.pulsar

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

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

Modifier and Type	Class and Description
class	SyncDatabaseActionFactoryBase<T extends SyncDatabaseActionBase> Base ActionFactory for synchronizing into database.

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

Modifier and Type	Method and Description
SyncDatabaseActionBase	SyncDatabaseActionBase.excludingDbs(String excludingDbs)
SyncDatabaseActionBase	SyncDatabaseActionBase.excludingTables(String excludingTables)
SyncDatabaseActionBase	SyncDatabaseActionBase.includingDbs(String includingDbs)
SyncDatabaseActionBase	SyncDatabaseActionBase.includingTables(String includingTables)
SyncDatabaseActionBase	SyncDatabaseActionBase.mergeShards(boolean mergeShards)
SyncDatabaseActionBase	SyncDatabaseActionBase.withDbPrefix(Map<String,String> dbPrefix)
SyncDatabaseActionBase	SyncDatabaseActionBase.withDbSuffix(Map<String,String> dbSuffix)
SyncDatabaseActionBase	SyncDatabaseActionBase.withMode(MultiTablesSinkMode mode)
SyncDatabaseActionBase	SyncDatabaseActionBase.withPartitionKeyMultiple(Map<String,List<String>> partitionKeyMultiple)
SyncDatabaseActionBase	SyncDatabaseActionBase.withPartitionKeys(String... partitionKeys)
SyncDatabaseActionBase	SyncDatabaseActionBase.withPrimaryKeys(String... primaryKeys)
SyncDatabaseActionBase	SyncDatabaseActionBase.withTableMapping(Map<String,String> tableMapping)
SyncDatabaseActionBase	SyncDatabaseActionBase.withTablePrefix(String tablePrefix)
SyncDatabaseActionBase	SyncDatabaseActionBase.withTableSuffix(String tableSuffix)

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

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

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

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

Subclasses of SyncDatabaseActionBase 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.

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

Subclasses of SyncDatabaseActionBase 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.

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

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

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