public interface DAGProcessor
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.
|
List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> sinkNodes, DAGProcessContext context)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.