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