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 and Description
protected	BufferedOpFinder()

Method Summary

Modifier and Type	Method and 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, visitSingleSender, visitSort, visitStatisticsAggregate, visitStatisticsMerge, visitStore, 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

BufferedOpFinder

protected BufferedOpFinder()

Method Detail

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