public class SortCompactAction extends CompactAction
identifier, table
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
SortCompactAction(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.
|
void |
run()
The execution method of the action.
|
SortCompactAction |
withOrderColumns(List<String> orderColumns) |
SortCompactAction |
withOrderColumns(String... orderColumns) |
SortCompactAction |
withOrderStrategy(String sortStrategy) |
getPredicate, withPartitionIdleTime, withPartitions, withWhereSql
batchSink
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
public void run() throws Exception
Action
run
in interface Action
run
in class CompactAction
Exception
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.
build
in interface Action
build
in class CompactAction
Exception
- If an error occurs during the build process.public SortCompactAction withOrderStrategy(String sortStrategy)
public SortCompactAction withOrderColumns(String... orderColumns)
public SortCompactAction withOrderColumns(List<String> orderColumns)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.