org.apache.paimon.flink.action

Class RescaleAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.RescaleAction

All Implemented Interfaces:

Action

public class RescaleAction
extends TableActionBase

Action to rescale one partition of a table.

Field Summary

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

identifier, table

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

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Constructor and Description
RescaleAction(String databaseName, String tableName, Map<String,String> catalogConfig)

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.
RescaleAction	withBucketNum(int bucketNum)
RescaleAction	withPartition(Map<String,String> partition)
RescaleAction	withScanParallelism(int scanParallelism)
RescaleAction	withSinkParallelism(int sinkParallelism)

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

batchSink

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

RescaleAction

public RescaleAction(String databaseName,
                     String tableName,
                     Map<String,String> catalogConfig)

Method Detail

withBucketNum

public RescaleAction withBucketNum(int bucketNum)

withPartition

public RescaleAction withPartition(Map<String,String> partition)

withScanParallelism

public RescaleAction withScanParallelism(int scanParallelism)

withSinkParallelism

public RescaleAction withSinkParallelism(int sinkParallelism)

build

public void build()
           throws Exception

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.

Throws:

Exception - If an error occurs during the build process.

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception