public class RemoveOrphanFilesAction extends ActionBase
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
RemoveOrphanFilesAction(String warehouse,
String databaseName,
String tableName,
String parallelism,
Map<String,String> catalogConfig) |
Modifier and Type | Method and Description |
---|---|
void |
dryRun() |
void |
olderThan(String olderThan) |
void |
run()
The execution method of the action.
|
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.