org.apache.flink.table.planner.plan.nodes.exec

Class ExecNodeConfig

java.lang.Object

org.apache.flink.table.planner.plan.nodes.exec.ExecNodeConfig

All Implemented Interfaces:

ReadableConfig

@Internal
public final class ExecNodeConfig
extends Object
implements ReadableConfig

Configuration view which is used combine the PlannerBase.getTableConfig() with the ExecNodeBase.getPersistedConfig() configuration. The persisted configuration of the ExecNode which is deserialized from the JSON plan has precedence over the PlannerBase.getTableConfig().

Method Summary

Modifier and Type	Method and Description
<T> T	get(ConfigOption<T> option) Reads a value using the metadata included in ConfigOption.
<T> Optional<T>	getOptional(ConfigOption<T> option) Reads a value using the metadata included in ConfigOption.
long	getStateRetentionTime()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

get

public <T> T get(ConfigOption<T> option)

Description copied from interface: ReadableConfig

Reads a value using the metadata included in ConfigOption. Returns the ConfigOption.defaultValue() if value key not present in the configuration.

Specified by:

get in interface ReadableConfig

Type Parameters:

T - type of the value to read

Parameters:

option - metadata of the option to read

Returns:

read value or ConfigOption.defaultValue() if not found

See Also:

ReadableConfig.getOptional(ConfigOption)

getOptional

public <T> Optional<T> getOptional(ConfigOption<T> option)

Description copied from interface: ReadableConfig

Reads a value using the metadata included in ConfigOption. In contrast to ReadableConfig.get(ConfigOption) returns Optional.empty() if value not present.

Specified by:

getOptional in interface ReadableConfig

Type Parameters:

T - type of the value to read

Parameters:

option - metadata of the option to read

Returns:

read value or Optional.empty() if not found

See Also:

ReadableConfig.get(ConfigOption)

getStateRetentionTime

public long getStateRetentionTime()

Returns:

The duration until state which was not updated will be retained.