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 QueryWorkUnitSimpleParallelizer.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 QueryWorkUnitSimpleParallelizer.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 QueryWorkUnitThrottledResourceManager.QueuedResourceAllocator.workMethods in org.apache.drill.exec.work.foreman.rm with parameters of type QueryWorkUnitModifier and TypeMethodDescriptionvoidDefaultResourceManager.DefaultResourceAllocator.visitPhysicalPlan(QueryWorkUnit work) voidQueryResourceAllocator.visitPhysicalPlan(QueryWorkUnit work) Provide the manager with the physical plan and node assignments for the query to be run.voidThrottledResourceManager.QueuedResourceAllocator.visitPhysicalPlan(QueryWorkUnit work)