sql-client.yaml
configuration file.@Deprecated public class ExecutionEntry extends Object
All properties of this entry are optional and evaluated lazily.
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
asMap()
Deprecated.
|
Map<String,String> |
asTopLevelMap()
Deprecated.
|
static ExecutionEntry |
create(Map<String,Object> config)
Deprecated.
|
static ExecutionEntry |
enrich(ExecutionEntry execution,
Map<String,String> prefixedProperties)
Deprecated.
Creates a new execution entry enriched with additional properties that are prefixed with
Environment.EXECUTION_ENTRY . |
boolean |
equals(Object o)
Deprecated.
|
Optional<String> |
getCurrentCatalog()
Deprecated.
|
Optional<String> |
getCurrentDatabase()
Deprecated.
|
int |
getMaxParallelism()
Deprecated.
|
Optional<Integer> |
getParallelism()
Deprecated.
|
RestartStrategies.RestartStrategyConfiguration |
getRestartStrategy()
Deprecated.
|
int |
hashCode()
Deprecated.
|
boolean |
inBatchMode()
Deprecated.
|
boolean |
inStreamingMode()
Deprecated.
|
boolean |
isBlinkPlanner()
Deprecated.
|
boolean |
isStreamingPlanner()
Deprecated.
|
static ExecutionEntry |
merge(ExecutionEntry execution1,
ExecutionEntry execution2)
Deprecated.
Merges two execution entries.
|
protected void |
validate(DescriptorProperties properties)
Deprecated.
Performs syntactic validation.
|
public static final ExecutionEntry DEFAULT_INSTANCE
public static final String EXECUTION_PLANNER
public static final String EXECUTION_PLANNER_VALUE_OLD
public static final String EXECUTION_PLANNER_VALUE_BLINK
public static final String EXECUTION_TYPE
public static final String EXECUTION_TYPE_VALUE_STREAMING
public static final String EXECUTION_TIME_CHARACTERISTIC
public static final String EXECUTION_PERIODIC_WATERMARKS_INTERVAL
public static final String EXECUTION_MIN_STATE_RETENTION
public static final String EXECUTION_MAX_STATE_RETENTION
public static final String EXECUTION_PARALLELISM
public static final String EXECUTION_MAX_PARALLELISM
public static final String EXECUTION_RESULT_MODE
public static final String EXECUTION_MAX_TABLE_RESULT_ROWS
public static final String EXECUTION_RESTART_STRATEGY_TYPE
public static final String EXECUTION_RESTART_STRATEGY_ATTEMPTS
public static final String EXECUTION_RESTART_STRATEGY_DELAY
public static final String EXECUTION_RESTART_STRATEGY_FAILURE_RATE_INTERVAL
public static final String EXECUTION_RESTART_STRATEGY_MAX_FAILURES_PER_INTERVAL
public static final String EXECUTION_CURRENT_CATALOG
public static final String EXECUTION_CURRENT_DATABASE
protected final DescriptorProperties properties
protected void validate(DescriptorProperties properties)
public boolean inStreamingMode()
public boolean inBatchMode()
public boolean isStreamingPlanner()
public boolean isBlinkPlanner()
public int getMaxParallelism()
public RestartStrategies.RestartStrategyConfiguration getRestartStrategy()
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–2022 The Apache Software Foundation. All rights reserved.