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 and Description
AbstractPhysicalVisitor()

Method Summary

Modifier and Type	Method and 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	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	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 Detail

AbstractPhysicalVisitor

public AbstractPhysicalVisitor()

Method Detail

visitExchange

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

Specified by:

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

Throws:

E extends Throwable

visitUnion

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

Specified by:

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

Throws:

E extends Throwable

visitWriter

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

Specified by:

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

Throws:

E extends Throwable

visitFilter

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

Specified by:

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

Throws:

E extends Throwable

visitWindowFrame

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

Specified by:

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

Throws:

E extends Throwable

visitProject

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

Specified by:

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

Throws:

E extends Throwable

visitTrace

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

Specified by:

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

Throws:

E extends Throwable

visitSort

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

Specified by:

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

Throws:

E extends Throwable

visitLimit

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

Specified by:

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

Throws:

E extends Throwable

visitStreamingAggregate

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

Specified by:

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

Throws:

E extends Throwable

visitStatisticsAggregate

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

Specified by:

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

Throws:

E extends Throwable

visitStatisticsMerge

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

Specified by:

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

Throws:

E extends Throwable

visitHashAggregate

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

Specified by:

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

Throws:

E extends Throwable

visitSender

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

Specified by:

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

Throws:

E extends Throwable

visitFlatten

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

Specified by:

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

Throws:

E extends Throwable

visitReceiver

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

Specified by:

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

Throws:

E extends Throwable

visitGroupScan

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

Specified by:

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

Throws:

E extends Throwable

visitSubScan

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

Specified by:

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

Throws:

E extends Throwable

visitStore

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

Specified by:

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

Throws:

E extends Throwable

visitChildren

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

Throws:

E extends Throwable

visitRowKeyJoin

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

Specified by:

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

Throws:

E extends Throwable

visitHashPartitionSender

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

Specified by:

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

Throws:

E extends Throwable

visitOrderedPartitionSender

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

Specified by:

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

Throws:

E extends Throwable

visitUnorderedReceiver

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

Specified by:

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

Throws:

E extends Throwable

visitMergingReceiver

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

Specified by:

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

Throws:

E extends Throwable

visitHashPartitionSender

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

Specified by:

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

Throws:

E extends Throwable

visitRangePartitionSender

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

Specified by:

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

Throws:

E extends Throwable

visitBroadcastSender

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

Specified by:

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

Throws:

E extends Throwable

visitScreen

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

Specified by:

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

Throws:

E extends Throwable

visitSingleSender

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

Specified by:

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

Throws:

E extends Throwable

visitProducerConsumer

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

Specified by:

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

Throws:

E extends Throwable

visitUnnest

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

Specified by:

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

Throws:

E extends Throwable

visitLateralJoin

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

Specified by:

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

Throws:

E extends Throwable

visitIteratorValidator

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

Specified by:

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

Throws:

E extends Throwable

visitValues

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

Specified by:

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

Throws:

E extends Throwable

visitUnpivot

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

Specified by:

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

Throws:

E extends Throwable

visitOp

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

Specified by:

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

Throws:

E extends Throwable