Package org.apache.drill.exec.work.foreman.rm

Class ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder

java.lang.Object

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

org.apache.drill.exec.work.foreman.rm.ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder

All Implemented Interfaces:

PhysicalVisitor<Void,List<PhysicalOperator>,RuntimeException>

Enclosing class:

ThrottledResourceManager.QueuedResourceAllocator

protected static class ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder
extends AbstractPhysicalVisitor<Void,List<PhysicalOperator>,RuntimeException>

Searches a fragment operator tree to find buffered within that fragment.

Field Summary

Fields inherited from interface org.apache.drill.exec.physical.base.PhysicalVisitor

logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BufferedOpFinder()

Method Summary

Modifier and Type	Method	Description
Void	visitOp(PhysicalOperator op, List<PhysicalOperator> value)

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

visitBroadcastSender, visitChildren, visitExchange, 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

BufferedOpFinder

protected BufferedOpFinder()

Method Details

visitOp

public Void visitOp(PhysicalOperator op,
 List<PhysicalOperator> value)
             throws RuntimeException

Specified by:

visitOp in interface PhysicalVisitor<Void,List<PhysicalOperator>,RuntimeException>

Overrides:

visitOp in class AbstractPhysicalVisitor<Void,List<PhysicalOperator>,RuntimeException>

Throws:

RuntimeException