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:

org.apache.flink.configuration.ReadableConfig

@Internal
public final class ExecNodeConfig
extends Object
implements org.apache.flink.configuration.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().

This class is intended to contain additional context information for ExecNode translation such as shouldSetUid() or helper methods for accessing configuration such as getStateRetentionTime().

Method Summary

Modifier and Type	Method and Description
<T> T	get(org.apache.flink.configuration.ConfigOption<T> option)
<T> Optional<T>	getOptional(org.apache.flink.configuration.ConfigOption<T> option)
long	getStateRetentionTime()
boolean	isCompiled()
static ExecNodeConfig	ofNodeConfig(org.apache.flink.configuration.ReadableConfig nodeConfig, boolean isCompiled)
static ExecNodeConfig	ofTableConfig(org.apache.flink.table.api.TableConfig tableConfig, boolean isCompiled)
boolean	shouldSetUid()
Map<String,String>	toMap()

Methods inherited from class java.lang.Object

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

Method Detail

ofNodeConfig

public static ExecNodeConfig ofNodeConfig(org.apache.flink.configuration.ReadableConfig nodeConfig,
                                          boolean isCompiled)

ofTableConfig

@VisibleForTesting
public static ExecNodeConfig ofTableConfig(org.apache.flink.table.api.TableConfig tableConfig,
                                                              boolean isCompiled)

get

public <T> T get(org.apache.flink.configuration.ConfigOption<T> option)

Specified by:

get in interface org.apache.flink.configuration.ReadableConfig

getOptional

public <T> Optional<T> getOptional(org.apache.flink.configuration.ConfigOption<T> option)

Specified by:

getOptional in interface org.apache.flink.configuration.ReadableConfig

toMap

@Internal
public Map<String,String> toMap()

Specified by:

toMap in interface org.apache.flink.configuration.ReadableConfig

getStateRetentionTime

public long getStateRetentionTime()

Returns:

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

isCompiled

public boolean isCompiled()

Returns:

Whether the ExecNode translation happens as part of a plan compilation.

shouldSetUid

public boolean shouldSetUid()

Returns:

Whether transformations should set a UID.