org.apache.flink.table.planner.plan.nodes.physical.stream

Class StreamPhysicalAsyncCalc

java.lang.Object

org.apache.calcite.rel.AbstractRelNode

org.apache.calcite.rel.SingleRel

org.apache.calcite.rel.core.Calc

org.apache.flink.table.planner.plan.nodes.common.CommonCalc

org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalCalcBase

org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalAsyncCalc

All Implemented Interfaces:

Cloneable, org.apache.calcite.plan.RelOptNode, org.apache.calcite.rel.hint.Hintable, org.apache.calcite.rel.RelNode, org.apache.flink.table.planner.plan.nodes.FlinkRelNode, org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel, org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalRel

public class StreamPhysicalAsyncCalc
extends org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalCalcBase

Stream physical RelNode for AsyncScalarFunction.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.calcite.rel.RelNode

org.apache.calcite.rel.RelNode.Context

Field Summary

Fields inherited from class org.apache.calcite.rel.core.Calc

hints, program

Fields inherited from class org.apache.calcite.rel.SingleRel

input

Fields inherited from class org.apache.calcite.rel.AbstractRelNode

digest, id, rowType, traitSet

Constructor Summary

Constructors

Constructor and Description
StreamPhysicalAsyncCalc(org.apache.calcite.plan.RelOptCluster cluster, org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode inputRel, org.apache.calcite.rex.RexProgram calcProgram, org.apache.calcite.rel.type.RelDataType outputRowType)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.core.Calc	copy(org.apache.calcite.plan.RelTraitSet traitSet, org.apache.calcite.rel.RelNode child, org.apache.calcite.rex.RexProgram program)
ExecNode<?>	translateToExecNode()

Methods inherited from class org.apache.flink.table.planner.plan.nodes.physical.stream.StreamPhysicalCalcBase

deriveRowType, requireWatermark, satisfyTraits, translateToExecNode

Methods inherited from class org.apache.flink.table.planner.plan.nodes.common.CommonCalc

computeSelfCost, convertToExpressionDetail, explainTerms, getExpressionString, getExpressionString, getExpressionString, getExpressionString, getRelDetailedDescription, projectionToString, projectionToString$default$1

Methods inherited from class org.apache.calcite.rel.core.Calc

accept, containsOver, copy, copy, estimateRowCount, getHints, getProgram, isValid

Methods inherited from class org.apache.calcite.rel.SingleRel

childrenAccept, getInput, getInputs, replaceInput

Methods inherited from class org.apache.calcite.rel.AbstractRelNode

accept, collectVariablesSet, collectVariablesUsed, deepEquals, deepHashCode, equals, explain, getCluster, getConvention, getCorrelVariable, getDescription, getDigest, getExpectedInputRowType, getId, getInput, getRelDigest, getRelTypeName, getRowType, getTable, getTraitSet, getVariablesSet, hashCode, isEnforcer, metadata, onRegister, recomputeDigest, register, sole, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.physical.FlinkPhysicalRel

$init$

Methods inherited from interface org.apache.flink.table.planner.plan.nodes.FlinkRelNode

$init$, convertToExpressionDetail, getExpressionString, getExpressionString, getExpressionString, getExpressionString, getRelDetailedDescription

Methods inherited from interface org.apache.calcite.rel.RelNode

accept, accept, childrenAccept, collectVariablesSet, collectVariablesUsed, computeSelfCost, copy, deepEquals, deepHashCode, estimateRowCount, explain, explain, fieldIsNullable, getConvention, getCorrelVariable, getDigest, getExpectedInputRowType, getInput, getInputs, getRelDigest, getRelTypeName, getRowType, getTable, getVariablesSet, isEnforcer, isValid, metadata, onRegister, recomputeDigest, register, replaceInput

Methods inherited from interface org.apache.calcite.plan.RelOptNode

getCluster, getDescription, getId, getTraitSet

Methods inherited from interface org.apache.calcite.rel.hint.Hintable

attachHints, withHints

Constructor Detail

StreamPhysicalAsyncCalc

public StreamPhysicalAsyncCalc(org.apache.calcite.plan.RelOptCluster cluster,
                               org.apache.calcite.plan.RelTraitSet traitSet,
                               org.apache.calcite.rel.RelNode inputRel,
                               org.apache.calcite.rex.RexProgram calcProgram,
                               org.apache.calcite.rel.type.RelDataType outputRowType)

Method Detail

copy

public org.apache.calcite.rel.core.Calc copy(org.apache.calcite.plan.RelTraitSet traitSet,
                                             org.apache.calcite.rel.RelNode child,
                                             org.apache.calcite.rex.RexProgram program)

Specified by:

copy in class org.apache.calcite.rel.core.Calc

translateToExecNode

public ExecNode<?> translateToExecNode()