public class CompactAction extends TableActionBase
identifier, table
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
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) |
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) |
batchSink
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
public CompactAction withPartitions(List<Map<String,String>> partitions)
public CompactAction withWhereSql(String whereSql)
public CompactAction withPartitionIdleTime(@Nullable java.time.Duration partitionIdleTime)
public void build() throws Exception
Action
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.
Exception
- If an error occurs during the build process.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.