Uses of Class
org.apache.drill.exec.work.QueryWorkUnit

Packages that use QueryWorkUnit

Package	Description
org.apache.drill.exec.planner.fragment
org.apache.drill.exec.planner.fragment.contrib
org.apache.drill.exec.work.filter
org.apache.drill.exec.work.foreman.rm	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 QueryWorkUnit

Modifier and Type	Method and Description
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)

Methods in org.apache.drill.exec.planner.fragment that return types with arguments of type QueryWorkUnit

Modifier and Type

Method and Description

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

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 QueryWorkUnit

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

Uses of QueryWorkUnit in org.apache.drill.exec.work.filter

Constructors in org.apache.drill.exec.work.filter with parameters of type QueryWorkUnit

Constructor and Description
RuntimeFilterRouter(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 QueryWorkUnit

Modifier and Type	Field and Description
protected QueryWorkUnit	ThrottledResourceManager.QueuedResourceAllocator.work

Methods in org.apache.drill.exec.work.foreman.rm with parameters of type QueryWorkUnit

Modifier and Type	Method and Description
void	ThrottledResourceManager.QueuedResourceAllocator.visitPhysicalPlan(QueryWorkUnit work)
void	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.