Package org.apache.drill.exec.planner.fragment

Class MemoryCalculator

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<Void,Wrapper,RuntimeException>

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

org.apache.drill.exec.planner.fragment.MemoryCalculator

All Implemented Interfaces:

PhysicalVisitor<Void,Wrapper,RuntimeException>

public class MemoryCalculator
extends AbstractOpWrapperVisitor<Void,RuntimeException>

A visitor to compute memory requirements for each operator in a minor fragment. This visitor will be called for each major fragment. It traverses the physical operators in that major fragment and computes the memory for each operator per each minor fragment. The minor fragment memory resources are further grouped into per Drillbit resource requirements.

Constructor Summary

Constructors

Constructor	Description
MemoryCalculator(PlanningSet planningSet, QueryContext context)

Method Summary

Modifier and Type	Method	Description
List<org.apache.commons.lang3.tuple.Pair<PhysicalOperator,Long>>	getBufferedOperators(CoordinationProtos.DrillbitEndpoint endpoint)
Void	visitOp(PhysicalOperator op, Wrapper fragment)
Void	visitReceivingExchange(Exchange exchange, Wrapper fragment)
Void	visitSendingExchange(Exchange exchange, Wrapper fragment)

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, visitGroupScan, visitHashAggregate, visitHashPartitionSender, visitHashPartitionSender, visitIteratorValidator, visitLateralJoin, visitLimit, visitMergingReceiver, visitOrderedPartitionSender, visitProducerConsumer, visitProject, visitRangePartitionSender, visitReceiver, visitRowKeyJoin, visitScreen, visitSender, visitSetOp, visitSingleSender, visitSort, visitStatisticsAggregate, visitStatisticsMerge, visitStore, visitStreamingAggregate, visitSubScan, visitTableModify, 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 Details

MemoryCalculator

public MemoryCalculator(PlanningSet planningSet,
 QueryContext context)

Method Details

visitSendingExchange

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

Overrides:

visitSendingExchange in class AbstractOpWrapperVisitor<Void,RuntimeException>

Throws:

RuntimeException

visitReceivingExchange

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

Overrides:

visitReceivingExchange in class AbstractOpWrapperVisitor<Void,RuntimeException>

Throws:

RuntimeException

getBufferedOperators

public List<org.apache.commons.lang3.tuple.Pair<PhysicalOperator,Long>> getBufferedOperators(CoordinationProtos.DrillbitEndpoint endpoint)

visitOp

public Void visitOp(PhysicalOperator op,
 Wrapper fragment)

Specified by:

visitOp in interface PhysicalVisitor<Void,Wrapper,RuntimeException>

Overrides:

visitOp in class AbstractPhysicalVisitor<Void,Wrapper,RuntimeException>