org.apache.flink.table.planner.plan.fusion

Class OpFusionCodegenSpecGenerator

java.lang.Object

org.apache.flink.table.planner.plan.fusion.OpFusionCodegenSpecGenerator

@Internal
public abstract class OpFusionCodegenSpecGenerator
extends Object

OpFusionCodegenSpecGenerator is used to operator fusion codegen that generate the fusion code, it has multiple inputs and outputs, then form a DAG. Every OpFusionCodegenSpecGenerator holds an OpFusionCodegenSpec that used to generate the operator process row code. In addition, it also provides some meta information that codegen needed.

Field Summary

Fields

Modifier and Type	Field and Description
protected OpFusionCodegenSpec	opFusionCodegenSpec

Constructor Summary

Constructors

Constructor and Description
OpFusionCodegenSpecGenerator(RowType outputType, OpFusionCodegenSpec opFusionCodegenSpec)

Method Summary

Modifier and Type	Method and Description
abstract void	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.
abstract void	addReusableCloseCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)
abstract void	addReusableInitCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)
abstract void	addReusableOpenCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)
abstract String	endInputConsume() Generate code to trigger the clean work of operator, call its output's OpFusionCodegenSpec.doEndInputConsume(int).
abstract void	endInputProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx) Generate Java source code to do clean work for operator corresponding input.
abstract List<OpFusionCodegenSpecGenerator>	getInputs()
abstract long	getManagedMemory()
OpFusionCodegenSpec	getOpFusionCodegenSpec()
OpFusionContext	getOpFusionContext()
RowType	getOutputType()
abstract String	processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars, String row) Consume the generated columns or row from current operator, call its output's OpFusionCodegenSpec.doProcessConsume(int, List, GeneratedExpression) method.
abstract void	processProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx) Generate Java source code to process the rows from operator corresponding input.
void	setup(org.apache.flink.table.planner.plan.fusion.OpFusionCodegenSpecGenerator.Context context) Initializes the operator spec generator needed information.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

opFusionCodegenSpec

protected final OpFusionCodegenSpec opFusionCodegenSpec

Constructor Detail

OpFusionCodegenSpecGenerator

public OpFusionCodegenSpecGenerator(RowType outputType,
                                    OpFusionCodegenSpec opFusionCodegenSpec)

Method Detail

setup

public void setup(org.apache.flink.table.planner.plan.fusion.OpFusionCodegenSpecGenerator.Context context)

Initializes the operator spec generator needed information. This method must be called before produce and consume related method.

getOutputType

public RowType getOutputType()

getOpFusionCodegenSpec

public OpFusionCodegenSpec getOpFusionCodegenSpec()

getOpFusionContext

public OpFusionContext getOpFusionContext()

getManagedMemory

public abstract long getManagedMemory()

getInputs

public abstract List<OpFusionCodegenSpecGenerator> getInputs()

addOutput

public abstract void 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.

Parameters:

inputIdOfOutput - This is numbered starting from 1, and `1` indicates the first input of output OpFusionCodegenSpecGenerator.

output - The OpFusionCodegenSpecGenerator as output of current spec generator.

processProduce

public abstract void processProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)

Generate Java source code to process the rows from operator corresponding input.

processConsume

public abstract String processConsume(List<org.apache.flink.table.planner.codegen.GeneratedExpression> outputVars,
                                      String row)

Consume the generated columns or row from current operator, call its output's OpFusionCodegenSpec.doProcessConsume(int, List, GeneratedExpression) method.

Note that `outputVars` and `row` can't both be null.

endInputProduce

public abstract void endInputProduce(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)

Generate Java source code to do clean work for operator corresponding input.

endInputConsume

public abstract String endInputConsume()

Generate code to trigger the clean work of operator, call its output's OpFusionCodegenSpec.doEndInputConsume(int). The leaf operator start to call endInputConsume method.

addReusableInitCode

public abstract void addReusableInitCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)

addReusableOpenCode

public abstract void addReusableOpenCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)

addReusableCloseCode

public abstract void addReusableCloseCode(org.apache.flink.table.planner.codegen.CodeGeneratorContext fusionCtx)