Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.process |
Modifier and Type | Method and Description |
---|---|
List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> |
DAGProcessor.process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> sinkNodes,
DAGProcessContext context)
Given a dag, process it and return the result dag.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.