Interface InternalPlan
-
- All Known Implementing Classes:
ExecNodeGraphInternalPlan
@Internal public interface InternalPlan
Internal interface wrapping a plan. This is used in order to propagate the plan back and forth thePlanner
interface. TheTableEnvironment
wraps it in an implementation ofCompiledPlan
, to provide the fluent user-friendly interface.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description String
asJsonString()
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
.
-
-
-
Method Detail
-
asJsonString
String asJsonString()
- See Also:
CompiledPlan.asJsonString()
-
writeToFile
void writeToFile(File file, boolean ignoreIfExists, boolean failIfExists)
Note thatignoreIfExists
has precedence overfailIfExists
.- See Also:
CompiledPlan.writeToFile(File, boolean)
-
getFlinkVersion
FlinkVersion getFlinkVersion()
- See Also:
CompiledPlan.getFlinkVersion()
-
-