org.apache.flink.table.planner.plan

类 ExecNodeGraphInternalPlan

java.lang.Object

org.apache.flink.table.planner.plan.ExecNodeGraphInternalPlan

所有已实现的接口:

org.apache.flink.table.delegation.InternalPlan

@Internal
public class ExecNodeGraphInternalPlan
extends Object
implements org.apache.flink.table.delegation.InternalPlan

Implementation of CompiledPlan backed by an ExecNodeGraph.

构造器概要

构造器

构造器和说明
ExecNodeGraphInternalPlan(String serializedPlan, ExecNodeGraph execNodeGraph)

方法概要

限定符和类型	方法和说明
String	asJsonString()
ExecNodeGraph	getExecNodeGraph()
org.apache.flink.FlinkVersion	getFlinkVersion()
List<String>	getSinkIdentifiers()
void	writeToFile(File file, boolean ignoreIfExists, boolean failIfExists)

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

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

构造器详细资料

ExecNodeGraphInternalPlan

public ExecNodeGraphInternalPlan(String serializedPlan,
                                 ExecNodeGraph execNodeGraph)

方法详细资料

getExecNodeGraph

public ExecNodeGraph getExecNodeGraph()

asJsonString

public String asJsonString()

指定者:

asJsonString 在接口中 org.apache.flink.table.delegation.InternalPlan

writeToFile

public void writeToFile(File file,
                        boolean ignoreIfExists,
                        boolean failIfExists)

指定者:

writeToFile 在接口中 org.apache.flink.table.delegation.InternalPlan

getFlinkVersion

public org.apache.flink.FlinkVersion getFlinkVersion()

指定者:

getFlinkVersion 在接口中 org.apache.flink.table.delegation.InternalPlan

getSinkIdentifiers

public List<String> getSinkIdentifiers()

指定者:

getSinkIdentifiers 在接口中 org.apache.flink.table.delegation.InternalPlan