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

Class StreamPhysicalAsyncCalc

java.lang.Object

StreamPhysicalCalcBase

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

public class StreamPhysicalAsyncCalc
extends StreamPhysicalCalcBase

Stream physical RelNode for AsyncScalarFunction.

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 java.lang.Object

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

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)

translateToExecNode

public ExecNode<?> translateToExecNode()