org.apache.hive.service.server

Class HiveServer2

java.lang.Object

org.apache.hive.service.AbstractService

org.apache.hive.service.CompositeService

org.apache.hive.service.server.HiveServer2

All Implemented Interfaces:

Service

public class HiveServer2
extends CompositeService

HiveServer2.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveServer2.FailoverHandlerCallback

Nested classes/interfaces inherited from class org.apache.hive.service.CompositeService

CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hive.service.Service

Service.STATE

Field Summary

Fields

Modifier and Type	Field and Description
static String	INSTANCE_URI_CONFIG

Constructor Summary

Constructors

Constructor and Description
HiveServer2()
HiveServer2(PamAuthenticator pamAuthenticator)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.SettableFuture<Boolean>	getIsLeaderTestFuture()
com.google.common.util.concurrent.SettableFuture<Boolean>	getNotLeaderTestFuture()
int	getOpenSessionsCount()
String	getServerHost()
void	init(HiveConf hiveConf) Initialize the service.
boolean	isDeregisteredWithZooKeeper()
static boolean	isHTTPTransportMode(org.apache.hadoop.conf.Configuration hiveConf)
static boolean	isKerberosAuthMode(org.apache.hadoop.conf.Configuration hiveConf)
boolean	isLeader()
static void	main(String[] args)
static void	scheduleClearDanglingScratchDir(HiveConf hiveConf, int initialWaitInSec)
void	setPamAuthenticator(PamAuthenticator pamAuthenticator)
void	start() Start the service.
void	startPrivilegeSynchonizer(HiveConf hiveConf)
void	stop() Stop the service.

Methods inherited from class org.apache.hive.service.CompositeService

addService, getServices, removeService

Methods inherited from class org.apache.hive.service.AbstractService

getHiveConf, getName, getServiceState, getStartTime, register, setHiveConf, unregister

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE_URI_CONFIG

public static final String INSTANCE_URI_CONFIG

See Also:

Constant Field Values

Constructor Detail

HiveServer2

public HiveServer2()

HiveServer2

public HiveServer2(PamAuthenticator pamAuthenticator)

Method Detail

setPamAuthenticator

public void setPamAuthenticator(PamAuthenticator pamAuthenticator)

getIsLeaderTestFuture

public com.google.common.util.concurrent.SettableFuture<Boolean> getIsLeaderTestFuture()

getNotLeaderTestFuture

public com.google.common.util.concurrent.SettableFuture<Boolean> getNotLeaderTestFuture()

init

public void init(HiveConf hiveConf)

Description copied from class: AbstractService

Initialize the service. The transition must be from Service.STATE.NOTINITED to Service.STATE.INITED unless the operation failed and an exception was raised.

Specified by:

init in interface Service

Overrides:

init in class CompositeService

isHTTPTransportMode

public static boolean isHTTPTransportMode(org.apache.hadoop.conf.Configuration hiveConf)

isKerberosAuthMode

public static boolean isKerberosAuthMode(org.apache.hadoop.conf.Configuration hiveConf)

isLeader

public boolean isLeader()

getOpenSessionsCount

public int getOpenSessionsCount()

isDeregisteredWithZooKeeper

public boolean isDeregisteredWithZooKeeper()

getServerHost

public String getServerHost()
                     throws Exception

Throws:

Exception

start

public void start()

Description copied from class: AbstractService

Start the service. The transition should be from Service.STATE.INITED to Service.STATE.STARTED unless the operation failed and an exception was raised.

Specified by:

start in interface Service

Overrides:

start in class CompositeService

stop

public void stop()

Description copied from class: AbstractService

Stop the service. This operation must be designed to complete regardless of the initial state of the service, including the state of all its internal fields.

Specified by:

stop in interface Service

Overrides:

stop in class CompositeService

scheduleClearDanglingScratchDir

public static void scheduleClearDanglingScratchDir(HiveConf hiveConf,
                                                   int initialWaitInSec)

startPrivilegeSynchonizer

public void startPrivilegeSynchonizer(HiveConf hiveConf)
                               throws Exception

Throws:

Exception

main

public static void main(String[] args)