| Modifier and Type | Method and Description |
|---|---|
abstract List<OpFusionCodegenSpecGenerator> |
OpFusionCodegenSpecGenerator.getInputs() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
OpFusionCodegenSpecGenerator.addOutput(int inputIdOfOutput,
OpFusionCodegenSpecGenerator output)
Add the specific
OpFusionCodegenSpecGenerator as the output of current operator spec
generator, one OpFusionCodegenSpecGenerator may have multiple outputs that form a
DAG. |
| Modifier and Type | Method and Description |
|---|---|
OpFusionCodegenSpecGenerator |
ExecEdge.translateToFusionCodegenSpec(org.apache.flink.table.delegation.Planner planner,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx)
Translates this edge into operator fusion codegen spec generator.
|
OpFusionCodegenSpecGenerator |
FusionCodegenExecNode.translateToFusionCodegenSpec(org.apache.flink.table.delegation.Planner planner,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx)
Translates this node into a
OpFusionCodegenSpecGenerator. |
OpFusionCodegenSpecGenerator |
ExecNodeBase.translateToFusionCodegenSpec(org.apache.flink.table.delegation.Planner planner,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
ExecNodeBase.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx)
Internal method, translates this node into a operator codegen spec generator.
|
| Modifier and Type | Method and Description |
|---|---|
protected OpFusionCodegenSpecGenerator |
BatchExecExecutionOrderEnforcer.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecHashJoin.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecHashAggregate.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecCalc.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
protected OpFusionCodegenSpecGenerator |
BatchExecInputAdapter.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
| Modifier and Type | Method and Description |
|---|---|
protected OpFusionCodegenSpecGenerator |
BatchExecRuntimeFilter.translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner,
ExecNodeConfig config,
org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.