public class WorkloadManager extends TezSessionPoolSession.AbstractTriggerValidator implements TezSessionPoolSession.Manager, WorkloadManagerMxBean
Modifier and Type | Class and Description |
---|---|
static class |
WorkloadManager.NoPoolMappingException |
Modifier and Type | Field and Description |
---|---|
protected Thread |
wmThread
The master thread the processes the events from EventState.
|
Modifier and Type | Method and Description |
---|---|
void |
closeAndReopenExpiredSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) |
static WorkloadManager |
create(String yarnQueue,
HiveConf conf,
WMFullResourcePlan plan)
Called once, when HS2 initializes.
|
protected WmTezSession |
createSessionObject(String sessionId,
HiveConf conf) |
void |
destroy(TezSessionState session) |
protected HiveConf |
getConf() |
org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker |
getExpirationTracker() |
static WorkloadManager |
getInstance() |
WmTezSession |
getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf) |
WmTezSession |
getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf,
WmContext wmContext) |
List<String> |
getWmStateDescription() |
void |
notifyInitializationCompleted(org.apache.hadoop.hive.ql.exec.tez.WorkloadManager.SessionInitContext initCtx) |
void |
notifyOfClusterStateChange() |
void |
notifyOfInconsistentAllocation(WmTezSession session) |
void |
registerOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
Called by TezSessionPoolSession when opened.
|
TezSessionState |
reopen(TezSessionState session) |
void |
returnAfterUse(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) |
void |
start() |
void |
stop() |
void |
unregisterOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
Called by TezSessionPoolSession when closed.
|
com.google.common.util.concurrent.ListenableFuture<Boolean> |
updateResourcePlanAsync(WMFullResourcePlan plan) |
protected final Thread wmThread
public static WorkloadManager getInstance()
public static WorkloadManager create(String yarnQueue, HiveConf conf, WMFullResourcePlan plan) throws ExecutionException, InterruptedException
public com.google.common.util.concurrent.ListenableFuture<Boolean> updateResourcePlanAsync(WMFullResourcePlan plan)
public WmTezSession getSession(TezSessionState session, UserPoolMapping.MappingInput input, HiveConf conf) throws Exception
Exception
public WmTezSession getSession(TezSessionState session, UserPoolMapping.MappingInput input, HiveConf conf, WmContext wmContext) throws Exception
Exception
public void destroy(TezSessionState session) throws Exception
destroy
in interface TezSessionPoolSession.Manager
Exception
public void returnAfterUse(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) throws Exception
returnAfterUse
in interface TezSessionPoolSession.Manager
Exception
public void notifyOfInconsistentAllocation(WmTezSession session)
public void notifyOfClusterStateChange()
public List<String> getWmStateDescription()
getWmStateDescription
in interface WorkloadManagerMxBean
public void notifyInitializationCompleted(org.apache.hadoop.hive.ql.exec.tez.WorkloadManager.SessionInitContext initCtx)
public TezSessionState reopen(TezSessionState session) throws Exception
reopen
in interface TezSessionPoolSession.Manager
Exception
public void closeAndReopenExpiredSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session) throws Exception
Exception
protected WmTezSession createSessionObject(String sessionId, HiveConf conf)
public void registerOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
registerOpenSession
in interface TezSessionPoolSession.Manager
public void unregisterOpenSession(org.apache.hadoop.hive.ql.exec.tez.TezSessionPoolSession session)
unregisterOpenSession
in interface TezSessionPoolSession.Manager
public org.apache.hadoop.hive.ql.exec.tez.SessionExpirationTracker getExpirationTracker()
protected final HiveConf getConf()
Copyright © 2022 The Apache Software Foundation. All rights reserved.