org.apache.flink.table.planner.plan

Class ExecNodeGraphInternalPlan

java.lang.Object

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

All Implemented Interfaces:

InternalPlan

@Internal
public class ExecNodeGraphInternalPlan
extends Object
implements InternalPlan

Implementation of CompiledPlan backed by an ExecNodeGraph.

Constructor Summary

Constructors

Constructor and Description
ExecNodeGraphInternalPlan(Supplier<String> serializedPlanSupplier, ExecNodeGraph execNodeGraph)

Method Summary

Modifier and Type	Method and Description
String	asJsonString()
ExecNodeGraph	getExecNodeGraph()
FlinkVersion	getFlinkVersion()
List<String>	getSinkIdentifiers() This returns an ordered list of sink identifiers, if any.
void	writeToFile(File file, boolean ignoreIfExists, boolean failIfExists) Note that ignoreIfExists has precedence over failIfExists.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecNodeGraphInternalPlan

public ExecNodeGraphInternalPlan(Supplier<String> serializedPlanSupplier,
                                 ExecNodeGraph execNodeGraph)

Method Detail

getExecNodeGraph

public ExecNodeGraph getExecNodeGraph()

asJsonString

public String asJsonString()

Specified by:

asJsonString in interface InternalPlan

See Also:

CompiledPlan.asJsonString()

writeToFile

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

Description copied from interface: InternalPlan

Note that ignoreIfExists has precedence over failIfExists.

Specified by:

writeToFile in interface InternalPlan

See Also:

CompiledPlan.writeToFile(File, boolean)

getFlinkVersion

public FlinkVersion getFlinkVersion()

Specified by:

getFlinkVersion in interface InternalPlan

See Also:

CompiledPlan.getFlinkVersion()

getSinkIdentifiers

public List<String> getSinkIdentifiers()

Description copied from interface: InternalPlan

This returns an ordered list of sink identifiers, if any.

Specified by:

getSinkIdentifiers in interface InternalPlan