public class LlapZookeeperRegistryImpl extends ZkRegistryBase<LlapServiceInstance> implements ServiceRegistry<LlapServiceInstance>
conf, doCheckAcls, encoder, hostname, UNIQUE_ID, UNIQUE_IDENTIFIER, USER_SCOPE_PATH_PREFIX, WORKER_GROUP, WORKER_PREFIX, workersPath, zooKeeperClient
Constructor and Description |
---|
LlapZookeeperRegistryImpl(String instanceName,
org.apache.hadoop.conf.Configuration conf) |
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)
|
ensureInstancesCache, getAllInternal, getByHostInternal, getInstanceByPath, getRegistrationZnodePath, getRootNamespace, getWorkerData, populateCache, registerServiceRecord, registerServiceRecord, registerStateChangeListener, sizeInternal, start, unregisterInternal, updateServiceRecord
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
registerStateChangeListener, start
public LlapZookeeperRegistryImpl(String instanceName, org.apache.hadoop.conf.Configuration conf)
public org.apache.hadoop.registry.client.types.Endpoint getRpcEndpoint()
public org.apache.hadoop.registry.client.types.Endpoint getShuffleEndpoint()
public org.apache.hadoop.registry.client.types.Endpoint getServicesEndpoint()
public org.apache.hadoop.registry.client.types.Endpoint getMngEndpoint()
public org.apache.hadoop.registry.client.types.Endpoint getOutputFormatEndpoint()
public String register() throws IOException
ServiceRegistry
register
in interface ServiceRegistry<LlapServiceInstance>
IOException
public void unregister() throws IOException
ServiceRegistry
unregister
in interface ServiceRegistry<LlapServiceInstance>
IOException
public LlapServiceInstanceSet getInstances(String component, long clusterReadyTimeoutMs) throws IOException
ServiceRegistry
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.IOException
public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId() throws IOException
getApplicationId
in interface ServiceRegistry<LlapServiceInstance>
IOException
public void stop()
ServiceRegistry
stop
in interface ServiceRegistry<LlapServiceInstance>
stop
in class ZkRegistryBase<LlapServiceInstance>
protected LlapServiceInstance createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv) throws IOException
createServiceInstance
in class ZkRegistryBase<LlapServiceInstance>
IOException
protected String getZkPathUser(org.apache.hadoop.conf.Configuration conf)
getZkPathUser
in class ZkRegistryBase<LlapServiceInstance>
Copyright © 2022 The Apache Software Foundation. All rights reserved.