org.apache.paimon.flink.action

Class CompactDatabaseAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.CompactDatabaseAction

All Implemented Interfaces:

Action

public class CompactDatabaseAction
extends ActionBase

Database compact action for Flink.

Field Summary

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

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Constructor and Description
CompactDatabaseAction(String warehouse, Map<String,String> catalogConfig)

Method Summary

Modifier and Type	Method and Description
void	build() Builds the action within the given Flink Stream Execution Environment.
CompactDatabaseAction	excludingTables(String excludingTables)
CompactDatabaseAction	includingDatabases(String includingDatabases)
CompactDatabaseAction	includingTables(String includingTables)
void	run() The execution method of the action.
CompactDatabaseAction	withDatabaseCompactMode(String mode)
CompactDatabaseAction	withPartitionIdleTime(java.time.Duration partitionIdleTime)
CompactDatabaseAction	withTableOptions(Map<String,String> tableOptions)

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

CompactDatabaseAction

public CompactDatabaseAction(String warehouse,
                             Map<String,String> catalogConfig)

Method Detail

includingDatabases

public CompactDatabaseAction includingDatabases(@Nullable
                                                String includingDatabases)

includingTables

public CompactDatabaseAction includingTables(@Nullable
                                             String includingTables)

excludingTables

public CompactDatabaseAction excludingTables(@Nullable
                                             String excludingTables)

withDatabaseCompactMode

public CompactDatabaseAction withDatabaseCompactMode(@Nullable
                                                     String mode)

withTableOptions

public CompactDatabaseAction withTableOptions(Map<String,String> tableOptions)

withPartitionIdleTime

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

build

public void build()

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.

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception