org.apache.paimon.flink.action

Class SortCompactAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.CompactAction

org.apache.paimon.flink.action.SortCompactAction

All Implemented Interfaces:

Action

public class SortCompactAction
extends CompactAction

Compact with sort action.

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
SortCompactAction(String warehouse, String database, String tableName, Map<String,String> catalogConfig, Map<String,String> tableConf)

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.
SortCompactAction	withOrderColumns(List<String> orderColumns)
SortCompactAction	withOrderColumns(String... orderColumns)
SortCompactAction	withOrderStrategy(String sortStrategy)

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

getPredicate, withFullCompaction, withPartitionIdleTime, withPartitions, withWhereSql

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

SortCompactAction

public SortCompactAction(String warehouse,
                         String database,
                         String tableName,
                         Map<String,String> catalogConfig,
                         Map<String,String> tableConf)

Method Detail

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Specified by:

run in interface Action

Overrides:

run in class CompactAction

Throws:

Exception

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.

Specified by:

build in interface Action

Overrides:

build in class CompactAction

Throws:

Exception - If an error occurs during the build process.

withOrderStrategy

public SortCompactAction withOrderStrategy(String sortStrategy)

withOrderColumns

public SortCompactAction withOrderColumns(String... orderColumns)

withOrderColumns

public SortCompactAction withOrderColumns(List<String> orderColumns)