org.apache.hive.service.server

Class HS2ActivePassiveHARegistry

java.lang.Object

org.apache.hadoop.hive.registry.impl.ZkRegistryBase<HiveServer2Instance>

org.apache.hive.service.server.HS2ActivePassiveHARegistry

All Implemented Interfaces:

ServiceRegistry<HiveServer2Instance>, ServiceInstanceSet<HiveServer2Instance>, HiveServer2HAInstanceSet

public class HS2ActivePassiveHARegistry
extends ZkRegistryBase<HiveServer2Instance>
implements ServiceRegistry<HiveServer2Instance>, HiveServer2HAInstanceSet

Field Summary

Fields inherited from class org.apache.hadoop.hive.registry.impl.ZkRegistryBase

conf, doCheckAcls, encoder, hostname, UNIQUE_ID, UNIQUE_IDENTIFIER, USER_SCOPE_PATH_PREFIX, WORKER_GROUP, WORKER_PREFIX, workersPath, zooKeeperClient

Method Summary

Modifier and Type	Method and Description
protected HiveServer2Instance	createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv)
void	failover()
Collection<HiveServer2Instance>	getAll() Get an instance mapping which map worker identity to each instance.
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationId()
Set<HiveServer2Instance>	getByHost(String host) Get a list of service instances for a given host.
HiveServer2Instance	getInstance(String instanceId) Get an instance by worker identity.
ServiceInstanceSet<HiveServer2Instance>	getInstances(String component, long clusterReadyTimeoutMs) Client API to get the list of instances registered via the current registry key.
HiveServer2Instance	getLeader() In Active/Passive setup, returns current active leader.
protected String	getZkPathUser(org.apache.hadoop.conf.Configuration conf)
String	register() Register the current instance - the implementation takes care of the endpoints to register.
void	registerStateChangeListener(ServiceInstanceStateChangeListener<HiveServer2Instance> listener) Adds state change listeners for service instances.
int	size() Get number of instances in the currently available.
void	start() Start the service registry
void	stop() Stop the service registry
void	unregister() Remove the current registration cleanly (implementation defined cleanup)
protected void	unregisterInternal()

Methods inherited from class org.apache.hadoop.hive.registry.impl.ZkRegistryBase

ensureInstancesCache, getAllInternal, getByHostInternal, getInstanceByPath, getRegistrationZnodePath, getRootNamespace, getWorkerData, populateCache, registerServiceRecord, registerServiceRecord, sizeInternal, updateServiceRecord

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start()
           throws IOException

Description copied from interface: ServiceRegistry

Start the service registry

Specified by:

start in interface ServiceRegistry<HiveServer2Instance>

Overrides:

start in class ZkRegistryBase<HiveServer2Instance>

Throws:

IOException

unregisterInternal

protected void unregisterInternal()

Overrides:

unregisterInternal in class ZkRegistryBase<HiveServer2Instance>

register

public String register()
                throws IOException

Description copied from interface: ServiceRegistry

Register the current instance - the implementation takes care of the endpoints to register.

Specified by:

register in interface ServiceRegistry<HiveServer2Instance>

Returns:

self identifying name

Throws:

IOException

unregister

public void unregister()

Description copied from interface: ServiceRegistry

Remove the current registration cleanly (implementation defined cleanup)

Specified by:

unregister in interface ServiceRegistry<HiveServer2Instance>

getInstances

public ServiceInstanceSet<HiveServer2Instance> getInstances(String component,
                                                            long clusterReadyTimeoutMs)
                                                     throws IOException

Description copied from interface: ServiceRegistry

Client API to get the list of instances registered via the current registry key.

Specified by:

getInstances in interface ServiceRegistry<HiveServer2Instance>

clusterReadyTimeoutMs - The time to wait for the cluster to be ready, if it's not started yet. 0 means do not wait.

Throws:

IOException

stop

public void stop()

Description copied from interface: ServiceRegistry

Stop the service registry

Specified by:

stop in interface ServiceRegistry<HiveServer2Instance>

Overrides:

stop in class ZkRegistryBase<HiveServer2Instance>

createServiceInstance

protected HiveServer2Instance createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv)
                                             throws IOException

Specified by:

createServiceInstance in class ZkRegistryBase<HiveServer2Instance>

Throws:

IOException

registerStateChangeListener

public void registerStateChangeListener(ServiceInstanceStateChangeListener<HiveServer2Instance> listener)
                                 throws IOException

Description copied from interface: ServiceRegistry

Adds state change listeners for service instances.

Specified by:

registerStateChangeListener in interface ServiceRegistry<HiveServer2Instance>

Overrides:

registerStateChangeListener in class ZkRegistryBase<HiveServer2Instance>

Parameters:

listener - - state change listener

Throws:

IOException

getApplicationId

public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId()
                                                                  throws IOException

Specified by:

getApplicationId in interface ServiceRegistry<HiveServer2Instance>

Returns:

The application ID of the LLAP cluster.

Throws:

IOException

getZkPathUser

protected String getZkPathUser(org.apache.hadoop.conf.Configuration conf)

Specified by:

getZkPathUser in class ZkRegistryBase<HiveServer2Instance>

failover

public void failover()
              throws Exception

Throws:

Exception

getLeader

public HiveServer2Instance getLeader()

Description copied from interface: HiveServer2HAInstanceSet

In Active/Passive setup, returns current active leader.

Specified by:

getLeader in interface HiveServer2HAInstanceSet

Returns:

leader instance

getAll

public Collection<HiveServer2Instance> getAll()

Description copied from interface: ServiceInstanceSet

Get an instance mapping which map worker identity to each instance. The worker identity does not collide between restarts, so each restart will have a unique id, while having the same host/ip pair.

Specified by:

getAll in interface ServiceInstanceSet<HiveServer2Instance>

Returns:

instance list

getInstance

public HiveServer2Instance getInstance(String instanceId)

Description copied from interface: ServiceInstanceSet

Get an instance by worker identity.

Specified by:

getInstance in interface ServiceInstanceSet<HiveServer2Instance>

Parameters:

instanceId - worker id

Returns:

instance

getByHost

public Set<HiveServer2Instance> getByHost(String host)

Description copied from interface: ServiceInstanceSet

Get a list of service instances for a given host. The list could include dead and alive instances.

Specified by:

getByHost in interface ServiceInstanceSet<HiveServer2Instance>

Parameters:

host - hostname

Returns:

instance list

size

public int size()

Description copied from interface: ServiceInstanceSet

Get number of instances in the currently available.

Specified by:

size in interface ServiceInstanceSet<HiveServer2Instance>

Returns:

- number of instances