public class TezAmRegistryImpl extends ZkRegistryBase<TezAmInstance>
conf, doCheckAcls, encoder, hostname, UNIQUE_ID, UNIQUE_IDENTIFIER, USER_SCOPE_PATH_PREFIX, WORKER_GROUP, WORKER_PREFIX, workersPath, zooKeeperClient
Modifier and Type | Method and Description |
---|---|
static TezAmRegistryImpl |
create(org.apache.hadoop.conf.Configuration conf,
boolean useSecureZk) |
protected TezAmInstance |
createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv) |
TezAmInstance |
getInstance(String name) |
String |
getRegistryName() |
protected String |
getZkPathUser(org.apache.hadoop.conf.Configuration conf) |
void |
initializeWithoutRegistering() |
void |
populateCache(boolean doInvokeListeners) |
String |
register(int amPort,
int pluginPort,
String sessionId,
String serializedToken,
String jobIdForToken,
int guaranteedCount) |
void |
updateGuaranteed(int guaranteedCount) |
ensureInstancesCache, getAllInternal, getByHostInternal, getInstanceByPath, getRegistrationZnodePath, getRootNamespace, getWorkerData, populateCache, registerServiceRecord, registerServiceRecord, registerStateChangeListener, sizeInternal, start, stop, unregisterInternal, updateServiceRecord
public static TezAmRegistryImpl create(org.apache.hadoop.conf.Configuration conf, boolean useSecureZk)
public void initializeWithoutRegistering() throws IOException
IOException
public void populateCache(boolean doInvokeListeners) throws IOException
IOException
public String register(int amPort, int pluginPort, String sessionId, String serializedToken, String jobIdForToken, int guaranteedCount) throws IOException
IOException
public void updateGuaranteed(int guaranteedCount) throws IOException
IOException
public TezAmInstance getInstance(String name)
protected TezAmInstance createServiceInstance(org.apache.hadoop.registry.client.types.ServiceRecord srv) throws IOException
createServiceInstance
in class ZkRegistryBase<TezAmInstance>
IOException
protected String getZkPathUser(org.apache.hadoop.conf.Configuration conf)
getZkPathUser
in class ZkRegistryBase<TezAmInstance>
public String getRegistryName()
Copyright © 2022 The Apache Software Foundation. All rights reserved.