org.apache.flink.table.planner.plan.reuse

Class ReplaceScanWithCalcShuttle

java.lang.Object

org.apache.calcite.rel.RelShuttleImpl

org.apache.calcite.rel.RelHomogeneousShuttle

org.apache.flink.table.planner.plan.utils.DefaultRelShuttle

org.apache.flink.table.planner.plan.reuse.ReplaceScanWithCalcShuttle

All Implemented Interfaces:

org.apache.calcite.rel.RelShuttle

public class ReplaceScanWithCalcShuttle
extends org.apache.flink.table.planner.plan.utils.DefaultRelShuttle

Replace CommonPhysicalTableSourceScan with Calc.

Field Summary

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

stack

Constructor Summary

Constructors

Constructor and Description
ReplaceScanWithCalcShuttle(Map<org.apache.flink.table.planner.plan.nodes.physical.common.CommonPhysicalTableSourceScan,org.apache.calcite.rel.RelNode> replaceMap)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.RelNode	visit(org.apache.calcite.rel.RelNode rel)

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

visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit, visit

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

visitChild, visitChildren

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplaceScanWithCalcShuttle

public ReplaceScanWithCalcShuttle(Map<org.apache.flink.table.planner.plan.nodes.physical.common.CommonPhysicalTableSourceScan,org.apache.calcite.rel.RelNode> replaceMap)

Method Detail

visit

public org.apache.calcite.rel.RelNode visit(org.apache.calcite.rel.RelNode rel)

Specified by:

visit in interface org.apache.calcite.rel.RelShuttle

Overrides:

visit in class org.apache.flink.table.planner.plan.utils.DefaultRelShuttle