org.apache.flink.table.planner.delegation.hive

Class HiveSessionState

java.lang.Object

org.apache.hadoop.hive.ql.session.SessionState

org.apache.flink.table.planner.delegation.hive.HiveSessionState

public class HiveSessionState
extends org.apache.hadoop.hive.ql.session.SessionState

Sub-class of SessionState to meet our needs.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.session.SessionState

org.apache.hadoop.hive.ql.session.SessionState.AuthorizationMode, org.apache.hadoop.hive.ql.session.SessionState.LogHelper, org.apache.hadoop.hive.ql.session.SessionState.ResourceType

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.session.SessionState

childErr, childOut, err, hiveHist, in, info, isSilent, isVerbose, out, parentLoader, tmpErrOutputFile, tmpOutputFile

Constructor Summary

Constructors

Constructor and Description
HiveSessionState(HiveConf conf, ClassLoader contextLoader)

Method Summary

Modifier and Type	Method and Description
static void	clearSessionState()
void	close()
Timestamp	getHiveParserCurrentTS()
void	setHiveParserCurrentTSCurrentTS(Timestamp hiveParserCurrentTS)
static void	startSessionState(HiveConf hiveConf, CatalogManager catalogManager)

Methods inherited from class org.apache.hadoop.hive.ql.session.SessionState

add_resource, add_resource, add_resources, add_resources, addCleanupItem, addLocalMapRedErrors, applyAuthorizationPolicy, beginStart, closeSparkSession, delete_resources, delete_resources, deleteTmpErrOutputFile, deleteTmpOutputFile, detachSession, endStart, find_resource_type, generateTempTableLocation, get, getActiveAuthorizer, getATSDomainId, getAuthenticator, getAuthorizationMode, getAuthorizer, getAuthorizerInterface, getAuthorizerV2, getCompileLock, getConf, getConsole, getCreateTableGrants, getCurrentDatabase, getCurrentFunctionsInUse, getForwardedAddresses, getGroupsFromAuthenticator, getHdfsEncryptionShim, getHdfsEncryptionShim, getHdfsScratchDirURIString, getHDFSSessionPath, getHiveHistory, getHiveServer2Host, getHiveVariables, getIsSilent, getIsUsingThriftJDBCBinarySerDe, getIsVerbose, getKillQuery, getLastCommand, getLocalMapRedErrors, getLocalSessionPath, getMapRedStats, getNextValuesTempTableSuffix, getOverriddenConfigurations, getPerfLogger, getPerfLogger, getProgressMonitor, getQueryCurrentTimestamp, getRegistry, getRegistryForWrite, getReloadableAuxJars, getResourceDownloader, getSessionConf, getSessionId, getSparkSession, getStackTraces, getTempPartitions, getTempTableColStats, getTempTables, getTempTableSpace, getTempTableSpace, getTezSession, getTmpErrOutputFile, getTmpOutputFile, getTxnMgr, getUserFromAuthenticator, getUserIpAddress, getUserName, initTxnMgr, isAuthorizationModeV2, isHiveServerQuery, list_hdfs_resource, list_local_resource, list_resource, loadAuxJars, loadReloadableAuxJars, resetThreadName, resolveAndDownload, setActiveAuthorizer, setATSDomainId, setAuthenticator, setAuthorizer, setConf, setCreateTableGrants, setCurrentDatabase, setCurrentSessionState, setForwardedAddresses, setHiveServer2Host, setHiveVariables, setIsHiveServerQuery, setIsSilent, setIsUsingThriftJDBCBinarySerDe, setIsVerbose, setKillQuery, setLastCommand, setLocalMapRedErrors, setMapRedStats, setOverriddenConfigurations, setSparkSession, setStackTraces, setTezSession, setTmpErrOutputFile, setTmpOutputFile, setTxnMgr, setupQueryCurrentTimestamp, setUserIpAddress, start, start, updateHistory, updateProgressedPercentage, updateProgressMonitor, updateThreadName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveSessionState

public HiveSessionState(HiveConf conf,
                        ClassLoader contextLoader)

Method Detail

close

public void close()
           throws IOException

Overrides:

close in class org.apache.hadoop.hive.ql.session.SessionState

Throws:

IOException

setHiveParserCurrentTSCurrentTS

public void setHiveParserCurrentTSCurrentTS(Timestamp hiveParserCurrentTS)

getHiveParserCurrentTS

public Timestamp getHiveParserCurrentTS()

startSessionState

public static void startSessionState(HiveConf hiveConf,
                                     CatalogManager catalogManager)

clearSessionState

public static void clearSessionState()