org.apache.paimon.flink.action

Class CompactAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.CompactAction

All Implemented Interfaces:

Action

Direct Known Subclasses:

SortCompactAction

public class CompactAction
extends TableActionBase

Table compact action for Flink.

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
CompactAction(String warehouse, String database, String tableName)
CompactAction(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.
protected Predicate	getPredicate()
void	run() The execution method of the action.
CompactAction	withPartitionIdleTime(java.time.Duration partitionIdleTime)
CompactAction	withPartitions(List<Map<String,String>> partitions)
CompactAction	withWhereSql(String whereSql)

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

CompactAction

public CompactAction(String warehouse,
                     String database,
                     String tableName)

CompactAction

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

Method Detail

withPartitions

public CompactAction withPartitions(List<Map<String,String>> partitions)

withWhereSql

public CompactAction withWhereSql(String whereSql)

withPartitionIdleTime

public CompactAction withPartitionIdleTime(@Nullable
                                           java.time.Duration partitionIdleTime)

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.

getPredicate

protected Predicate getPredicate()
                          throws Exception

Throws:

Exception

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception