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

Class ExcessiveExchangeIdentifier

java.lang.Object

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

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

All Implemented Interfaces:

PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

public class ExcessiveExchangeIdentifier
extends BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
ExcessiveExchangeIdentifier(long targetSliceSize)

Method Summary

Modifier and Type	Method	Description
org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat	getNewStat()
static Prel	removeExcessiveExchanges(Prel prel, long targetSliceSize)
Prel	visitExchange(ExchangePrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat parent)
Prel	visitLateral(LateralJoinPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	visitPrel(Prel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	visitScan(ScanPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	visitScreen(ScreenPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
Prel	visitUnnest(UnnestPrel prel, org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)

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

visitJoin, visitLeaf, visitProject, visitScan, visitTableModify, visitWriter

Methods inherited from class java.lang.Object

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

Constructor Details

ExcessiveExchangeIdentifier

public ExcessiveExchangeIdentifier(long targetSliceSize)

Method Details

removeExcessiveExchanges

public static Prel removeExcessiveExchanges(Prel prel,
 long targetSliceSize)

visitExchange

public Prel visitExchange(ExchangePrel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat parent)
                   throws RuntimeException

Specified by:

visitExchange in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitExchange in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

visitScreen

public Prel visitScreen(ScreenPrel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
                 throws RuntimeException

Specified by:

visitScreen in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitScreen in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

visitScan

public Prel visitScan(ScanPrel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
               throws RuntimeException

Specified by:

visitScan in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitScan in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

visitLateral

public Prel visitLateral(LateralJoinPrel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
                  throws RuntimeException

Specified by:

visitLateral in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitLateral in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

visitUnnest

public Prel visitUnnest(UnnestPrel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
                 throws RuntimeException

Specified by:

visitUnnest in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitUnnest in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

visitPrel

public Prel visitPrel(Prel prel,
 org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat s)
               throws RuntimeException

Specified by:

visitPrel in interface PrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Overrides:

visitPrel in class BasePrelVisitor<Prel,org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat,RuntimeException>

Throws:

RuntimeException

getNewStat

public org.apache.drill.exec.planner.physical.visitor.ExcessiveExchangeIdentifier.MajorFragmentStat getNewStat()