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() |
long |
getMinStateRetention() |
int |
getParallelism() |
TimeCharacteristic |
getTimeCharacteristic() |
boolean |
isBatchExecution() |
boolean |
isChangelogMode() |
boolean |
isStreamingExecution() |
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 getMinStateRetention()
public long getMaxStateRetention()
public int getParallelism()
public int getMaxParallelism()
public boolean isChangelogMode()
public static Execution merge(Execution exec1, Execution exec2)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.