org.apache.hive.service.cli.session
Class HiveSessionImplwithUGI
java.lang.Object
org.apache.hive.service.cli.session.HiveSessionImpl
org.apache.hive.service.cli.session.HiveSessionImplwithUGI
- All Implemented Interfaces:
- HiveSession
public class HiveSessionImplwithUGI
- extends HiveSessionImpl
HiveSessionImplwithUGI.
HiveSession with connecting user's UGI and delegation token if required
Methods inherited from class org.apache.hive.service.cli.session.HiveSessionImpl |
cancelOperation, closeOperation, executeStatement, fetchResults, fetchResults, getCatalogs, getColumns, getFunctions, getHiveConf, getInfo, getMetaStoreClient, getPassword, getResultSetMetadata, getSchemas, getSessionHandle, getSessionState, getTables, getTableTypes, getTypeInfo, getUsername, getUserName, release, setOperationManager, setSessionManager, setUserName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HS2TOKEN
public static final String HS2TOKEN
- See Also:
- Constant Field Values
HiveSessionImplwithUGI
public HiveSessionImplwithUGI(String username,
String password,
Map<String,String> sessionConf,
String delegationToken)
throws HiveSQLException
- Throws:
HiveSQLException
setSessionUGI
public void setSessionUGI(String owner)
throws HiveSQLException
- Throws:
HiveSQLException
getSessionUgi
public UserGroupInformation getSessionUgi()
getDelegationToken
public String getDelegationToken()
acquire
protected void acquire()
throws HiveSQLException
- Overrides:
acquire
in class HiveSessionImpl
- Throws:
HiveSQLException
close
public void close()
throws HiveSQLException
- close the file systems for the session
cancel the session's delegation token and close the metastore connection
- Specified by:
close
in interface HiveSession
- Overrides:
close
in class HiveSessionImpl
- Throws:
HiveSQLException
getSession
protected HiveSession getSession()
- Overrides:
getSession
in class HiveSessionImpl
setProxySession
public void setProxySession(HiveSession proxySession)
Copyright © 2012 The Apache Software Foundation