Uses of Class
org.apache.flink.optimizer.plan.SinkPlanNode
-
Packages that use SinkPlanNode Package Description org.apache.flink.optimizer.plan org.apache.flink.optimizer.plandump org.apache.flink.optimizer.traversals This package contains the various traversals over the program plan and the optimizer DAG (directed acyclic graph) that are made in the course of the optimization. -
-
Uses of SinkPlanNode in org.apache.flink.optimizer.plan
Methods in org.apache.flink.optimizer.plan that return types with arguments of type SinkPlanNode Modifier and Type Method Description Collection<SinkPlanNode>OptimizedPlan. getDataSinks()Gets the data sinks from this OptimizedPlan.Method parameters in org.apache.flink.optimizer.plan with type arguments of type SinkPlanNode Modifier and Type Method Description voidSinkJoinerPlanNode. getDataSinks(List<SinkPlanNode> sinks) -
Uses of SinkPlanNode in org.apache.flink.optimizer.plandump
Method parameters in org.apache.flink.optimizer.plandump with type arguments of type SinkPlanNode Modifier and Type Method Description voidPlanJSONDumpGenerator. dumpOptimizerPlanAsJSON(List<SinkPlanNode> nodes, PrintWriter writer) -
Uses of SinkPlanNode in org.apache.flink.optimizer.traversals
Method parameters in org.apache.flink.optimizer.traversals with type arguments of type SinkPlanNode Modifier and Type Method Description OptimizedPlanPlanFinalizer. createFinalPlan(List<SinkPlanNode> sinks, String jobName, org.apache.flink.api.common.Plan originalPlan)
-