public class SessionState
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
SessionState.LogHelper
This class provides helper routines to emit informational and error
messages to the user and log4j files while obeying the current session's
verbosity levels.
|
static interface |
SessionState.ResourceHook
ResourceHook.
|
static class |
SessionState.ResourceType
ResourceType.
|
Modifier and Type | Field and Description |
---|---|
java.io.PrintStream |
childErr
Error output from any child process(es).
|
java.io.PrintStream |
childOut
Standard output from any child process(es).
|
protected HiveConf |
conf
current configuration.
|
java.io.PrintStream |
err |
protected HiveHistory |
hiveHist |
java.io.InputStream |
in
Streams to read/write from.
|
java.io.PrintStream |
info |
protected boolean |
isSilent
silent mode.
|
protected boolean |
isVerbose
verbose mode
|
java.io.PrintStream |
out |
protected java.io.File |
tmpOutputFile
Temporary file name used to store results of non-Hive commands (e.g., set, dfs)
and HiveServer.fetch*() function will read results from this file
|
Constructor and Description |
---|
SessionState(HiveConf conf) |
Modifier and Type | Method and Description |
---|---|
void |
add_builtin_resource(SessionState.ResourceType t,
java.lang.String value) |
java.lang.String |
add_resource(SessionState.ResourceType t,
java.lang.String value) |
java.lang.String |
add_resource(SessionState.ResourceType t,
java.lang.String value,
boolean convertToUnix) |
void |
addLocalMapRedErrors(java.lang.String id,
java.util.List<java.lang.String> localMapRedErrors) |
static boolean |
canDownloadResource(java.lang.String value)
Returns true if it is from any external File Systems except local
|
void |
close() |
void |
delete_resource(SessionState.ResourceType t) |
boolean |
delete_resource(SessionState.ResourceType t,
java.lang.String value) |
static SessionState.ResourceType |
find_resource_type(java.lang.String s) |
static SessionState |
get()
get the current session.
|
HiveAuthenticationProvider |
getAuthenticator() |
HiveAuthorizationProvider |
getAuthorizer() |
java.lang.String |
getCmd() |
java.lang.String |
getCommandType() |
HiveConf |
getConf() |
static SessionState.LogHelper |
getConsole()
initialize or retrieve console object for SessionState.
|
CreateTableAutomaticGrant |
getCreateTableGrants() |
java.lang.String |
getCurrentDatabase() |
HiveHistory |
getHiveHistory()
get hiveHitsory object which does structured logging.
|
HiveOperation |
getHiveOperation() |
java.util.Map<java.lang.String,java.lang.String> |
getHiveVariables() |
boolean |
getIsSilent() |
boolean |
getIsVerbose() |
java.util.List<MapRedStats> |
getLastMapRedStatsList() |
LineageState |
getLineageState()
Get the lineage state stored in this session.
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
getLocalMapRedErrors() |
java.util.Map<java.lang.String,java.lang.String> |
getOverriddenConfigurations() |
PerfLogger |
getPerfLogger(boolean resetPerfLogger) |
java.lang.String |
getQueryId() |
java.lang.String |
getSessionId() |
java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> |
getStackTraces() |
java.io.File |
getTmpOutputFile() |
java.util.Set<java.lang.String> |
list_resource(SessionState.ResourceType t,
java.util.List<java.lang.String> filter) |
static boolean |
registerJar(java.lang.String newJar) |
void |
setAuthenticator(HiveAuthenticationProvider authenticator) |
void |
setAuthorizer(HiveAuthorizationProvider authorizer) |
void |
setCmd(java.lang.String cmdString) |
void |
setCommandType(HiveOperation commandType) |
void |
setConf(HiveConf conf) |
void |
setCreateTableGrants(CreateTableAutomaticGrant createTableGrants) |
void |
setCurrentDatabase(java.lang.String currentDatabase) |
void |
setHiveVariables(java.util.Map<java.lang.String,java.lang.String> hiveVariables) |
void |
setIsSilent(boolean isSilent) |
void |
setIsVerbose(boolean isVerbose) |
void |
setLastMapRedStatsList(java.util.List<MapRedStats> lastMapRedStatsList) |
void |
setLocalMapRedErrors(java.util.Map<java.lang.String,java.util.List<java.lang.String>> localMapRedErrors) |
void |
setOverriddenConfigurations(java.util.Map<java.lang.String,java.lang.String> overriddenConfigurations) |
void |
setStackTraces(java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> stackTraces) |
void |
setTmpOutputFile(java.io.File f) |
static SessionState |
start(HiveConf conf)
start a new session and set it to current session.
|
static SessionState |
start(SessionState startSs)
set current session to existing session object if a thread is running
multiple sessions - it must call this method with the new session object
when switching from one session to another.
|
static boolean |
unregisterJar(java.lang.String jarsToUnregister) |
static java.lang.String |
validateFile(java.util.Set<java.lang.String> curFiles,
java.lang.String newFile) |
protected HiveConf conf
protected boolean isSilent
protected boolean isVerbose
protected HiveHistory hiveHist
public java.io.InputStream in
public java.io.PrintStream out
public java.io.PrintStream info
public java.io.PrintStream err
public java.io.PrintStream childOut
public java.io.PrintStream childErr
protected java.io.File tmpOutputFile
public SessionState(HiveConf conf)
public LineageState getLineageState()
public HiveConf getConf()
public void setConf(HiveConf conf)
public java.io.File getTmpOutputFile()
public void setTmpOutputFile(java.io.File f)
public boolean getIsSilent()
public void setIsSilent(boolean isSilent)
public boolean getIsVerbose()
public void setIsVerbose(boolean isVerbose)
public void setCmd(java.lang.String cmdString)
public java.lang.String getCmd()
public java.lang.String getQueryId()
public java.util.Map<java.lang.String,java.lang.String> getHiveVariables()
public void setHiveVariables(java.util.Map<java.lang.String,java.lang.String> hiveVariables)
public java.lang.String getSessionId()
public static SessionState start(HiveConf conf)
public static SessionState start(SessionState startSs)
HiveException
public static SessionState get()
public HiveHistory getHiveHistory()
public static SessionState.LogHelper getConsole()
public static java.lang.String validateFile(java.util.Set<java.lang.String> curFiles, java.lang.String newFile)
public static boolean registerJar(java.lang.String newJar)
public static boolean unregisterJar(java.lang.String jarsToUnregister)
public static SessionState.ResourceType find_resource_type(java.lang.String s)
public java.lang.String add_resource(SessionState.ResourceType t, java.lang.String value)
public java.lang.String add_resource(SessionState.ResourceType t, java.lang.String value, boolean convertToUnix)
public void add_builtin_resource(SessionState.ResourceType t, java.lang.String value)
public static boolean canDownloadResource(java.lang.String value)
public boolean delete_resource(SessionState.ResourceType t, java.lang.String value)
public java.util.Set<java.lang.String> list_resource(SessionState.ResourceType t, java.util.List<java.lang.String> filter)
public void delete_resource(SessionState.ResourceType t)
public java.lang.String getCommandType()
public HiveOperation getHiveOperation()
public void setCommandType(HiveOperation commandType)
public HiveAuthorizationProvider getAuthorizer()
public void setAuthorizer(HiveAuthorizationProvider authorizer)
public HiveAuthenticationProvider getAuthenticator()
public void setAuthenticator(HiveAuthenticationProvider authenticator)
public CreateTableAutomaticGrant getCreateTableGrants()
public void setCreateTableGrants(CreateTableAutomaticGrant createTableGrants)
public java.util.List<MapRedStats> getLastMapRedStatsList()
public void setLastMapRedStatsList(java.util.List<MapRedStats> lastMapRedStatsList)
public void setStackTraces(java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> stackTraces)
public java.util.Map<java.lang.String,java.util.List<java.util.List<java.lang.String>>> getStackTraces()
public java.util.Map<java.lang.String,java.lang.String> getOverriddenConfigurations()
public void setOverriddenConfigurations(java.util.Map<java.lang.String,java.lang.String> overriddenConfigurations)
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getLocalMapRedErrors()
public void addLocalMapRedErrors(java.lang.String id, java.util.List<java.lang.String> localMapRedErrors)
public void setLocalMapRedErrors(java.util.Map<java.lang.String,java.util.List<java.lang.String>> localMapRedErrors)
public java.lang.String getCurrentDatabase()
public void setCurrentDatabase(java.lang.String currentDatabase)
public void close() throws java.io.IOException
java.io.IOException
public PerfLogger getPerfLogger(boolean resetPerfLogger)
resetPerfLogger
- Copyright © 2012 The Apache Software Foundation