public class HiveSessionImpl extends java.lang.Object implements HiveSession
Constructor and Description |
---|
HiveSessionImpl(java.lang.String username,
java.lang.String password,
java.util.Map<java.lang.String,java.lang.String> sessionConf) |
Modifier and Type | Method and Description |
---|---|
protected void |
acquire() |
void |
cancelOperation(OperationHandle opHandle) |
void |
close()
close the session
|
void |
closeOperation(OperationHandle opHandle) |
OperationHandle |
executeStatement(java.lang.String statement,
java.util.Map<java.lang.String,java.lang.String> confOverlay)
execute operation handler
|
OperationHandle |
executeStatementAsync(java.lang.String statement,
java.util.Map<java.lang.String,java.lang.String> confOverlay)
execute operation handler
|
RowSet |
fetchResults(OperationHandle opHandle) |
RowSet |
fetchResults(OperationHandle opHandle,
FetchOrientation orientation,
long maxRows) |
OperationHandle |
getCatalogs()
getCatalogs operation handler
|
OperationHandle |
getColumns(java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String tableName,
java.lang.String columnName)
getColumns operation handler
|
OperationHandle |
getFunctions(java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String functionName)
getFunctions operation handler
|
HiveConf |
getHiveConf() |
GetInfoValue |
getInfo(GetInfoType getInfoType)
getInfo operation handler
|
IMetaStoreClient |
getMetaStoreClient() |
java.lang.String |
getPassword() |
TableSchema |
getResultSetMetadata(OperationHandle opHandle) |
OperationHandle |
getSchemas(java.lang.String catalogName,
java.lang.String schemaName)
getSchemas operation handler
|
protected HiveSession |
getSession() |
SessionHandle |
getSessionHandle() |
SessionManager |
getSessionManager()
Get the session manager for the session
|
SessionState |
getSessionState() |
OperationHandle |
getTables(java.lang.String catalogName,
java.lang.String schemaName,
java.lang.String tableName,
java.util.List<java.lang.String> tableTypes)
getTables operation handler
|
OperationHandle |
getTableTypes()
getTableTypes operation handler
|
OperationHandle |
getTypeInfo()
getTypeInfo operation handler
|
java.lang.String |
getUsername() |
java.lang.String |
getUserName() |
protected void |
release() |
void |
setOperationManager(OperationManager operationManager)
Set operation manager for the session
|
void |
setSessionManager(SessionManager sessionManager)
Set the session manager for the session
|
void |
setUserName(java.lang.String userName) |
public HiveSessionImpl(java.lang.String username, java.lang.String password, java.util.Map<java.lang.String,java.lang.String> sessionConf)
public SessionManager getSessionManager()
HiveSession
getSessionManager
in interface HiveSession
public void setSessionManager(SessionManager sessionManager)
HiveSession
setSessionManager
in interface HiveSession
public void setOperationManager(OperationManager operationManager)
HiveSession
setOperationManager
in interface HiveSession
protected void acquire() throws HiveSQLException
HiveSQLException
protected void release()
public SessionHandle getSessionHandle()
getSessionHandle
in interface HiveSession
public java.lang.String getUsername()
getUsername
in interface HiveSession
public java.lang.String getPassword()
getPassword
in interface HiveSession
public HiveConf getHiveConf()
getHiveConf
in interface HiveSession
public IMetaStoreClient getMetaStoreClient() throws HiveSQLException
getMetaStoreClient
in interface HiveSession
HiveSQLException
public GetInfoValue getInfo(GetInfoType getInfoType) throws HiveSQLException
HiveSession
getInfo
in interface HiveSession
HiveSQLException
public OperationHandle executeStatement(java.lang.String statement, java.util.Map<java.lang.String,java.lang.String> confOverlay) throws HiveSQLException
HiveSession
executeStatement
in interface HiveSession
HiveSQLException
public OperationHandle executeStatementAsync(java.lang.String statement, java.util.Map<java.lang.String,java.lang.String> confOverlay) throws HiveSQLException
HiveSession
executeStatementAsync
in interface HiveSession
HiveSQLException
public OperationHandle getTypeInfo() throws HiveSQLException
HiveSession
getTypeInfo
in interface HiveSession
HiveSQLException
public OperationHandle getCatalogs() throws HiveSQLException
HiveSession
getCatalogs
in interface HiveSession
HiveSQLException
public OperationHandle getSchemas(java.lang.String catalogName, java.lang.String schemaName) throws HiveSQLException
HiveSession
getSchemas
in interface HiveSession
HiveSQLException
public OperationHandle getTables(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.util.List<java.lang.String> tableTypes) throws HiveSQLException
HiveSession
getTables
in interface HiveSession
HiveSQLException
public OperationHandle getTableTypes() throws HiveSQLException
HiveSession
getTableTypes
in interface HiveSession
HiveSQLException
public OperationHandle getColumns(java.lang.String catalogName, java.lang.String schemaName, java.lang.String tableName, java.lang.String columnName) throws HiveSQLException
HiveSession
getColumns
in interface HiveSession
HiveSQLException
public OperationHandle getFunctions(java.lang.String catalogName, java.lang.String schemaName, java.lang.String functionName) throws HiveSQLException
HiveSession
getFunctions
in interface HiveSession
HiveSQLException
public void close() throws HiveSQLException
HiveSession
close
in interface HiveSession
HiveSQLException
public SessionState getSessionState()
getSessionState
in interface HiveSession
public java.lang.String getUserName()
getUserName
in interface HiveSession
public void setUserName(java.lang.String userName)
setUserName
in interface HiveSession
public void cancelOperation(OperationHandle opHandle) throws HiveSQLException
cancelOperation
in interface HiveSession
HiveSQLException
public void closeOperation(OperationHandle opHandle) throws HiveSQLException
closeOperation
in interface HiveSession
HiveSQLException
public TableSchema getResultSetMetadata(OperationHandle opHandle) throws HiveSQLException
getResultSetMetadata
in interface HiveSession
HiveSQLException
public RowSet fetchResults(OperationHandle opHandle, FetchOrientation orientation, long maxRows) throws HiveSQLException
fetchResults
in interface HiveSession
HiveSQLException
public RowSet fetchResults(OperationHandle opHandle) throws HiveSQLException
fetchResults
in interface HiveSession
HiveSQLException
protected HiveSession getSession()
Copyright © 2012 The Apache Software Foundation