org.apache.hadoop.hive.registry.impl

Class TezAmRegistryImpl

java.lang.Object

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

org.apache.hadoop.hive.registry.impl.TezAmRegistryImpl

public class TezAmRegistryImpl
extends ZkRegistryBase<TezAmInstance>

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

Method Summary

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)

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

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

Methods inherited from class java.lang.Object

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

Method Detail

create

public static TezAmRegistryImpl create(org.apache.hadoop.conf.Configuration conf,
                                       boolean useSecureZk)

initializeWithoutRegistering

public void initializeWithoutRegistering()
                                  throws IOException

Throws:

IOException

populateCache

public void populateCache(boolean doInvokeListeners)
                   throws IOException

Throws:

IOException

register

public String register(int amPort,
                       int pluginPort,
                       String sessionId,
                       String serializedToken,
                       String jobIdForToken,
                       int guaranteedCount)
                throws IOException

Throws:

IOException

updateGuaranteed

public void updateGuaranteed(int guaranteedCount)
                      throws IOException

Throws:

IOException

getInstance

public TezAmInstance getInstance(String name)

createServiceInstance

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

Specified by:

createServiceInstance in class ZkRegistryBase<TezAmInstance>

Throws:

IOException

getZkPathUser

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

Specified by:

getZkPathUser in class ZkRegistryBase<TezAmInstance>

getRegistryName

public String getRegistryName()