org.apache.drill.exec.physical.impl

Class TraceInjector

java.lang.Object

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

org.apache.drill.exec.physical.impl.TraceInjector

All Implemented Interfaces:

PhysicalVisitor<PhysicalOperator,FragmentContext,ExecutionSetupException>

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

Constructor Summary

Constructors

Constructor and Description
TraceInjector()

Method Summary

Modifier and Type	Method and Description
static PhysicalOperator	getExec(FragmentContext context, FragmentRoot root)
PhysicalOperator	visitOp(PhysicalOperator op, FragmentContext context) Traverse the physical plan and inject the trace 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

TraceInjector

public TraceInjector()

Method Detail

getExec

public static PhysicalOperator getExec(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 trace 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 trace operator will be injected

context - Fragment context

Returns:

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

Throws:

ExecutionSetupException