Uses of Class
org.apache.drill.exec.planner.fragment.Fragment

Packages that use Fragment

Package	Description
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.planner.fragment.contrib

Uses of Fragment in org.apache.drill.exec.planner.fragment

Methods in org.apache.drill.exec.planner.fragment that return Fragment

Modifier and Type	Method and Description
Fragment	MakeFragmentsVisitor.getNextFragment()
Fragment	Materializer.IndexedFragmentNode.getNode()
Fragment	Wrapper.getNode()
Fragment	Fragment.ExchangeFragmentPair.getNode()
Fragment	MakeFragmentsVisitor.visitExchange(Exchange exchange, Fragment receivingFragment)
Fragment	MakeFragmentsVisitor.visitOp(PhysicalOperator op, Fragment value)

Methods in org.apache.drill.exec.planner.fragment with parameters of type Fragment

Modifier and Type	Method and Description
void	Fragment.addReceiveExchange(Exchange e, Fragment fragment)
void	Fragment.addSendExchange(Exchange e, Fragment sendingToFragment)
Wrapper	PlanningSet.findRootWrapper(Fragment rootFragment) find the root Wrapper which contains the root Fragment and hold the root wrapper
QueryWorkUnit	QueryParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) This is the only function exposed to the consumer of this parallelizer (currently Foreman) to parallelize the plan.
QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) The starting function for the whole parallelization and memory computation logic.
protected QueryWorkUnit	SimpleParallelizer.generateWorkUnit(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Fragment rootNode, PlanningSet planningSet, UserSession session, BitControl.QueryContextInformation queryContextInfo)
Wrapper	PlanningSet.get(Fragment node)
List<QueryWorkUnit>	SimpleParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently
void	SimpleParallelizer.initFragmentWrappers(Fragment rootFragment, PlanningSet planningSet)
PlanningSet	SimpleParallelizer.prepareFragmentTree(Fragment rootFragment)
T	FragmentVisitor.visit(Fragment n, V extra)
Fragment	MakeFragmentsVisitor.visitExchange(Exchange exchange, Fragment receivingFragment)
Fragment	MakeFragmentsVisitor.visitOp(PhysicalOperator op, Fragment value)

Constructors in org.apache.drill.exec.planner.fragment with parameters of type Fragment

Constructor and Description
ExchangeFragmentPair(Exchange exchange, Fragment fragXchgTo)
Wrapper(Fragment node, int majorFragmentId)

Uses of Fragment in org.apache.drill.exec.planner.fragment.contrib

Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type Fragment

Modifier and Type

Method and Description

List<QueryWorkUnit>

SplittingParallelizer.getSplitFragments(OptionList options, CoordinationProtos.DrillbitEndpoint foremanNode, UserBitShared.QueryId queryId, Collection<CoordinationProtos.DrillbitEndpoint> activeEndpoints, PhysicalPlanReader reader, Fragment rootFragment, UserSession session, BitControl.QueryContextInformation queryContextInfo) Create multiple physical plans from original query planning, it will allow execute them eventually independently