org.apache.paimon.flink.action

Class ExpirePartitionsAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.ExpirePartitionsAction

All Implemented Interfaces:

Action

public class ExpirePartitionsAction
extends TableActionBase

Expire partitions 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
ExpirePartitionsAction(String warehouse, String databaseName, String tableName, Map<String,String> catalogConfig, String expirationTime, String timestampFormatter, String timestampPattern, String expireStrategy)

Method Summary

Modifier and Type	Method and Description
void	run() The execution method of the action.

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

Methods inherited from interface org.apache.paimon.flink.action.Action

build

Constructor Detail

ExpirePartitionsAction

public ExpirePartitionsAction(String warehouse,
                              String databaseName,
                              String tableName,
                              Map<String,String> catalogConfig,
                              String expirationTime,
                              String timestampFormatter,
                              String timestampPattern,
                              String expireStrategy)

Method Detail

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception