Uses of Class
org.apache.drill.exec.work.QueryWorkUnit
Package
Description
Provides resource management and queuing support for the Drill foreman.
-
Uses of QueryWorkUnit in org.apache.drill.exec.planner.fragment
Modifier 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) Modifier 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
Modifier 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
ModifierConstructorDescriptionRuntimeFilterRouter
(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
Modifier and TypeFieldDescriptionprotected QueryWorkUnit
ThrottledResourceManager.QueuedResourceAllocator.work
Modifier 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)