public class ExecutionEntry extends Object
All properties of this entry are optional and evaluated lazily.
Modifier and Type | Field and Description |
---|---|
static ExecutionEntry |
DEFAULT_INSTANCE |
protected DescriptorProperties |
properties |
public static final ExecutionEntry DEFAULT_INSTANCE
protected final DescriptorProperties properties
protected void validate(DescriptorProperties properties)
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 RestartStrategies.RestartStrategyConfiguration getRestartStrategy()
public boolean isChangelogMode()
public boolean isTableMode()
public static ExecutionEntry create(Map<String,Object> config)
public static ExecutionEntry merge(ExecutionEntry execution1, ExecutionEntry execution2)
public static ExecutionEntry enrich(ExecutionEntry execution, Map<String,String> prefixedProperties)
Environment.EXECUTION_ENTRY
.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.