public class BatchExecCalc extends CommonExecCalc implements BatchExecNode<RowData>
ExecNode
for Calc.CALC_TRANSFORMATION, condition, FIELD_NAME_CONDITION, FIELD_NAME_PROJECTION, projection
FIELD_NAME_CONFIGURATION, FIELD_NAME_DESCRIPTION, FIELD_NAME_ID, FIELD_NAME_INPUT_PROPERTIES, FIELD_NAME_OUTPUT_TYPE, FIELD_NAME_STATE, FIELD_NAME_TYPE
Constructor and Description |
---|
BatchExecCalc(ReadableConfig tableConfig,
List<org.apache.calcite.rex.RexNode> projection,
org.apache.calcite.rex.RexNode condition,
InputProperty inputProperty,
RowType outputType,
String description) |
Modifier and Type | Method and Description |
---|---|
boolean |
supportFusionCodegen()
Whether this ExecNode supports OFCG or not.
|
protected OpFusionCodegenSpecGenerator |
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.
|
translateToPlanInternal
accept, createFormattedTransformationDescription, createFormattedTransformationName, createTransformationDescription, createTransformationMeta, createTransformationMeta, createTransformationName, createTransformationUid, getContextFromAnnotation, getDescription, getId, getInputEdges, getInputProperties, getOutputType, getPersistedConfig, getSimplifiedName, getTransformation, inputsContainSingleton, replaceInputEdge, setCompiled, setInputEdges, translateToFusionCodegenSpec, translateToPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, getDescription, getId, getInputEdges, getInputProperties, getOutputType, replaceInputEdge, setCompiled, setInputEdges
translateToPlan
translateToFusionCodegenSpec
public BatchExecCalc(ReadableConfig tableConfig, List<org.apache.calcite.rex.RexNode> projection, @Nullable org.apache.calcite.rex.RexNode condition, InputProperty inputProperty, RowType outputType, String description)
public boolean supportFusionCodegen()
FusionCodegenExecNode
supportFusionCodegen
in interface FusionCodegenExecNode
supportFusionCodegen
in class ExecNodeBase<RowData>
protected OpFusionCodegenSpecGenerator translateToFusionCodegenSpecInternal(org.apache.flink.table.planner.delegation.PlannerBase planner, ExecNodeConfig config, org.apache.flink.table.planner.codegen.CodeGeneratorContext parentCtx)
ExecNodeBase
translateToFusionCodegenSpecInternal
in class ExecNodeBase<RowData>
planner
- The planner.config
- per-ExecNode
configuration that contains the merged configuration from
various layers which all the nodes implementing this method should use, instead of
retrieving configuration from the planner
. For more details check ExecNodeConfig
.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.