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

Class LateralUnnestRowIDVisitor

java.lang.Object

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

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

All Implemented Interfaces:

PrelVisitor<Prel,Boolean,RuntimeException>

public class LateralUnnestRowIDVisitor
extends BasePrelVisitor<Prel,Boolean,RuntimeException>

LateralUnnestRowIDVisitor traverses the physical plan and modifies all the operators in the pipeline of Lateral and Unnest operators to accommodate IMPLICIT_COLUMN. The source for the IMPLICIT_COLUMN is unnest operator and the sink for the column is the corresponding Lateral join operator.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LateralUnnestRowIDVisitor.CorrelateVarReplacer	Visitor for RelNodes which applies specified RexShuttle visitor for every node in the tree.

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
LateralUnnestRowIDVisitor()

Method Summary

Modifier and Type	Method	Description
static Prel	insertRowID(Prel prel)
Prel	visitLateral(LateralJoinPrel prel, Boolean isRightOfLateral)
Prel	visitPrel(Prel prel, Boolean isRightOfLateral)
Prel	visitUnnest(UnnestPrel prel, Boolean isRightOfLateral)

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

visitExchange, visitJoin, visitLeaf, visitProject, visitScan, visitScan, visitScreen, visitTableModify, visitWriter

Methods inherited from class java.lang.Object

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

Constructor Details

LateralUnnestRowIDVisitor

public LateralUnnestRowIDVisitor()

Method Details

insertRowID

public static Prel insertRowID(Prel prel)

visitPrel

public Prel visitPrel(Prel prel,
 Boolean isRightOfLateral)
               throws RuntimeException

Specified by:

visitPrel in interface PrelVisitor<Prel,Boolean,RuntimeException>

Overrides:

visitPrel in class BasePrelVisitor<Prel,Boolean,RuntimeException>

Throws:

RuntimeException

visitLateral

public Prel visitLateral(LateralJoinPrel prel,
 Boolean isRightOfLateral)
                  throws RuntimeException

Specified by:

visitLateral in interface PrelVisitor<Prel,Boolean,RuntimeException>

Overrides:

visitLateral in class BasePrelVisitor<Prel,Boolean,RuntimeException>

Throws:

RuntimeException

visitUnnest

public Prel visitUnnest(UnnestPrel prel,
 Boolean isRightOfLateral)
                 throws RuntimeException

Specified by:

visitUnnest in interface PrelVisitor<Prel,Boolean,RuntimeException>

Overrides:

visitUnnest in class BasePrelVisitor<Prel,Boolean,RuntimeException>

Throws:

RuntimeException