org.apache.flink.table.delegation

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 the Planner interface. The TableEnvironment wraps it in an implementation of CompiledPlan, to provide the fluent user-friendly interface.

Method Summary

Modifier and Type	Method and 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 that ignoreIfExists has precedence over failIfExists.

Method Detail

asJsonString

String asJsonString()

See Also:

CompiledPlan.asJsonString()

writeToFile

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

Note that ignoreIfExists has precedence over failIfExists.

See Also:

CompiledPlan.writeToFile(File, boolean)

getFlinkVersion

FlinkVersion getFlinkVersion()

See Also:

CompiledPlan.getFlinkVersion()

getSinkIdentifiers

List<String> getSinkIdentifiers()

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