public class CloneAction extends ActionBase
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
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) |
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.
|
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
public void build()
Action
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.
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.