public class LlapFixedRegistryImpl extends Object implements ServiceRegistry
Modifier and Type | Field and Description |
---|---|
static String |
FIXED_REGISTRY_RESOLVE_HOST_NAMES |
Constructor and Description |
---|
LlapFixedRegistryImpl(String hosts,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId() |
ServiceInstanceSet |
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)
|
@InterfaceAudience.Private public static final String FIXED_REGISTRY_RESOLVE_HOST_NAMES
public LlapFixedRegistryImpl(String hosts, org.apache.hadoop.conf.Configuration conf)
public void start() throws IOException
ServiceRegistry
start
in interface ServiceRegistry
IOException
public void stop() throws IOException
ServiceRegistry
stop
in interface ServiceRegistry
IOException
public String register() throws IOException
ServiceRegistry
register
in interface ServiceRegistry
IOException
public void unregister() throws IOException
ServiceRegistry
unregister
in interface ServiceRegistry
IOException
public ServiceInstanceSet getInstances(String component, long timeoutMs) throws IOException
ServiceRegistry
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.IOException
public void registerStateChangeListener(ServiceInstanceStateChangeListener listener)
ServiceRegistry
registerStateChangeListener
in interface ServiceRegistry
listener
- - state change listenerpublic org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId() throws IOException
getApplicationId
in interface ServiceRegistry
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.