org.apache.flink.table.planner.plan.nodes.process

Interface DAGProcessor

public interface DAGProcessor

DAGProcess plugin, use it can set resource of dag or change other node info.

Method Summary

Modifier and Type	Method and Description
List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>>	process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> sinkNodes, DAGProcessContext context) Given a dag, process it and return the result dag.

Method Detail

process

List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> sinkNodes,
                                                                           DAGProcessContext context)

Given a dag, process it and return the result dag.