org.apache.drill.exec.physical.base

Interface PhysicalVisitor<RETURN,EXTRA,EXCEP extends Throwable>

Type Parameters:

RETURN - The class associated with the return of each visit method.

EXTRA - The class object associated with additional data required for a particular operator modification.

EXCEP - An optional exception class that can be thrown when a portion of a modification or traversal fails. Must extend Throwable. In the case where the visitor does not throw any caught exception, this can be set as RuntimeException.

All Known Implementing Classes:

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

public interface PhysicalVisitor<RETURN,EXTRA,EXCEP extends Throwable>

Visitor class designed to traversal of a operator tree. Basis for a number of operator manipulations including fragmentation and materialization.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	logger

Method Summary

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

Field Detail

logger

static final org.slf4j.Logger logger

Method Detail

visitExchange

RETURN visitExchange(Exchange exchange,
                     EXTRA value)
              throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitGroupScan

RETURN visitGroupScan(GroupScan groupScan,
                      EXTRA value)
               throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitSubScan

RETURN visitSubScan(SubScan subScan,
                    EXTRA value)
             throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitStore

RETURN visitStore(Store store,
                  EXTRA value)
           throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitFilter

RETURN visitFilter(Filter filter,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitUnion

RETURN visitUnion(UnionAll union,
                  EXTRA value)
           throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitProject

RETURN visitProject(Project project,
                    EXTRA value)
             throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitTrace

RETURN visitTrace(Trace trace,
                  EXTRA value)
           throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitSort

RETURN visitSort(Sort sort,
                 EXTRA value)
          throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitLimit

RETURN visitLimit(Limit limit,
                  EXTRA value)
           throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitFlatten

RETURN visitFlatten(FlattenPOP flatten,
                    EXTRA value)
             throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitSender

RETURN visitSender(Sender sender,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitRowKeyJoin

RETURN visitRowKeyJoin(RowKeyJoinPOP join,
                       EXTRA value)
                throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitReceiver

RETURN visitReceiver(Receiver receiver,
                     EXTRA value)
              throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitStreamingAggregate

RETURN visitStreamingAggregate(StreamingAggregate agg,
                               EXTRA value)
                        throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitStatisticsAggregate

RETURN visitStatisticsAggregate(StatisticsAggregate agg,
                                EXTRA value)
                         throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitStatisticsMerge

RETURN visitStatisticsMerge(StatisticsMerge agg,
                            EXTRA value)
                     throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitHashAggregate

RETURN visitHashAggregate(HashAggregate agg,
                          EXTRA value)
                   throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitWriter

RETURN visitWriter(Writer op,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitUnpivot

RETURN visitUnpivot(UnpivotMaps op,
                    EXTRA value)
             throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitValues

RETURN visitValues(Values op,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitOp

RETURN visitOp(PhysicalOperator op,
               EXTRA value)
        throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitHashPartitionSender

RETURN visitHashPartitionSender(HashPartitionSender op,
                                EXTRA value)
                         throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitOrderedPartitionSender

RETURN visitOrderedPartitionSender(OrderedPartitionSender op,
                                   EXTRA value)
                            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitUnorderedReceiver

RETURN visitUnorderedReceiver(UnorderedReceiver op,
                              EXTRA value)
                       throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitMergingReceiver

RETURN visitMergingReceiver(MergingReceiverPOP op,
                            EXTRA value)
                     throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitHashPartitionSender

RETURN visitHashPartitionSender(HashToRandomExchange op,
                                EXTRA value)
                         throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitRangePartitionSender

RETURN visitRangePartitionSender(RangePartitionSender op,
                                 EXTRA value)
                          throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitBroadcastSender

RETURN visitBroadcastSender(BroadcastSender op,
                            EXTRA value)
                     throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitScreen

RETURN visitScreen(Screen op,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitSingleSender

RETURN visitSingleSender(SingleSender op,
                         EXTRA value)
                  throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitWindowFrame

RETURN visitWindowFrame(WindowPOP op,
                        EXTRA value)
                 throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitProducerConsumer

RETURN visitProducerConsumer(ProducerConsumer op,
                             EXTRA value)
                      throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitUnnest

RETURN visitUnnest(UnnestPOP unnest,
                   EXTRA value)
            throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitLateralJoin

RETURN visitLateralJoin(LateralJoinPOP lateralJoinPOP,
                        EXTRA value)
                 throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable

visitIteratorValidator

RETURN visitIteratorValidator(IteratorValidator op,
                              EXTRA value)
                       throws EXCEP extends Throwable

Throws:

EXCEP extends Throwable