Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec.tez |
Modifier and Type | Method and Description |
---|---|
protected WmTezSession |
WorkloadManager.createSessionObject(String sessionId,
HiveConf conf) |
WmTezSession |
WorkloadManager.getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf) |
WmTezSession |
WorkloadManager.getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf,
WmContext wmContext) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<WmTezSession> |
WmTezSession.waitForAmRegistryAsync(int timeoutMs,
ScheduledExecutorService timeoutPool) |
Modifier and Type | Method and Description |
---|---|
void |
WmEvent.endEvent(WmTezSession sessionState) |
void |
WorkloadManager.notifyOfInconsistentAllocation(WmTezSession session) |
void |
GuaranteedTasksAllocator.updateSessionAsync(WmTezSession session) |
Modifier and Type | Method and Description |
---|---|
void |
KillMoveTriggerActionHandler.applyAction(Map<WmTezSession,Trigger> queriesViolated) |
int |
GuaranteedTasksAllocator.updateSessionsAsync(Double totalMaxAlloc,
List<WmTezSession> sessionsToUpdate) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.