org.apache.paimon.flink.action

Class CloneAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.CloneAction

All Implemented Interfaces:

Action

public class CloneAction
extends ActionBase

The Latest Snapshot clone action for Flink.

Field Summary

Fields inherited from class org.apache.paimon.flink.action.ActionBase

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Constructor and Description
CloneAction(String warehouse, String database, String tableName, Map<String,String> sourceCatalogConfig, String targetWarehouse, String targetDatabase, String targetTableName, Map<String,String> targetCatalogConfig, String parallelismStr)

Method Summary

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

Methods inherited from class org.apache.paimon.flink.action.ActionBase

catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CloneAction

public CloneAction(String warehouse,
                   String database,
                   String tableName,
                   Map<String,String> sourceCatalogConfig,
                   String targetWarehouse,
                   String targetDatabase,
                   String targetTableName,
                   Map<String,String> targetCatalogConfig,
                   String parallelismStr)

Method Detail

build

public void build()

Description copied from interface: Action

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.

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception