Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec.tez | |
org.apache.hadoop.hive.ql.session | |
org.apache.hadoop.hive.ql.wm |
Modifier and Type | Class and Description |
---|---|
class |
WmTezSession |
Modifier and Type | Method and Description |
---|---|
TezSessionState |
TezSessionPoolManager.getSession(TezSessionState session,
HiveConf conf,
boolean doOpen,
boolean llap) |
static TezSessionState |
WorkloadManagerFederation.getSession(TezSessionState session,
HiveConf conf,
UserPoolMapping.MappingInput input,
boolean isUnmanagedLlapMode,
WmContext wmContext) |
TezSessionState |
TezSessionState.reopen() |
TezSessionState |
WorkloadManager.reopen(TezSessionState session) |
TezSessionState |
TezSessionPoolManager.reopen(TezSessionState sessionState)
Reopens the session that was found to not be running.
|
Modifier and Type | Method and Description |
---|---|
static void |
TezSessionPoolManager.closeIfNotDefault(TezSessionState tezSessionState,
boolean keepTmpDir) |
void |
WorkloadManager.destroy(TezSessionState session) |
void |
TezSessionPoolManager.destroy(TezSessionState tezSessionState)
This is called only in extreme cases where even our retry of submit fails.
|
TezSessionState |
TezSessionPoolManager.getSession(TezSessionState session,
HiveConf conf,
boolean doOpen,
boolean llap) |
static TezSessionState |
WorkloadManagerFederation.getSession(TezSessionState session,
HiveConf conf,
UserPoolMapping.MappingInput input,
boolean isUnmanagedLlapMode,
WmContext wmContext) |
WmTezSession |
WorkloadManager.getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf) |
WmTezSession |
WorkloadManager.getSession(TezSessionState session,
UserPoolMapping.MappingInput input,
HiveConf conf,
WmContext wmContext) |
TezSessionState |
WorkloadManager.reopen(TezSessionState session) |
TezSessionState |
TezSessionPoolManager.reopen(TezSessionState sessionState)
Reopens the session that was found to not be running.
|
Modifier and Type | Method and Description |
---|---|
void |
KillTriggerActionHandler.applyAction(Map<TezSessionState,Trigger> queriesViolated) |
Modifier and Type | Method and Description |
---|---|
TezSessionState |
SessionState.getTezSession() |
Modifier and Type | Method and Description |
---|---|
void |
SessionState.setTezSession(TezSessionState session)
Called from TezTask to attach a TezSession to use to the threadlocal.
|
Modifier and Type | Method and Description |
---|---|
List<TezSessionState> |
SessionTriggerProvider.getSessions() |
Modifier and Type | Method and Description |
---|---|
void |
SessionTriggerProvider.setSessions(List<TezSessionState> sessions) |
Constructor and Description |
---|
SessionTriggerProvider(List<TezSessionState> openSessions,
List<Trigger> triggers) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.