org.apache.drill.exec.planner.fragment

Class MakeFragmentsVisitor

java.lang.Object

org.apache.drill.exec.physical.base.AbstractPhysicalVisitor<Fragment,Fragment,ForemanSetupException>

org.apache.drill.exec.planner.fragment.MakeFragmentsVisitor

All Implemented Interfaces:

PhysicalVisitor<Fragment,Fragment,ForemanSetupException>

public class MakeFragmentsVisitor
extends AbstractPhysicalVisitor<Fragment,Fragment,ForemanSetupException>

Responsible for breaking a plan into its constituent Fragments.

Field Summary

Fields

Modifier and Type	Field and Description
static MakeFragmentsVisitor	INSTANCE

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

logger

Method Summary

Modifier and Type	Method and Description
Fragment	getNextFragment()
Fragment	visitExchange(Exchange exchange, Fragment receivingFragment)
Fragment	visitOp(PhysicalOperator op, Fragment value)

Methods inherited from class org.apache.drill.exec.physical.base.AbstractPhysicalVisitor

visitBroadcastSender, visitChildren, 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

Field Detail

INSTANCE

public static final MakeFragmentsVisitor INSTANCE

Method Detail

visitExchange

public Fragment visitExchange(Exchange exchange,
                              Fragment receivingFragment)
                       throws ForemanSetupException

Specified by:

visitExchange in interface PhysicalVisitor<Fragment,Fragment,ForemanSetupException>

Overrides:

visitExchange in class AbstractPhysicalVisitor<Fragment,Fragment,ForemanSetupException>

Throws:

ForemanSetupException

visitOp

public Fragment visitOp(PhysicalOperator op,
                        Fragment value)
                 throws ForemanSetupException

Specified by:

visitOp in interface PhysicalVisitor<Fragment,Fragment,ForemanSetupException>

Overrides:

visitOp in class AbstractPhysicalVisitor<Fragment,Fragment,ForemanSetupException>

Throws:

ForemanSetupException

getNextFragment

public Fragment getNextFragment()