Package org.apache.drill.exec.physical.base

Class AbstractPhysicalVisitor<T,X,E extends Throwable>

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<T,X,E>

All Implemented Interfaces:

PhysicalVisitor<T,X,E>

Direct Known Subclasses:

AbstractOpWrapperVisitor, ExchangeRemoverMaterializer, Fragment.BufferedOpFinder, IteratorValidatorInjector, MakeFragmentsVisitor, Materializer, OperatorIdVisitor, RuntimeFilterRouter.RuntimeFilterParallelismCollector, SimpleParallelizer.CountRequiredFragments, ThrottledResourceManager.QueuedResourceAllocator.BufferedOpFinder, TraceInjector

public abstract class AbstractPhysicalVisitor<T,X,E extends Throwable>
extends Object
implements PhysicalVisitor<T,X,E>

Field Summary

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

logger

Constructor Summary

Constructors

Constructor	Description
AbstractPhysicalVisitor()

Method Summary

Modifier and Type	Method	Description
T	visitBroadcastSender(BroadcastSender op, X value)
T	visitChildren(PhysicalOperator op, X value)
T	visitExchange(Exchange exchange, X value)
T	visitFilter(Filter filter, X value)
T	visitFlatten(FlattenPOP flatten, X value)
T	visitGroupScan(GroupScan groupScan, X value)
T	visitHashAggregate(HashAggregate agg, X value)
T	visitHashPartitionSender(HashPartitionSender op, X value)
T	visitHashPartitionSender(HashToRandomExchange op, X value)
T	visitIteratorValidator(IteratorValidator op, X value)
T	visitLateralJoin(LateralJoinPOP lateralJoinPOP, X value)
T	visitLimit(Limit limit, X value)
T	visitMergingReceiver(MergingReceiverPOP op, X value)
T	visitOp(PhysicalOperator op, X value)
T	visitOrderedPartitionSender(OrderedPartitionSender op, X value)
T	visitProducerConsumer(ProducerConsumer op, X value)
T	visitProject(Project project, X value)
T	visitRangePartitionSender(RangePartitionSender op, X value)
T	visitReceiver(Receiver receiver, X value)
T	visitRowKeyJoin(RowKeyJoinPOP join, X value)
T	visitScreen(Screen op, X value)
T	visitSender(Sender sender, X value)
T	visitSetOp(SetOp setOp, X value)
T	visitSingleSender(SingleSender op, X value)
T	visitSort(Sort sort, X value)
T	visitStatisticsAggregate(StatisticsAggregate agg, X value)
T	visitStatisticsMerge(StatisticsMerge agg, X value)
T	visitStore(Store store, X value)
T	visitStreamingAggregate(StreamingAggregate agg, X value)
T	visitSubScan(SubScan subScan, X value)
T	visitTableModify(TableModify op, X value)
T	visitTrace(Trace trace, X value)
T	visitUnion(UnionAll union, X value)
T	visitUnnest(UnnestPOP unnest, X value)
T	visitUnorderedReceiver(UnorderedReceiver op, X value)
T	visitUnpivot(UnpivotMaps op, X value)
T	visitValues(Values op, X value)
T	visitWindowFrame(WindowPOP windowFrame, X value)
T	visitWriter(Writer writer, X value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AbstractPhysicalVisitor

public AbstractPhysicalVisitor()

Method Details

visitExchange

public T visitExchange(Exchange exchange,
 X value)
                throws E

Specified by:

visitExchange in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitUnion

public T visitUnion(UnionAll union,
 X value)
             throws E

Specified by:

visitUnion in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitSetOp

public T visitSetOp(SetOp setOp,
 X value)
             throws E

Specified by:

visitSetOp in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitWriter

public T visitWriter(Writer writer,
 X value)
              throws E

Specified by:

visitWriter in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitFilter

public T visitFilter(Filter filter,
 X value)
              throws E

Specified by:

visitFilter in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitWindowFrame

public T visitWindowFrame(WindowPOP windowFrame,
 X value)
                   throws E

Specified by:

visitWindowFrame in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitProject

public T visitProject(Project project,
 X value)
               throws E

Specified by:

visitProject in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitTrace

public T visitTrace(Trace trace,
 X value)
             throws E

Specified by:

visitTrace in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitSort

public T visitSort(Sort sort,
 X value)
            throws E

Specified by:

visitSort in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitLimit

public T visitLimit(Limit limit,
 X value)
             throws E

Specified by:

visitLimit in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitStreamingAggregate

public T visitStreamingAggregate(StreamingAggregate agg,
 X value)
                          throws E

Specified by:

visitStreamingAggregate in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitStatisticsAggregate

public T visitStatisticsAggregate(StatisticsAggregate agg,
 X value)
                           throws E

Specified by:

visitStatisticsAggregate in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitStatisticsMerge

public T visitStatisticsMerge(StatisticsMerge agg,
 X value)
                       throws E

Specified by:

visitStatisticsMerge in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitHashAggregate

public T visitHashAggregate(HashAggregate agg,
 X value)
                     throws E

Specified by:

visitHashAggregate in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitSender

public T visitSender(Sender sender,
 X value)
              throws E

Specified by:

visitSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitFlatten

public T visitFlatten(FlattenPOP flatten,
 X value)
               throws E

Specified by:

visitFlatten in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitReceiver

public T visitReceiver(Receiver receiver,
 X value)
                throws E

Specified by:

visitReceiver in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitGroupScan

public T visitGroupScan(GroupScan groupScan,
 X value)
                 throws E

Specified by:

visitGroupScan in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitSubScan

public T visitSubScan(SubScan subScan,
 X value)
               throws E

Specified by:

visitSubScan in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitStore

public T visitStore(Store store,
 X value)
             throws E

Specified by:

visitStore in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitChildren

public T visitChildren(PhysicalOperator op,
 X value)
                throws E

Throws:

E

visitRowKeyJoin

public T visitRowKeyJoin(RowKeyJoinPOP join,
 X value)
                  throws E

Specified by:

visitRowKeyJoin in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitHashPartitionSender

public T visitHashPartitionSender(HashPartitionSender op,
 X value)
                           throws E

Specified by:

visitHashPartitionSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitOrderedPartitionSender

public T visitOrderedPartitionSender(OrderedPartitionSender op,
 X value)
                              throws E

Specified by:

visitOrderedPartitionSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitUnorderedReceiver

public T visitUnorderedReceiver(UnorderedReceiver op,
 X value)
                         throws E

Specified by:

visitUnorderedReceiver in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitMergingReceiver

public T visitMergingReceiver(MergingReceiverPOP op,
 X value)
                       throws E

Specified by:

visitMergingReceiver in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitHashPartitionSender

public T visitHashPartitionSender(HashToRandomExchange op,
 X value)
                           throws E

Specified by:

visitHashPartitionSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitRangePartitionSender

public T visitRangePartitionSender(RangePartitionSender op,
 X value)
                            throws E

Specified by:

visitRangePartitionSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitBroadcastSender

public T visitBroadcastSender(BroadcastSender op,
 X value)
                       throws E

Specified by:

visitBroadcastSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitScreen

public T visitScreen(Screen op,
 X value)
              throws E

Specified by:

visitScreen in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitSingleSender

public T visitSingleSender(SingleSender op,
 X value)
                    throws E

Specified by:

visitSingleSender in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitProducerConsumer

public T visitProducerConsumer(ProducerConsumer op,
 X value)
                        throws E

Specified by:

visitProducerConsumer in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitUnnest

public T visitUnnest(UnnestPOP unnest,
 X value)
              throws E

Specified by:

visitUnnest in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitLateralJoin

public T visitLateralJoin(LateralJoinPOP lateralJoinPOP,
 X value)
                   throws E

Specified by:

visitLateralJoin in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitIteratorValidator

public T visitIteratorValidator(IteratorValidator op,
 X value)
                         throws E

Specified by:

visitIteratorValidator in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitValues

public T visitValues(Values op,
 X value)
              throws E

Specified by:

visitValues in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitUnpivot

public T visitUnpivot(UnpivotMaps op,
 X value)
               throws E

Specified by:

visitUnpivot in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitTableModify

public T visitTableModify(TableModify op,
 X value)
                   throws E

Specified by:

visitTableModify in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E

visitOp

public T visitOp(PhysicalOperator op,
 X value)
          throws E

Specified by:

visitOp in interface PhysicalVisitor<T,X,E extends Throwable>

Throws:

E