public class Execution extends Object
Constructor and Description |
---|
Execution() |
Modifier and Type | Method and Description |
---|---|
static Execution |
create(Map<String,Object> config) |
static Execution |
enrich(Execution exec,
Map<String,String> properties)
Creates a new execution enriched with additional properties.
|
int |
getMaxParallelism() |
long |
getMaxStateRetention() |
int |
getMaxTableResultRows() |
long |
getMinStateRetention() |
int |
getParallelism() |
long |
getPeriodicWatermarksInterval() |
TimeCharacteristic |
getTimeCharacteristic() |
boolean |
isBatchExecution() |
boolean |
isChangelogMode() |
boolean |
isStreamingExecution() |
boolean |
isTableMode() |
static Execution |
merge(Execution exec1,
Execution exec2)
Merges two executions.
|
Map<String,String> |
toProperties() |
public boolean isStreamingExecution()
public boolean isBatchExecution()
public TimeCharacteristic getTimeCharacteristic()
public long getPeriodicWatermarksInterval()
public long getMinStateRetention()
public long getMaxStateRetention()
public int getParallelism()
public int getMaxParallelism()
public int getMaxTableResultRows()
public boolean isChangelogMode()
public boolean isTableMode()
public static Execution merge(Execution exec1, Execution exec2)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.