org.apache.flink.table.client.config.entries

Class ExecutionEntry

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
protected org.apache.flink.table.descriptors.DescriptorProperties	properties

Method Summary

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)
int	getMaxParallelism()
long	getMaxStateRetention()
int	getMaxTableResultRows()
long	getMinStateRetention()
int	getParallelism()
long	getPeriodicWatermarksInterval()
org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration	getRestartStrategy()
org.apache.flink.streaming.api.TimeCharacteristic	getTimeCharacteristic()
int	hashCode()
boolean	isBatchExecution()
boolean	isChangelogMode()
boolean	isStreamingExecution()
boolean	isTableMode()
static ExecutionEntry	merge(ExecutionEntry execution1, ExecutionEntry execution2) Merges two execution entries.
protected void	validate(org.apache.flink.table.descriptors.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

properties

protected final org.apache.flink.table.descriptors.DescriptorProperties properties

Method Detail

validate

protected void validate(org.apache.flink.table.descriptors.DescriptorProperties properties)

Performs syntactic validation.

isStreamingExecution

public boolean isStreamingExecution()

isBatchExecution

public boolean isBatchExecution()

getTimeCharacteristic

public org.apache.flink.streaming.api.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 org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration getRestartStrategy()

isChangelogMode

public boolean isChangelogMode()

isTableMode

public boolean isTableMode()

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