org.apache.drill.exec.work.filter

Class RuntimeFilterRouter.RuntimeFilterParallelismCollector

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<Void,org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder,RuntimeException>

org.apache.drill.exec.work.filter.RuntimeFilterRouter.RuntimeFilterParallelismCollector

All Implemented Interfaces:

PhysicalVisitor<Void,org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder,RuntimeException>

Enclosing class:

RuntimeFilterRouter

protected class RuntimeFilterRouter.RuntimeFilterParallelismCollector
extends AbstractPhysicalVisitor<Void,org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder,RuntimeException>

Collect the runtime filter parallelism related information such as join node major/minor fragment id , probe side scan node's major/minor fragment id, probe side node's endpoints.

Field Summary

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

logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RuntimeFilterParallelismCollector()

Method Summary

Modifier and Type	Method and Description
List<org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder>	getHolders()
Void	visitOp(PhysicalOperator op, org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder holder)

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

RuntimeFilterParallelismCollector

protected RuntimeFilterParallelismCollector()

Method Detail

visitOp

public Void visitOp(PhysicalOperator op,
                    org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder holder)
             throws RuntimeException

Specified by:

visitOp in interface PhysicalVisitor<Void,org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder,RuntimeException>

Overrides:

visitOp in class AbstractPhysicalVisitor<Void,org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder,RuntimeException>

Throws:

RuntimeException

getHolders

public List<org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder> getHolders()