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

Class ReplaceScanWithCalcShuttle

java.lang.Object

DefaultRelShuttle

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

public class ReplaceScanWithCalcShuttle
extends DefaultRelShuttle

Replace CommonPhysicalTableSourceScan with Calc.

Constructor Summary

Constructors

Constructor and Description
ReplaceScanWithCalcShuttle(Map<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 java.lang.Object

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

Constructor Detail

ReplaceScanWithCalcShuttle

public ReplaceScanWithCalcShuttle(Map<CommonPhysicalTableSourceScan,org.apache.calcite.rel.RelNode> replaceMap)

Method Detail

visit

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