public static class DefaultResourceManager.DefaultQueryResourceManager extends DefaultResourceManager.DefaultResourceAllocator implements QueryResourceManager
Constructor and Description |
---|
DefaultQueryResourceManager(DefaultResourceManager rm,
Foreman foreman) |
Modifier and Type | Method and Description |
---|---|
void |
admit()
Admit the query into the cluster.
|
void |
exit()
Mark the query as completing, giving up its slot in the
cluster.
|
QueryParallelizer |
getParallelizer(boolean memoryPlanning)
Create a parallelizer to parallelize each major fragment of the query into
many minor fragments.
|
boolean |
hasQueue()
Hint that this resource manager queues.
|
String |
queueName()
Returns the name of the queue (if any) on which the query was
placed.
|
void |
setCost(double cost)
For some cases the foreman does not have a full plan, just a cost.
|
getQueryContext, visitAbstractPlan, visitPhysicalPlan
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
visitAbstractPlan, visitPhysicalPlan
public DefaultQueryResourceManager(DefaultResourceManager rm, Foreman foreman)
public void setCost(double cost)
QueryResourceManager
setCost
in interface QueryResourceManager
public QueryParallelizer getParallelizer(boolean memoryPlanning)
QueryResourceManager
getParallelizer
in interface QueryResourceManager
memoryPlanning
- memory planning needs to be done during parallelizationpublic void admit()
QueryResourceManager
admit
in interface QueryResourceManager
public void exit()
QueryResourceManager
exit
in interface QueryResourceManager
public boolean hasQueue()
QueryResourceManager
hasQueue
in interface QueryResourceManager
public String queueName()
QueryResourceManager
queueName
in interface QueryResourceManager
Copyright © 1970 The Apache Software Foundation. All rights reserved.