org.apache.drill.exec.planner.physical.visitor

Class RuntimeFilterVisitor

java.lang.Object

org.apache.drill.exec.planner.physical.visitor.BasePrelVisitor<Prel,Void,RuntimeException>

org.apache.drill.exec.planner.physical.visitor.RuntimeFilterVisitor

All Implemented Interfaces:

PrelVisitor<Prel,Void,RuntimeException>

public class RuntimeFilterVisitor
extends BasePrelVisitor<Prel,Void,RuntimeException>

This visitor does two major things: 1) Find the possible HashJoinPrel to add a RuntimeFilterDef to it. 2) Generate a RuntimeFilterPrel over the corresponding probe side ScanPrel.

Field Summary

Fields inherited from interface org.apache.drill.exec.planner.physical.visitor.PrelVisitor

logger

Method Summary

Modifier and Type	Method and Description
static Prel	addRuntimeFilter(Prel prel, QueryContext queryContext)
Prel	visitJoin(JoinPrel prel, Void value)
Prel	visitPrel(Prel prel, Void value)
Prel	visitScan(ScanPrel prel, Void value)

Methods inherited from class org.apache.drill.exec.planner.physical.visitor.BasePrelVisitor

visitExchange, visitLateral, visitLeaf, visitProject, visitScan, visitScreen, visitUnnest, visitWriter

Methods inherited from class java.lang.Object

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

Method Detail

addRuntimeFilter

public static Prel addRuntimeFilter(Prel prel,
                                    QueryContext queryContext)

visitPrel

public Prel visitPrel(Prel prel,
                      Void value)
               throws RuntimeException

Specified by:

visitPrel in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitPrel in class BasePrelVisitor<Prel,Void,RuntimeException>

Throws:

RuntimeException

visitJoin

public Prel visitJoin(JoinPrel prel,
                      Void value)
               throws RuntimeException

Specified by:

visitJoin in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitJoin in class BasePrelVisitor<Prel,Void,RuntimeException>

Throws:

RuntimeException

visitScan

public Prel visitScan(ScanPrel prel,
                      Void value)
               throws RuntimeException

Specified by:

visitScan in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitScan in class BasePrelVisitor<Prel,Void,RuntimeException>

Throws:

RuntimeException