Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
ExecNodeGraphInternalPlan.getExecNodeGraph() |
Constructor and Description |
---|
ExecNodeGraphInternalPlan(String serializedPlan,
ExecNodeGraph execNodeGraph) |
Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
ExecNodeGraphGenerator.generate(List<org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel> relNodes,
boolean isCompiled) |
Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
ForwardHashExchangeProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
ResetTransformationProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
DeadlockBreakupProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
MultipleInputNodeCreationProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
DynamicFilteringDependencyProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
ExecNodeGraphProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context)
Given an
ExecNodeGraph , process it and return the result ExecNodeGraph . |
Modifier and Type | Method and Description |
---|---|
ExecNodeGraph |
ForwardHashExchangeProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
ResetTransformationProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
DeadlockBreakupProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
MultipleInputNodeCreationProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
DynamicFilteringDependencyProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context) |
ExecNodeGraph |
ExecNodeGraphProcessor.process(ExecNodeGraph execGraph,
ProcessorContext context)
Given an
ExecNodeGraph , process it and return the result ExecNodeGraph . |
Modifier and Type | Method and Description |
---|---|
static String |
ExecNodePlanDumper.dagToString(ExecNodeGraph execGraph)
Converts an
ExecNodeGraph to a string as a tree style. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.