Uses of Interface
org.apache.paimon.flink.action.Action

Packages that use Action

Package	Description
org.apache.paimon.flink.action
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 Action in org.apache.paimon.flink.action

Classes in org.apache.paimon.flink.action that implement Action

Modifier and Type	Class and Description
class	ActionBase Abstract base of Action for table.
class	CloneAction The Latest Snapshot clone action for Flink.
class	CompactAction Table compact action for Flink.
class	CompactDatabaseAction Database compact action for Flink.
class	CreateBranchAction Create branch action for Flink.
class	CreateTagAction Create tag action for Flink.
class	CreateTagFromTimestampAction Create tag from timestamp action for Flink.
class	CreateTagFromWatermarkAction Create tag from watermark action for Flink.
class	DeleteAction Delete from table action for Flink.
class	DeleteBranchAction Delete branch action for Flink.
class	DeleteTagAction Delete tag action for Flink.
class	DropPartitionAction Table drop partition action for Flink.
class	ExpirePartitionsAction Expire partitions action for Flink.
class	ExpireSnapshotsAction Expire snapshots action for Flink.
class	ExpireTagsAction Expire tags action for Flink.
class	FastForwardAction Fast Forward action for Flink.
class	MarkPartitionDoneAction Table partition mark done action for Flink.
class	MergeIntoAction Flink action for 'MERGE INTO', which references the syntax as follows (we use 'upsert' semantics instead of 'update'):
class	MigrateDatabaseAction Migrate from external all hive table in database to paimon table.
class	MigrateFileAction Migrate from external hive table to paimon table.
class	MigrateTableAction Migrate from external hive table to paimon table.
class	RemoveOrphanFilesAction Action to remove the orphan data files and metadata files.
class	RenameTagAction Rename Tag action for Flink.
class	RepairAction Repair action for Flink.
class	ReplaceTagAction Replace tag action for Flink.
class	ResetConsumerAction Reset consumer action for Flink.
class	RewriteFileIndexAction Rewrite-file-index action for Flink.
class	RollbackToAction Rollback to specific version action for Flink.
class	RollbackToTimestampAction Rollback to specific timestamp action for Flink.
class	SortCompactAction Compact with sort action.
class	TableActionBase Abstract base of Action for table.

Methods in org.apache.paimon.flink.action that return types with arguments of type Action

Modifier and Type	Method and Description
Optional<Action>	CreateOrReplaceTagActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RewriteFileIndexActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CreateTagFromTimestampActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RemoveOrphanFilesActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	ExpireTagsActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	DeleteTagActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	ExpirePartitionsActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	ExpireSnapshotsActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	ActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	MigrateTableActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CreateBranchActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	DeleteActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	MigrateFileActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	DropPartitionActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RenameTagActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CompactDatabaseActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	MarkPartitionDoneActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CloneActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RollbackToTimestampActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	MigrateDatabaseActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	ResetConsumerActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	MergeIntoActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CompactActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RollbackToActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	QueryServiceActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	RepairActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	CreateTagFromWatermarkActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	DeleteBranchActionFactory.create(MultipleParameterToolAdapter params)
Optional<Action>	FastForwardActionFactory.create(MultipleParameterToolAdapter params)
static Optional<Action>	ActionFactory.createAction(String[] args)

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

Classes in org.apache.paimon.flink.action.cdc that implement Action

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	SynchronizationActionBase Base Action for table/database synchronizing job.
class	SyncTableActionBase Base Action for synchronizing into one Paimon table.

Methods in org.apache.paimon.flink.action.cdc that return types with arguments of type Action

Modifier and Type	Method and Description
Optional<Action>	SyncDatabaseActionFactoryBase.create(MultipleParameterToolAdapter params)
Optional<Action>	SynchronizationActionFactoryBase.create(MultipleParameterToolAdapter params)
Optional<Action>	SyncTableActionFactoryBase.create(MultipleParameterToolAdapter params)

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

Classes in org.apache.paimon.flink.action.cdc.kafka that implement Action

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

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

Classes in org.apache.paimon.flink.action.cdc.mongodb that implement Action

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

Classes in org.apache.paimon.flink.action.cdc.mysql that implement Action

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

Classes in org.apache.paimon.flink.action.cdc.postgres that implement Action

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

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

Classes in org.apache.paimon.flink.action.cdc.pulsar that implement Action

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