public static class DefaultResourceManager.DefaultResourceAllocator extends Object implements QueryResourceAllocator
Modifier | Constructor and Description |
---|---|
protected |
DefaultResourceAllocator(QueryContext queryContext) |
Modifier and Type | Method and Description |
---|---|
QueryContext |
getQueryContext() |
void |
visitAbstractPlan(PhysicalPlan plan)
Make any needed adjustments to the query plan before parallelization.
|
void |
visitPhysicalPlan(QueryWorkUnit work)
Provide the manager with the physical plan and node assignments
for the query to be run.
|
protected DefaultResourceAllocator(QueryContext queryContext)
public void visitAbstractPlan(PhysicalPlan plan)
QueryResourceAllocator
visitAbstractPlan
in interface QueryResourceAllocator
plan
- physical planpublic void visitPhysicalPlan(QueryWorkUnit work)
QueryResourceAllocator
visitPhysicalPlan
in interface QueryResourceAllocator
work
- query work unitpublic QueryContext getQueryContext()
Copyright © 1970 The Apache Software Foundation. All rights reserved.