org.apache.hadoop.hive.llap.registry.impl

Class LlapFixedRegistryImpl

java.lang.Object

org.apache.hadoop.hive.llap.registry.impl.LlapFixedRegistryImpl

All Implemented Interfaces:

ServiceRegistry

public class LlapFixedRegistryImpl
extends Object
implements ServiceRegistry

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIXED_REGISTRY_RESOLVE_HOST_NAMES

Constructor Summary

Constructors

Constructor and Description
LlapFixedRegistryImpl(String hosts, org.apache.hadoop.conf.Configuration conf)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

FIXED_REGISTRY_RESOLVE_HOST_NAMES

@InterfaceAudience.Private
public static final String FIXED_REGISTRY_RESOLVE_HOST_NAMES

See Also:

Constant Field Values

Constructor Detail

LlapFixedRegistryImpl

public LlapFixedRegistryImpl(String hosts,
                             org.apache.hadoop.conf.Configuration conf)

Method Detail

start

public void start()
           throws IOException

Description copied from interface: ServiceRegistry

Start the service registry

Specified by:

start in interface ServiceRegistry

Throws:

IOException

stop

public void stop()
          throws IOException

Description copied from interface: ServiceRegistry

Stop the service registry

Specified by:

stop in interface ServiceRegistry

Throws:

IOException

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

Returns:

self identifying name

Throws:

IOException

unregister

public void unregister()
                throws IOException

Description copied from interface: ServiceRegistry

Remove the current registration cleanly (implementation defined cleanup)

Specified by:

unregister in interface ServiceRegistry

Throws:

IOException

getWorkerIdentity

public static String getWorkerIdentity(String host)

getInstances

public LlapServiceInstanceSet getInstances(String component,
                                           long timeoutMs)
                                    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

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

Throws:

IOException

registerStateChangeListener

public void registerStateChangeListener(ServiceInstanceStateChangeListener listener)
                                 throws IOException

Description copied from interface: ServiceRegistry

Adds state change listeners for service instances.

Specified by:

registerStateChangeListener in interface ServiceRegistry

Parameters:

listener - - state change listener

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getApplicationId

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

Specified by:

getApplicationId in interface ServiceRegistry

Returns:

The application ID of the LLAP cluster.

Throws:

IOException