Package | Description |
---|---|
org.apache.flink.table.planner.plan.nodes.process | |
org.apache.flink.table.planner.plan.processors |
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.
|
Modifier and Type | Method and Description |
---|---|
List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> |
MultipleInputNodeCreationProcessor.process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> roots,
DAGProcessContext context) |
List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> |
DeadlockBreakupProcessor.process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> rootNodes,
DAGProcessContext context) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.