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

Class ReusableScanVisitor

java.lang.Object

org.apache.calcite.rel.RelVisitor

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

public class ReusableScanVisitor
extends org.apache.calcite.rel.RelVisitor

Find reusable sources.

Constructor Summary

Constructors

Constructor and Description
ReusableScanVisitor()

Method Summary

Modifier and Type	Method and Description
Map<String,List<CommonPhysicalTableSourceScan>>	digestToReusableScans()
void	visit(org.apache.calcite.rel.RelNode node, int ordinal, org.apache.calcite.rel.RelNode parent)

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

go, replaceRoot

Methods inherited from class java.lang.Object

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

Constructor Detail

ReusableScanVisitor

public ReusableScanVisitor()

Method Detail

visit

public void visit(org.apache.calcite.rel.RelNode node,
                  int ordinal,
                  org.apache.calcite.rel.RelNode parent)

Overrides:

visit in class org.apache.calcite.rel.RelVisitor

digestToReusableScans

public Map<String,List<CommonPhysicalTableSourceScan>> digestToReusableScans()