public class HiveServer2 extends CompositeService
Modifier and Type | Class and Description |
---|---|
static class |
HiveServer2.FailoverHandlerCallback |
CompositeService.CompositeServiceShutdownHook
Service.STATE
Modifier and Type | Field and Description |
---|---|
static String |
INSTANCE_URI_CONFIG |
Constructor and Description |
---|
HiveServer2() |
HiveServer2(PamAuthenticator pamAuthenticator) |
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.
|
addService, getServices, removeService
getHiveConf, getName, getServiceState, getStartTime, register, setHiveConf, unregister
public static final String INSTANCE_URI_CONFIG
public HiveServer2()
public HiveServer2(PamAuthenticator pamAuthenticator)
public void setPamAuthenticator(PamAuthenticator pamAuthenticator)
public com.google.common.util.concurrent.SettableFuture<Boolean> getIsLeaderTestFuture()
public com.google.common.util.concurrent.SettableFuture<Boolean> getNotLeaderTestFuture()
public void init(HiveConf hiveConf)
AbstractService
Service.STATE.NOTINITED
to Service.STATE.INITED
unless the
operation failed and an exception was raised.init
in interface Service
init
in class CompositeService
public static boolean isHTTPTransportMode(org.apache.hadoop.conf.Configuration hiveConf)
public static boolean isKerberosAuthMode(org.apache.hadoop.conf.Configuration hiveConf)
public boolean isLeader()
public int getOpenSessionsCount()
public boolean isDeregisteredWithZooKeeper()
public void start()
AbstractService
Service.STATE.INITED
to Service.STATE.STARTED
unless the
operation failed and an exception was raised.start
in interface Service
start
in class CompositeService
public void stop()
AbstractService
stop
in interface Service
stop
in class CompositeService
public static void scheduleClearDanglingScratchDir(HiveConf hiveConf, int initialWaitInSec)
public void startPrivilegeSynchonizer(HiveConf hiveConf) throws Exception
Exception
public static void main(String[] args)
Copyright © 2022 The Apache Software Foundation. All rights reserved.