Uses of Class
org.apache.drill.exec.planner.fragment.Fragment
Packages that use Fragment
Package
Description
-
Uses of Fragment in org.apache.drill.exec.planner.fragment
Methods in org.apache.drill.exec.planner.fragment that return FragmentModifier and TypeMethodDescriptionMakeFragmentsVisitor.getNextFragment()
Fragment.ExchangeFragmentPair.getNode()
Materializer.IndexedFragmentNode.getNode()
Wrapper.getNode()
MakeFragmentsVisitor.visitExchange
(Exchange exchange, Fragment receivingFragment) MakeFragmentsVisitor.visitOp
(PhysicalOperator op, Fragment value) Methods in org.apache.drill.exec.planner.fragment with parameters of type FragmentModifier and TypeMethodDescriptionvoid
Fragment.addReceiveExchange
(Exchange e, Fragment fragment) void
Fragment.addSendExchange
(Exchange e, Fragment sendingToFragment) PlanningSet.findRootWrapper
(Fragment rootFragment) find the root Wrapper which contains the root Fragment and hold the root wrapperQueryParallelizer.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.final 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) 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 independentlyvoid
SimpleParallelizer.initFragmentWrappers
(Fragment rootFragment, PlanningSet planningSet) SimpleParallelizer.prepareFragmentTree
(Fragment rootFragment) MakeFragmentsVisitor.visitExchange
(Exchange exchange, Fragment receivingFragment) MakeFragmentsVisitor.visitOp
(PhysicalOperator op, Fragment value) Constructors in org.apache.drill.exec.planner.fragment with parameters of type Fragment -
Uses of Fragment in org.apache.drill.exec.planner.fragment.contrib
Methods in org.apache.drill.exec.planner.fragment.contrib with parameters of type FragmentModifier and TypeMethodDescriptionSplittingParallelizer.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