public class MultipleInputNodeCreationProcessor extends Object implements DAGProcessor
DAGProcessor
which organize ExecNode
s into multiple input nodes.
For a detailed explanation of the algorithm, see appendix of the design doc.
Constructor and Description |
---|
MultipleInputNodeCreationProcessor(boolean isStreaming) |
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<?,?>> roots,
DAGProcessContext context)
Given a dag, process it and return the result dag.
|
public MultipleInputNodeCreationProcessor(boolean isStreaming)
public List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> process(List<org.apache.flink.table.planner.plan.nodes.exec.ExecNode<?,?>> roots, DAGProcessContext context)
DAGProcessor
process
in interface DAGProcessor
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.