public class RescaleAction extends TableActionBase
identifier, table
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
RescaleAction(String databaseName,
String tableName,
Map<String,String> catalogConfig) |
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.
|
RescaleAction |
withBucketNum(int bucketNum) |
RescaleAction |
withPartition(Map<String,String> partition) |
RescaleAction |
withScanParallelism(int scanParallelism) |
RescaleAction |
withSinkParallelism(int sinkParallelism) |
batchSink
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
public RescaleAction withBucketNum(int bucketNum)
public RescaleAction withPartition(Map<String,String> partition)
public RescaleAction withScanParallelism(int scanParallelism)
public RescaleAction withSinkParallelism(int sinkParallelism)
public void build() throws Exception
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.
Exception
- If an error occurs during the build process.Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.