org.apache.drill.exec.planner.fragment

Class StatsCollector

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<RET,Wrapper,EXCEP>

org.apache.drill.exec.planner.AbstractOpWrapperVisitor<Void,RuntimeException>

org.apache.drill.exec.planner.fragment.StatsCollector

All Implemented Interfaces:

PhysicalVisitor<Void,Wrapper,RuntimeException>

public class StatsCollector
extends AbstractOpWrapperVisitor<Void,RuntimeException>

Visitor to collect stats such as cost and parallelization info of operators within a fragment. All operators have cost associated with them, but only few type of operators such as scan, store and exchanges (both sending and receiving) have parallelization info associated with them.

Constructor Summary

Constructors

Constructor and Description
StatsCollector(PlanningSet planningSet)

Method Summary

Modifier and Type	Method and Description
Void	visitGroupScan(GroupScan groupScan, Wrapper wrapper)
Void	visitOp(PhysicalOperator op, Wrapper wrapper)
Void	visitReceivingExchange(Exchange exchange, Wrapper wrapper)
Void	visitSendingExchange(Exchange exchange, Wrapper wrapper)
Void	visitStore(Store store, Wrapper wrapper)

Methods inherited from class org.apache.drill.exec.planner.AbstractOpWrapperVisitor

visitExchange

Methods inherited from class org.apache.drill.exec.physical.base.AbstractPhysicalVisitor

visitBroadcastSender, visitChildren, visitFilter, visitFlatten, visitHashAggregate, visitHashPartitionSender, visitHashPartitionSender, visitIteratorValidator, visitLateralJoin, visitLimit, visitMergingReceiver, visitOrderedPartitionSender, visitProducerConsumer, visitProject, visitRangePartitionSender, visitReceiver, visitRowKeyJoin, visitScreen, visitSender, visitSingleSender, visitSort, visitStatisticsAggregate, visitStatisticsMerge, visitStreamingAggregate, visitSubScan, visitTrace, visitUnion, visitUnnest, visitUnorderedReceiver, visitUnpivot, visitValues, visitWindowFrame, visitWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

StatsCollector

public StatsCollector(PlanningSet planningSet)

Method Detail

visitSendingExchange

public Void visitSendingExchange(Exchange exchange,
                                 Wrapper wrapper)
                          throws RuntimeException

Overrides:

visitSendingExchange in class AbstractOpWrapperVisitor<Void,RuntimeException>

Throws:

RuntimeException

visitReceivingExchange

public Void visitReceivingExchange(Exchange exchange,
                                   Wrapper wrapper)
                            throws RuntimeException

Overrides:

visitReceivingExchange in class AbstractOpWrapperVisitor<Void,RuntimeException>

Throws:

RuntimeException

visitGroupScan

public Void visitGroupScan(GroupScan groupScan,
                           Wrapper wrapper)

Specified by:

visitGroupScan in interface PhysicalVisitor<Void,Wrapper,RuntimeException>

Overrides:

visitGroupScan in class AbstractPhysicalVisitor<Void,Wrapper,RuntimeException>

visitStore

public Void visitStore(Store store,
                       Wrapper wrapper)

Specified by:

visitStore in interface PhysicalVisitor<Void,Wrapper,RuntimeException>

Overrides:

visitStore in class AbstractPhysicalVisitor<Void,Wrapper,RuntimeException>

visitOp

public Void visitOp(PhysicalOperator op,
                    Wrapper wrapper)

Specified by:

visitOp in interface PhysicalVisitor<Void,Wrapper,RuntimeException>

Overrides:

visitOp in class AbstractPhysicalVisitor<Void,Wrapper,RuntimeException>