public class LlapRegistryService
extends org.apache.hadoop.service.AbstractService
Constructor and Description |
---|
LlapRegistryService(boolean isDaemon) |
Modifier and Type | Method and Description |
---|---|
static String |
currentUser() |
org.apache.hadoop.yarn.api.records.ApplicationId |
getApplicationId() |
static LlapRegistryService |
getClient(org.apache.hadoop.conf.Configuration conf)
Helper method to get a ServiceRegistry instance to read from the registry.
|
LlapServiceInstanceSet |
getInstances() |
LlapServiceInstanceSet |
getInstances(long clusterReadyTimeoutMs) |
String |
getWorkerIdentity() |
boolean |
isDynamic() |
void |
registerStateChangeListener(ServiceInstanceStateChangeListener<LlapServiceInstance> listener) |
void |
serviceInit(org.apache.hadoop.conf.Configuration conf) |
void |
serviceStart() |
void |
serviceStop() |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static LlapRegistryService getClient(org.apache.hadoop.conf.Configuration conf)
conf
- Configuration
instance which contains service registry information.public static String currentUser()
public void serviceInit(org.apache.hadoop.conf.Configuration conf)
serviceInit
in class org.apache.hadoop.service.AbstractService
public void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.AbstractService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.AbstractService
Exception
public LlapServiceInstanceSet getInstances() throws IOException
IOException
public LlapServiceInstanceSet getInstances(long clusterReadyTimeoutMs) throws IOException
IOException
public void registerStateChangeListener(ServiceInstanceStateChangeListener<LlapServiceInstance> listener) throws IOException
IOException
public boolean isDynamic()
public String getWorkerIdentity()
public org.apache.hadoop.yarn.api.records.ApplicationId getApplicationId() throws IOException
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.