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 ofCompiledPlan
backed by anExecNodeGraph
.
-
-
Constructor Summary
Constructors Constructor Description ExecNodeGraphInternalPlan(Supplier<String> serializedPlanSupplier, ExecNodeGraph execNodeGraph)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 thatignoreIfExists
has precedence overfailIfExists
.
-
-
-
Constructor Detail
-
ExecNodeGraphInternalPlan
public ExecNodeGraphInternalPlan(Supplier<String> serializedPlanSupplier, ExecNodeGraph execNodeGraph)
-
-
Method Detail
-
getExecNodeGraph
public ExecNodeGraph getExecNodeGraph()
-
asJsonString
public String asJsonString()
- Specified by:
asJsonString
in interfaceInternalPlan
- See Also:
CompiledPlan.asJsonString()
-
writeToFile
public void writeToFile(File file, boolean ignoreIfExists, boolean failIfExists)
Description copied from interface:InternalPlan
Note thatignoreIfExists
has precedence overfailIfExists
.- Specified by:
writeToFile
in interfaceInternalPlan
- See Also:
CompiledPlan.writeToFile(File, boolean)
-
getFlinkVersion
public FlinkVersion getFlinkVersion()
- Specified by:
getFlinkVersion
in interfaceInternalPlan
- 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 interfaceInternalPlan
-
-