org.apache.paimon.flink.action

Interface Action

All Known Implementing Classes:

ActionBase, CloneAction, CompactAction, CompactDatabaseAction, CreateBranchAction, CreateTagAction, CreateTagFromTimestampAction, CreateTagFromWatermarkAction, DeleteAction, DeleteBranchAction, DeleteTagAction, DropPartitionAction, ExpirePartitionsAction, ExpireSnapshotsAction, ExpireTagsAction, FastForwardAction, KafkaSyncDatabaseAction, KafkaSyncTableAction, MarkPartitionDoneAction, MergeIntoAction, MessageQueueSyncTableActionBase, MigrateDatabaseAction, MigrateFileAction, MigrateTableAction, MongoDBSyncDatabaseAction, MongoDBSyncTableAction, MySqlSyncDatabaseAction, MySqlSyncTableAction, PostgresSyncTableAction, PulsarSyncDatabaseAction, PulsarSyncTableAction, RemoveOrphanFilesAction, RenameTagAction, RepairAction, ReplaceTagAction, ResetConsumerAction, RewriteFileIndexAction, RollbackToAction, RollbackToTimestampAction, SortCompactAction, SyncDatabaseActionBase, SynchronizationActionBase, SyncTableActionBase, TableActionBase

public interface Action

Abstract class for Flink actions.

Method Summary

Modifier and Type	Method and Description
default void	build() Builds the action within the given Flink Stream Execution Environment.
void	run() The execution method of the action.

Method Detail

run

void run()
  throws Exception

The execution method of the action.

Throws:

Exception

build

default void build()
            throws Exception

Builds the action within the given Flink Stream Execution Environment.

This method is responsible for setting up any necessary configurations or resources needed for the action to run. It is called before the `run` method to prepare the environment for execution.

By default, this method is empty and can be overridden by subclasses to provide custom setup logic.

Throws:

Exception - If an error occurs during the build process.