org.apache.hadoop.hive.llap.registry

Interface ServiceRegistry<T extends ServiceInstance>

All Known Implementing Classes:

HS2ActivePassiveHARegistry, LlapFixedRegistryImpl, LlapZookeeperRegistryImpl

public interface ServiceRegistry<T extends ServiceInstance>

ServiceRegistry interface for switching between fixed host and dynamic registry implementations.

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationId()
ServiceInstanceSet<T>	getInstances(String component, long clusterReadyTimeoutMs) Client API to get the list of instances registered via the current registry key.
String	register() Register the current instance - the implementation takes care of the endpoints to register.
void	registerStateChangeListener(ServiceInstanceStateChangeListener<T> listener) Adds state change listeners for service instances.
void	start() Start the service registry
void	stop() Stop the service registry
void	unregister() Remove the current registration cleanly (implementation defined cleanup)

Method Detail

start

void start()
    throws IOException

Start the service registry

Throws:

IOException

stop

void stop()
   throws IOException

Stop the service registry

Throws:

IOException

register

String register()
         throws IOException

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

Returns:

self identifying name

Throws:

IOException

unregister

void unregister()
         throws IOException

Remove the current registration cleanly (implementation defined cleanup)

Throws:

IOException

getInstances

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

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

Parameters:

component -

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

Throws:

IOException

registerStateChangeListener

void registerStateChangeListener(ServiceInstanceStateChangeListener<T> listener)
                          throws IOException

Adds state change listeners for service instances.

Parameters:

listener - - state change listener

Throws:

IOException

getApplicationId

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

Returns:

The application ID of the LLAP cluster.

Throws:

IOException