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

Packages that use SyncTableActionBase

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 SyncTableActionBase in org.apache.paimon.flink.action.cdc

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

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

Modifier and Type	Method and Description
SyncTableActionBase	SyncTableActionBase.withComputedColumnArgs(List<String> computedColumnArgs)
SyncTableActionBase	SyncTableActionBase.withPartitionKeys(List<String> partitionKeys)
SyncTableActionBase	SyncTableActionBase.withPartitionKeys(String... partitionKeys)
SyncTableActionBase	SyncTableActionBase.withPrimaryKeys(List<String> primaryKeys)
SyncTableActionBase	SyncTableActionBase.withPrimaryKeys(String... primaryKeys)

Methods in org.apache.paimon.flink.action.cdc with parameters of type SyncTableActionBase

Modifier and Type	Method and Description
protected void	SyncTableActionFactoryBase.withParams(MultipleParameterToolAdapter params, SyncTableActionBase action)

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

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

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

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

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

Modifier and Type	Class and Description
class	MongoDBSyncTableAction Represents an action to synchronize a specific MongoDB table with a target system.

Methods in org.apache.paimon.flink.action.cdc.mongodb that return SyncTableActionBase

Modifier and Type	Method and Description
SyncTableActionBase	MongoDBSyncTableActionFactory.createAction()

Methods in org.apache.paimon.flink.action.cdc.mongodb with parameters of type SyncTableActionBase

Modifier and Type	Method and Description
protected void	MongoDBSyncTableActionFactory.withParams(MultipleParameterToolAdapter params, SyncTableActionBase action)

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

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

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

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

Subclasses of SyncTableActionBase 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 SyncTableActionBase in org.apache.paimon.flink.action.cdc.pulsar

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

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