public class ExecNodeGraphGenerator extends Object
ExecNode
graph from a graph of FlinkPhysicalRel
s.
This traverses the tree of FlinkPhysicalRel
starting from the sinks. At each rel we
recursively transform the inputs, then create a ExecNode
. Each rel will be visited only
once, that means a rel will only generate one ExecNode instance.
Exchange and Union will create a actual node in the ExecNode
graph as the first step,
once all ExecNodes' implementation are separated from physical rel, we will use InputProperty
to replace them.
Constructor and Description |
---|
ExecNodeGraphGenerator() |
Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
generate(List<org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel> relNodes) |
public ExecNodeGraph generate(List<org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel> relNodes)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.