Uses of Class
org.apache.flink.optimizer.dag.DataSinkNode

Packages that use DataSinkNode

Package	Description
org.apache.flink.optimizer
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 DataSinkNode in org.apache.flink.optimizer

Methods in org.apache.flink.optimizer that return types with arguments of type DataSinkNode

Modifier and Type	Method and Description
static List<DataSinkNode>	Optimizer.createPreOptimizedPlan(Plan program) This function performs only the first step to the compilation process - the creation of the optimizer representation of the plan.

Uses of DataSinkNode in org.apache.flink.optimizer.plan

Methods in org.apache.flink.optimizer.plan that return DataSinkNode

Modifier and Type	Method and Description
DataSinkNode	SinkPlanNode.getSinkNode()

Constructors in org.apache.flink.optimizer.plan with parameters of type DataSinkNode

Constructor and Description
SinkPlanNode(DataSinkNode template, String nodeName, Channel input) Constructs a new sink candidate node that uses NONE as its local strategy.

Uses of DataSinkNode in org.apache.flink.optimizer.plandump

Method parameters in org.apache.flink.optimizer.plandump with type arguments of type DataSinkNode

Modifier and Type	Method and Description
void	PlanJSONDumpGenerator.dumpPactPlanAsJSON(List<DataSinkNode> nodes, PrintWriter writer)
String	PlanJSONDumpGenerator.getPactPlanAsJSON(List<DataSinkNode> nodes)

Uses of DataSinkNode in org.apache.flink.optimizer.traversals

Methods in org.apache.flink.optimizer.traversals that return types with arguments of type DataSinkNode

Modifier and Type	Method and Description
List<DataSinkNode>	GraphCreatingVisitor.getSinks()