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

Class InsertLocalExchangeVisitor

java.lang.Object

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

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

All Implemented Interfaces:

PrelVisitor<Prel,Void,RuntimeException>

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

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
InsertLocalExchangeVisitor(OptionManager options)

Method Summary

Modifier and Type	Method and Description
static Prel	insertLocalExchanges(Prel prel, OptionManager options)
Prel	visitExchange(ExchangePrel prel, Void value)
Prel	visitPrel(Prel prel, Void value)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

InsertLocalExchangeVisitor

public InsertLocalExchangeVisitor(OptionManager options)

Method Detail

insertLocalExchanges

public static Prel insertLocalExchanges(Prel prel,
                                        OptionManager options)

visitExchange

public Prel visitExchange(ExchangePrel prel,
                          Void value)
                   throws RuntimeException

Specified by:

visitExchange in interface PrelVisitor<Prel,Void,RuntimeException>

Overrides:

visitExchange in class BasePrelVisitor<Prel,Void,RuntimeException>

Throws:

RuntimeException

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