ExecutionEntry (flink 1.11-SNAPSHOT API)

java.lang.Object
- org.apache.flink.table.client.config.entries.ExecutionEntry

```
public class ExecutionEntry
extends Object
```
Configuration of a table program execution. This class parses the `execution` part in an environment file. The execution describes properties that would usually be defined in the ExecutionEnvironment/StreamExecutionEnvironment/TableEnvironment or as code in a Flink job.
All properties of this entry are optional and evaluated lazily.

Field Summary

Fields
Modifier and Type	Field and Description
`static ExecutionEntry`	`DEFAULT_INSTANCE`
`static String`	`EXECUTION_CURRENT_CATALOG`
`static String`	`EXECUTION_CURRENT_DATABASE`
`static String`	`EXECUTION_PLANNER_VALUE_BLINK`
`static String`	`EXECUTION_PLANNER_VALUE_OLD`
`protected DescriptorProperties`	`properties`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Map<String,String>`	`asMap()`
`Map<String,String>`	`asTopLevelMap()`
`static ExecutionEntry`	`create(Map<String,Object> config)`
`static ExecutionEntry`	`enrich(ExecutionEntry execution, Map<String,String> prefixedProperties)` Creates a new execution entry enriched with additional properties that are prefixed with `Environment.EXECUTION_ENTRY`.
`boolean`	`equals(Object o)`
`Optional<String>`	`getCurrentCatalog()`
`Optional<String>`	`getCurrentDatabase()`
`EnvironmentSettings`	`getEnvironmentSettings()`
`int`	`getMaxParallelism()`
`long`	`getMaxStateRetention()`
`int`	`getMaxTableResultRows()`
`long`	`getMinStateRetention()`
`int`	`getParallelism()`
`long`	`getPeriodicWatermarksInterval()`
`RestartStrategies.RestartStrategyConfiguration`	`getRestartStrategy()`
`TimeCharacteristic`	`getTimeCharacteristic()`
`int`	`hashCode()`
`boolean`	`inBatchMode()`
`boolean`	`inStreamingMode()`
`boolean`	`isBatchPlanner()`
`boolean`	`isBlinkPlanner()`
`boolean`	`isChangelogMode()`
`boolean`	`isStreamingPlanner()`
`boolean`	`isTableauMode()`
`boolean`	`isTableMode()`
`static ExecutionEntry`	`merge(ExecutionEntry execution1, ExecutionEntry execution2)` Merges two execution entries.
`protected void`	`validate(DescriptorProperties properties)` Performs syntactic validation.

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_INSTANCE

public static final ExecutionEntry DEFAULT_INSTANCE

EXECUTION_PLANNER_VALUE_OLD

public static final String EXECUTION_PLANNER_VALUE_OLD

See Also:: Constant Field Values

EXECUTION_PLANNER_VALUE_BLINK

public static final String EXECUTION_PLANNER_VALUE_BLINK

See Also:: Constant Field Values

EXECUTION_CURRENT_CATALOG

public static final String EXECUTION_CURRENT_CATALOG

See Also:: Constant Field Values

EXECUTION_CURRENT_DATABASE

public static final String EXECUTION_CURRENT_DATABASE

See Also:: Constant Field Values

properties

protected final DescriptorProperties properties

Method Detail

validate

protected void validate(DescriptorProperties properties)

Performs syntactic validation.

getEnvironmentSettings

public EnvironmentSettings getEnvironmentSettings()

inStreamingMode
```
public boolean inStreamingMode()
```

inBatchMode
```
public boolean inBatchMode()
```

isStreamingPlanner
```
public boolean isStreamingPlanner()
```

isBatchPlanner
```
public boolean isBatchPlanner()
```

isBlinkPlanner
```
public boolean isBlinkPlanner()
```

getTimeCharacteristic

public TimeCharacteristic getTimeCharacteristic()

getPeriodicWatermarksInterval

public long getPeriodicWatermarksInterval()

getMinStateRetention
```
public long getMinStateRetention()
```

getMaxStateRetention
```
public long getMaxStateRetention()
```

getParallelism
```
public int getParallelism()
```

getMaxParallelism
```
public int getMaxParallelism()
```

getMaxTableResultRows
```
public int getMaxTableResultRows()
```

getRestartStrategy

public RestartStrategies.RestartStrategyConfiguration getRestartStrategy()

getCurrentCatalog

public Optional<String> getCurrentCatalog()

getCurrentDatabase

public Optional<String> getCurrentDatabase()

isChangelogMode
```
public boolean isChangelogMode()
```

isTableMode
```
public boolean isTableMode()
```

isTableauMode
```
public boolean isTableauMode()
```

asTopLevelMap

public Map<String,String> asTopLevelMap()

create

public static ExecutionEntry create(Map<String,Object> config)

merge

public static ExecutionEntry merge(ExecutionEntry execution1,
                                   ExecutionEntry execution2)

Merges two execution entries. The properties of the first execution entry might be overwritten by the second one.

enrich

public static ExecutionEntry enrich(ExecutionEntry execution,
                                    Map<String,String> prefixedProperties)

Creates a new execution entry enriched with additional properties that are prefixed with Environment.EXECUTION_ENTRY.

asMap
```
public Map<String,String> asMap()
```

equals
```
public boolean equals(Object o)
```
Overrides:

equals in class Object

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class Object

Back to Flink Website

Class ExecutionEntry

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

DEFAULT_INSTANCE

EXECUTION_PLANNER_VALUE_OLD

EXECUTION_PLANNER_VALUE_BLINK

EXECUTION_CURRENT_CATALOG

EXECUTION_CURRENT_DATABASE

properties

Method Detail

validate

getEnvironmentSettings

inStreamingMode

inBatchMode

isStreamingPlanner

isBatchPlanner

isBlinkPlanner

getTimeCharacteristic

getPeriodicWatermarksInterval

getMinStateRetention

getMaxStateRetention

getParallelism

getMaxParallelism

getMaxTableResultRows

getRestartStrategy

getCurrentCatalog

getCurrentDatabase

isChangelogMode

isTableMode

isTableauMode

asTopLevelMap

create

merge

enrich

asMap

equals

hashCode