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

Class LlapZookeeperRegistryImpl

java.lang.Object

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

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

All Implemented Interfaces:

ServiceRegistry<LlapServiceInstance>

public class LlapZookeeperRegistryImpl
extends ZkRegistryBase<LlapServiceInstance>
implements ServiceRegistry<LlapServiceInstance>

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

Constructor Summary

Constructors

Constructor and Description
LlapZookeeperRegistryImpl(String instanceName, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
protected LlapServiceInstance	createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv)
org.apache.hadoop.yarn.api.records.ApplicationId	getApplicationId()
LlapServiceInstanceSet	getInstances(String component, long clusterReadyTimeoutMs) Client API to get the list of instances registered via the current registry key.
org.apache.hadoop.registry.client.types.Endpoint	getMngEndpoint()
org.apache.hadoop.registry.client.types.Endpoint	getOutputFormatEndpoint()
org.apache.hadoop.registry.client.types.Endpoint	getRpcEndpoint()
org.apache.hadoop.registry.client.types.Endpoint	getServicesEndpoint()
org.apache.hadoop.registry.client.types.Endpoint	getShuffleEndpoint()
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	stop() Stop the service registry
void	unregister() Remove the current registration cleanly (implementation defined cleanup)

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hive.llap.registry.ServiceRegistry

registerStateChangeListener, start

Constructor Detail

LlapZookeeperRegistryImpl

public LlapZookeeperRegistryImpl(String instanceName,
                                 org.apache.hadoop.conf.Configuration conf)

Method Detail

getRpcEndpoint

public org.apache.hadoop.registry.client.types.Endpoint getRpcEndpoint()

getShuffleEndpoint

public org.apache.hadoop.registry.client.types.Endpoint getShuffleEndpoint()

getServicesEndpoint

public org.apache.hadoop.registry.client.types.Endpoint getServicesEndpoint()

getMngEndpoint

public org.apache.hadoop.registry.client.types.Endpoint getMngEndpoint()

getOutputFormatEndpoint

public org.apache.hadoop.registry.client.types.Endpoint getOutputFormatEndpoint()

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<LlapServiceInstance>

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<LlapServiceInstance>

Throws:

IOException

getInstances

public LlapServiceInstanceSet 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<LlapServiceInstance>

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

Throws:

IOException

getApplicationId

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

Specified by:

getApplicationId in interface ServiceRegistry<LlapServiceInstance>

Returns:

The application ID of the LLAP cluster.

Throws:

IOException

stop

public void stop()

Description copied from interface: ServiceRegistry

Stop the service registry

Specified by:

stop in interface ServiceRegistry<LlapServiceInstance>

Overrides:

stop in class ZkRegistryBase<LlapServiceInstance>

createServiceInstance

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

Specified by:

createServiceInstance in class ZkRegistryBase<LlapServiceInstance>

Throws:

IOException

getZkPathUser

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

Specified by:

getZkPathUser in class ZkRegistryBase<LlapServiceInstance>