org.apache.drill.exec.physical.impl.validate

Class IteratorValidatorInjector

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

org.apache.drill.exec.physical.impl.validate.IteratorValidatorInjector

All Implemented Interfaces:

PhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

public class IteratorValidatorInjector
extends AbstractPhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

Constructor Summary

Constructors

Constructor and Description
IteratorValidatorInjector()
IteratorValidatorInjector(boolean repeatablePipeline)

Method Summary

Modifier and Type	Method and Description
static FragmentRoot	rewritePlanWithIteratorValidator(FragmentContext context, FragmentRoot root)
PhysicalOperator	visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the IteratorValidator operator after every operator.

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

IteratorValidatorInjector

public IteratorValidatorInjector()

IteratorValidatorInjector

public IteratorValidatorInjector(boolean repeatablePipeline)

Method Detail

rewritePlanWithIteratorValidator

public static FragmentRoot rewritePlanWithIteratorValidator(FragmentContext context,
                                                            FragmentRoot root)
                                                     throws ExecutionSetupException

Throws:

ExecutionSetupException

visitOp

public PhysicalOperator visitOp(PhysicalOperator op,
                                FragmentContext context)
                         throws ExecutionSetupException

Traverse the physical plan and inject the IteratorValidator operator after every operator.

Specified by:

visitOp in interface PhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

Overrides:

visitOp in class AbstractPhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

Parameters:

op - Physical operator under which the IteratorValidator operator will be injected

context - Fragment context

Returns:

same physical operator as passed in, but its child will be a IteratorValidator operator whose child will be the original child of this operator

Throws:

ExecutionSetupException