public interface OpFusionContext
OpFusionCodegenSpec
needed to do operator fusion codegen.Modifier and Type | Method and Description |
---|---|
String |
endInputConsume()
Generate Java source code to do clean work for
OpFusionCodegenSpec corresponding
input, delegate to OpFusionCodegenSpecGenerator.endInputConsume() method. |
void |
endInputProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext codegenCtx)
Generate Java source code to do clean work for operator corresponding input, delegate to
OpFusionCodegenSpecGenerator.endInputProduce(CodeGeneratorContext) method. |
List<OpFusionContext> |
getInputFusionContexts()
Return the input
OpFusionContext of this OpFusionCodegenSpecGenerator . |
double |
getManagedMemoryFraction()
Return the managed memory fraction of this
OpFusionCodegenSpecGenerator needed during
all fusion operators. |
RowType |
getOutputType()
Return the output type of current
OpFusionCodegenSpecGenerator . |
default String |
processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars) |
String |
processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars,
String row)
Consume the generated columns or row from current
OpFusionCodegenSpec , delegate to
OpFusionCodegenSpecGenerator.processConsume(List, String) ()} method. |
void |
processProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext codegenCtx)
Generate Java source code to process the rows from operator corresponding input, delegate to
OpFusionCodegenSpecGenerator.processProduce(CodeGeneratorContext) method. |
RowType getOutputType()
OpFusionCodegenSpecGenerator
.double getManagedMemoryFraction()
OpFusionCodegenSpecGenerator
needed during
all fusion operators.List<OpFusionContext> getInputFusionContexts()
OpFusionContext
of this OpFusionCodegenSpecGenerator
.void processProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext codegenCtx)
OpFusionCodegenSpecGenerator.processProduce(CodeGeneratorContext)
method.void endInputProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext codegenCtx)
OpFusionCodegenSpecGenerator.endInputProduce(CodeGeneratorContext)
method.default String processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars)
String processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars, String row)
OpFusionCodegenSpec
, delegate to
OpFusionCodegenSpecGenerator.processConsume(List, String)
()} method.
Note that `outputVars` and `row` can't both be null.
String endInputConsume()
OpFusionCodegenSpec
corresponding
input, delegate to OpFusionCodegenSpecGenerator.endInputConsume()
method.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.