Uses of Class
org.apache.drill.exec.work.QueryWorkUnit
Packages that use QueryWorkUnit
Package
Description
Provides resource management and queuing support for the Drill foreman.
-
Uses of QueryWorkUnit in org.apache.drill.exec.planner.fragment
Methods in org.apache.drill.exec.planner.fragment that return QueryWorkUnitModifier and TypeMethodDescriptionQueryParallelizer.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) Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type QueryWorkUnitModifier and TypeMethodDescriptionSimpleParallelizer.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 -
Uses of QueryWorkUnit in org.apache.drill.exec.planner.fragment.contrib
Methods in org.apache.drill.exec.planner.fragment.contrib that return types with arguments of type QueryWorkUnitModifier 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 -
Uses of QueryWorkUnit in org.apache.drill.exec.work.filter
Constructors in org.apache.drill.exec.work.filter with parameters of type QueryWorkUnitModifierConstructorDescriptionRuntimeFilterRouter
(QueryWorkUnit workUnit, DrillbitContext drillbitContext) This class maintains context for the runtime join push down's filter management. -
Uses of QueryWorkUnit in org.apache.drill.exec.work.foreman.rm
Fields in org.apache.drill.exec.work.foreman.rm declared as QueryWorkUnitModifier and TypeFieldDescriptionprotected QueryWorkUnit
ThrottledResourceManager.QueuedResourceAllocator.work
Methods in org.apache.drill.exec.work.foreman.rm with parameters of type QueryWorkUnitModifier and TypeMethodDescriptionvoid
DefaultResourceManager.DefaultResourceAllocator.visitPhysicalPlan
(QueryWorkUnit work) void
QueryResourceAllocator.visitPhysicalPlan
(QueryWorkUnit work) Provide the manager with the physical plan and node assignments for the query to be run.void
ThrottledResourceManager.QueuedResourceAllocator.visitPhysicalPlan
(QueryWorkUnit work)