Action.Factory
Modifier and Type | Method and Description |
---|---|
void |
build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env) |
static Optional<Action> |
create(String[] args) |
void |
run()
The execution method of the action.
|
CompactAction |
withPartitions(List<Map<String,String>> partitions) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPartitions, getTablePath
public CompactAction withPartitions(List<Map<String,String>> partitions)
public void build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.