org.apache.paimon.flink.action

Class RemoveOrphanFilesAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.RemoveOrphanFilesAction

All Implemented Interfaces:

Action

public class RemoveOrphanFilesAction
extends ActionBase

Action to remove the orphan data files and metadata files.

Field Summary

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

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Constructor and Description
RemoveOrphanFilesAction(String warehouse, String databaseName, String tableName, Map<String,String> catalogConfig, Map<String,String> dynamicOptions)

Method Summary

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

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

RemoveOrphanFilesAction

public RemoveOrphanFilesAction(String warehouse,
                               String databaseName,
                               @Nullable
                               String tableName,
                               Map<String,String> catalogConfig,
                               Map<String,String> dynamicOptions)
                        throws Catalog.TableNotExistException,
                               Catalog.DatabaseNotExistException

Throws:

Catalog.TableNotExistException

Catalog.DatabaseNotExistException

Method Detail

olderThan

public void olderThan(String olderThan)

dryRun

public void dryRun()

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception