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
-
Method Summary
Modifier and TypeMethodDescriptionList<org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder>
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, visitSetOp, visitSingleSender, visitSort, visitStatisticsAggregate, visitStatisticsMerge, visitStore, visitStreamingAggregate, visitSubScan, visitTableModify, visitTrace, visitUnion, visitUnnest, visitUnorderedReceiver, visitUnpivot, visitValues, visitWindowFrame, visitWriter
-
Constructor Details
-
RuntimeFilterParallelismCollector
protected RuntimeFilterParallelismCollector()
-
-
Method Details
-
visitOp
public Void visitOp(PhysicalOperator op, org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder holder) throws RuntimeException - Specified by:
visitOp
in interfacePhysicalVisitor<Void,
org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder, RuntimeException> - Overrides:
visitOp
in classAbstractPhysicalVisitor<Void,
org.apache.drill.exec.work.filter.RuntimeFilterRouter.RFHelperHolder, RuntimeException> - Throws:
RuntimeException
-
getHolders
-