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

类 ExecNodeConfig

java.lang.Object

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

所有已实现的接口:

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().

方法概要

限定符和类型	方法和说明
<T> T	get(org.apache.flink.configuration.ConfigOption<T> option)
<T> Optional<T>	getOptional(org.apache.flink.configuration.ConfigOption<T> option)
long	getStateRetentionTime()
org.apache.flink.table.api.TableConfig	getTableConfig() 已过时。

从类继承的方法 java.lang.Object

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

方法详细资料

getTableConfig

@Deprecated
public org.apache.flink.table.api.TableConfig getTableConfig()

已过时。

Return the PlannerBase.getTableConfig().

返回:

the PlannerBase.getTableConfig().

get

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

指定者:

get 在接口中 org.apache.flink.configuration.ReadableConfig

getOptional

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

指定者:

getOptional 在接口中 org.apache.flink.configuration.ReadableConfig

getStateRetentionTime

public long getStateRetentionTime()

返回:

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