Index (Apache Hadoop YARN Registry 2.9.0 API)

A B C D E F G H I J K L M N O P R S T U V W Y Z

A

acls - Variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.AclListInfo
aclsForUser(String, int) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Set up the ACL for the user.
aclsToString(List<ACL>) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Stringify a list of ACLs for logging.
aclToString(ACL) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Convert an ACL to a string, with any obfuscation needed
addDiagnostics(String, Object...) - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Append a formatted string to the diagnostics.
addDigestACL(ACL) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Add a digest ACL
addExternalEndpoint(Endpoint) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Add an external endpoint
AddingCompositeService - Class in org.apache.hadoop.registry.server.services: Composite service that exports the add/remove methods.
AddingCompositeService(String) - Constructor for class org.apache.hadoop.registry.server.services.AddingCompositeService
addInternalEndpoint(Endpoint) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Add an internal endpoint
ADDRESS_HOSTNAME_AND_PORT - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes: hostname/FQDN and port pair: "host/port".
ADDRESS_HOSTNAME_FIELD - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes
ADDRESS_OTHER - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes: Any other address: "".
ADDRESS_PATH - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes: Path /a/b/c style: "path".
ADDRESS_PORT_FIELD - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes
ADDRESS_URI - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes: URI entries: "uri".
ADDRESS_ZOOKEEPER - Static variable in interface org.apache.hadoop.registry.client.types.AddressTypes: Zookeeper addresses as a triple : "zktriple".
addresses - Variable in class org.apache.hadoop.registry.client.types.Endpoint: a list of address tuples —tuples whose format depends on the address type
addressType - Variable in class org.apache.hadoop.registry.client.types.Endpoint: Type of address.
AddressTypes - Interface in org.apache.hadoop.registry.client.types: Enum of address types -as integers.
addService(Service) - Method in class org.apache.hadoop.registry.server.services.AddingCompositeService
addSystemACL(ACL) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Add another system ACL
addWriteAccessor(String, String) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Add a new write access entry to be added to node permissions in all future write operations of a session connected to a secure registry.
addWriteAccessor(String, String) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
addWriteAccessor(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Add a new write access entry for all future write operations.
ALL_READ_ACCESS - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: An ACL with read access for anyone
ALL_READWRITE_ACCESS - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: An ACL with read-write access for anyone
api - Variable in class org.apache.hadoop.registry.client.types.Endpoint: API implemented at the end of the binding
APPLICATION - Static variable in interface org.apache.hadoop.registry.client.types.yarn.PersistencePolicies: Remove when the YARN application defined in the id field terminates: "application".
APPLICATION_ATTEMPT - Static variable in interface org.apache.hadoop.registry.client.types.yarn.PersistencePolicies: Remove when the current YARN application attempt ID finishes: "application-attempt".
applySecurityEnvironment(CuratorFrameworkFactory.Builder) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Apply the security environment to this curator instance.
attributes() - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: The map of "other" attributes set when parsing.
AuthenticationFailedException - Exception in org.apache.hadoop.registry.client.exceptions: Exception raised when client access wasn't authenticated.
AuthenticationFailedException(String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.AuthenticationFailedException
AuthenticationFailedException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.AuthenticationFailedException
AuthenticationFailedException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.AuthenticationFailedException

B

bind(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
bind(String, ServiceRecord, int) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Bind a path in the registry to a service record
bind(String, ServiceRecord, int) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
bind(String, ServiceRecord, int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
BindFlags - Interface in org.apache.hadoop.registry.client.api: Combinable Flags to use when creating a service entry.
bindingDiagnosticDetails() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Get the binding diagnostics
BindingInformation - Class in org.apache.hadoop.registry.client.impl.zk: Binding information provided by a RegistryBindingSource
BindingInformation() - Constructor for class org.apache.hadoop.registry.client.impl.zk.BindingInformation
bindJVMtoJAASFile(File) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Bind the JVM JAS setting to the specified JAAS file.
bindZKToServerJAASContext(String) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Set the Zookeeper server property ZookeeperConfigOptions.PROP_ZK_SERVER_SASL_CONTEXT to the SASL context.
buildACLs(String, String, int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Parse the IDs, adding a realm if needed, setting the permissions
buildConnectionString() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Override point: get the connection string used to connect to the ZK service
buildSecurityDiagnostics() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Build the security diagnostics string
buildSecurityDiagnostics() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Build up low-level security diagnostics to aid debugging

C

call() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService.AsyncPurge
children - Variable in class org.apache.hadoop.registry.client.types.RegistryPathStatus: Number of child nodes
clearJaasSystemProperties() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Reset any system properties related to JAAS
clearWriteAccessors() - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Clear all write accessors.
clearWriteAccessors() - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
clearWriteAccessors() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Clear all write accessors
clearZKSaslClientProperties() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Clear all the ZK SASL Client properties Important:This is JVM-wide
clone() - Method in class org.apache.hadoop.registry.client.types.Endpoint: Shallow clone: the lists of addresses are shared
clone() - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Shallow clone: all endpoints will be shared across instances
close() - Method in class org.apache.hadoop.registry.cli.RegistryCli: Close the object by stopping the registry.
componentListPath(String, String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Create a path for listing components under a service
componentPath(String, String, String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Create the path to a service record for a component
CONTAINER - Static variable in interface org.apache.hadoop.registry.client.types.yarn.PersistencePolicies: Remove when the YARN container in the ID field finishes: "container"
convertUsername(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Convert the username to that which can be used for registry entries.
CREATE - Static variable in interface org.apache.hadoop.registry.client.api.BindFlags: Create the entry..
createACLForUser(UserGroupInformation, int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Create an ACL For a user.
createACLfromUsername(String, int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Given a user name (short or long), create a SASL ACL
createAnonymousInstance(Configuration) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory: Create and initialize an anonymous read/write registry operations instance.
createAuthenticatedInstance(Configuration, String, String) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory: Create and initialize an operations instance authenticated with write access via an id:password pair.
createDirAsync(String, List<ACL>, boolean) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Asynchronous operation to create a directory
createEnsembleProvider() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create the ensemble provider for this registry, by invoking RegistryBindingSource.supplyBindingInformation() on the provider stored in CuratorService.bindingSource Sets CuratorService.ensembleProvider to that value; sets CuratorService.connectionDescription to the binding info for use in toString and logging;
createFullPath(String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Create a full path from the registry root and the supplied subdir
createFullPath(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create a full path from the registry root and the supplied subdir
createInstance(Configuration) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory: Create and initialize a registry operations instance.
createInstance(String, Configuration) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory: Create and initialize a registry operations instance.
createJAASEntry(String, String, File) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Create a JAAS entry for insertion
createKerberosInstance(Configuration, String) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory: Create and initialize an secure, Kerberos-authenticated instance.
createRootRegistryPaths() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Create the initial registry paths
createSaslACL(UserGroupInformation, int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Given a UGI, create a SASL ACL from it
createSaslACLFromCurrentUser(int) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Create a SASL ACL for the user
CuratorService - Class in org.apache.hadoop.registry.client.impl.zk: This service binds to Zookeeper via Apache Curator.
CuratorService(String, RegistryBindingSource) - Constructor for class org.apache.hadoop.registry.client.impl.zk.CuratorService: Construct the service.
CuratorService(String) - Constructor for class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create an instance using this service as the binding source (i.e.
currentUser() - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Get the current user path formatted for the registry

D

DEFAULT_REGISTRY_CLIENT_JAAS_CONTEXT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: default client-side registry JAAS context: "Client"
DEFAULT_REGISTRY_ENABLED - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Defaut value for enabling the registry in the RM: false
DEFAULT_REGISTRY_SECURE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Default registry security policy: false.
DEFAULT_REGISTRY_SYSTEM_ACCOUNTS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Default system accounts given global access to the registry: "sasl:yarn@, sasl:mapred@, sasl:hdfs@, sasl:hadoop@".
DEFAULT_REGISTRY_USER_ACCOUNTS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Default system acls: "".
DEFAULT_REGISTRY_ZK_QUORUM - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The default zookeeper quorum binding for the registry: "localhost:2181"
DEFAULT_ZK_CONNECTION_TIMEOUT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The default ZK connection timeout: 15000.
DEFAULT_ZK_ENABLE_SASL_CLIENT - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: Default flag for the ZK client: "true".
DEFAULT_ZK_REGISTRY_ROOT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Default root of the yarn registry: "/registry"
DEFAULT_ZK_RETRY_CEILING - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Default limit on retries: 60000.
DEFAULT_ZK_RETRY_INTERVAL - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The default interval between connection retries: 1000.
DEFAULT_ZK_RETRY_TIMES - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The default # of times to retry a ZK connection: 5.
DEFAULT_ZK_SESSION_TIMEOUT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The default ZK session timeout: 60000.
DEFAULT_ZKSERVICE_HOST - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: Default host to serve on -this is localhost as it is the only one guaranteed to be available: "localhost".
delete(String, boolean) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Delete a path.
delete(String, boolean) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
delete(String, boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
DeleteCompletionCallback - Class in org.apache.hadoop.registry.server.services: Curator callback for delete operations completing.
DeleteCompletionCallback() - Constructor for class org.apache.hadoop.registry.server.services.DeleteCompletionCallback
description - Variable in class org.apache.hadoop.registry.client.impl.zk.BindingInformation: Any information that may be useful for diagnostics
description - Variable in class org.apache.hadoop.registry.client.types.ServiceRecord: Description string
digest(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Generate a base-64 encoded digest of the idPasswordPair pair
digest(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Generate a base-64 encoded digest of the idPasswordPair pair
disableZookeeperClientSASL() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Force disable ZK SASL bindings.
dumpPath(boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Return a path dumper instance which can do a full dump of the registry tree in its toString() operation
dumpRegistryRobustly(boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Diagnostics method to dump a registry robustly.

E

E_DATA_TOO_SHORT - Static variable in class org.apache.hadoop.registry.client.binding.JsonSerDeser
E_MISSING_MARKER_STRING - Static variable in class org.apache.hadoop.registry.client.binding.JsonSerDeser
E_NO_DATA - Static variable in class org.apache.hadoop.registry.client.binding.JsonSerDeser
E_NO_KERBEROS - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Error raised when the registry is tagged as secure but this process doesn't have hadoop security enabled.
E_NO_USER_DETERMINED_FOR_ACLS - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: there's no default user to add with permissions, so it would be impossible to create nodes with unrestricted user access
E_UNKNOWN_AUTHENTICATION_MECHANISM - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity
enableZookeeperClientSASL() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Turn ZK SASL on Important:This is JVM-wide
encodeForRegistry(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Perform any formatting for the registry needed to convert non-simple-DNS elements
encodeYarnID(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Perform whatever transforms are needed to get a YARN ID into a DNS-compatible name
Endpoint - Class in org.apache.hadoop.registry.client.types: Description of a single service/component endpoint.
Endpoint() - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Create an empty instance.
Endpoint(Endpoint) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Create an endpoint from another endpoint.
Endpoint(String, String, String, List<Map<String, String>>) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Build an endpoint with a list of addresses
Endpoint(String, String, String) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Build an endpoint with an empty address list
Endpoint(String, String, String, Map<String, String>) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Build an endpoint with a single address entry.
Endpoint(String, String, String, Map<String, String>...) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Build an endpoint with a list of addresses
Endpoint(String, String, URI...) - Constructor for class org.apache.hadoop.registry.client.types.Endpoint: Build an endpoint from a list of URIs; each URI is ASCII-encoded and added to the list of addresses.
ensembleProvider - Variable in class org.apache.hadoop.registry.client.impl.zk.BindingInformation: The Curator Ensemble Provider
equals(Object) - Method in class org.apache.hadoop.registry.client.types.RegistryPathStatus: Equality operator checks size, time and path of the entries.
equals(Object) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord
executor - Variable in class org.apache.hadoop.registry.server.services.RegistryAdminService: Executor for async operations
exists(String) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Probe for a path existing.
exists(String) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
exists(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
external - Variable in class org.apache.hadoop.registry.client.types.ServiceRecord: List of endpoints intended for use to external callers
extractServiceRecords(RegistryOperations, String, Collection<RegistryPathStatus>) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Extract all service records under a list of stat operations...this skips entries that are too short or simply not matching
extractServiceRecords(RegistryOperations, String, Map<String, RegistryPathStatus>) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Extract all service records under a list of stat operations...this non-atomic action skips entries that are too short or simply not matching.
extractServiceRecords(RegistryOperations, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Extract all service records under a list of stat operations...this non-atomic action skips entries that are too short or simply not matching.

F

fromBytes(String, byte[]) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Deserialize from a byte array
fromBytes(String, byte[], String) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Deserialize from a byte array, optionally checking for a marker string.
fromCurrentUser() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.UgiInfo
fromFile(File) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert from a JSON file
fromInstance(T) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: clone by converting to JSON and back again.
fromJson(String) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert from JSON
fromResource(String) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert from a JSON file
FSRegistryOperationsService - Class in org.apache.hadoop.registry.client.impl: Filesystem-based implementation of RegistryOperations.
FSRegistryOperationsService() - Constructor for class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService

G

get(String) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Get the "other" attribute with a specific key
get(String, String) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Get the "other" attribute with a specific key.
getAddressField(Map<String, String>, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Get a specific field from an address -raising an exception if the field is not present
getBindingSource() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Get the registry binding source ...
getClientAcls() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService: Get the aggregate set of ACLs the client should use to create directories
getClientACLs() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Get all ACLs needed for a client to use when writing to the repo.
getConnectionAddress() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Get the connection address
getConnectionString() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Get the connection string.
getCurrentUsernameUnencoded(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Get the current username, using the value of the parameter env_hadoop_username if it is set on an insecure cluster.
getDefaultRealmInJVM() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Get the default kerberos realm —returning "" if there is no realm or other problem
getDiagnostics() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Get the diagnostics info
getEventCount() - Method in class org.apache.hadoop.registry.server.services.DeleteCompletionCallback: Get the number of deletion events
getExecutor() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Get the executor
getExternalEndpoint(String) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Look up an external endpoint
getFs() - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
getInternalEndpoint(String) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Look up an internal endpoint
getKerberosAuthModuleForJVM() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Get the appropriate Kerberos Auth module for JAAS entries for this JVM.
getKerberosRealm() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Get the derived kerberos realm.
getName() - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Get the simple name of the class type to be marshalled
getPurgeOnCompletionPolicy() - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
getRegistrySecurity() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Get the registry security helper
getSystemACLs() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Get the system principals

H

HADOOP_USER_NAME - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: This the Hadoop environment variable which propagates the identity of a user in an insecure cluster
hashCode() - Method in class org.apache.hadoop.registry.client.types.RegistryPathStatus: The hash code is derived from the path.
hashCode() - Method in class org.apache.hadoop.registry.client.types.ServiceRecord
homeDir(String) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Get the path to a user's home dir
homePathForCurrentUser() - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Get the home path of the current user.
homePathForUser(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Buld the user path -switches to the system path if the user is "".
hostnamePortPair(String, int) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a (hostname, port) address pair
hostnamePortPair(InetSocketAddress) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a (hostname, port) address pair

I

idToString(Id) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Convert an ID to a string, stripping out all but the first few characters of any digest auth hash for security reasons
INDENT - Static variable in class org.apache.hadoop.registry.client.impl.zk.ZKPathDumper
inetAddrEndpoint(String, String, String, int) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create an internet address endpoint from a list of URIs
initUserRegistry(String) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Create the home path for a user if it does not exist.
initUserRegistryAsync(String) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Start an async operation to create the home path for a user if it does not exist
internal - Variable in class org.apache.hadoop.registry.client.types.ServiceRecord: List of endpoints for use within an application.
InvalidPathnameException - Exception in org.apache.hadoop.registry.client.exceptions: A path name was invalid.
InvalidPathnameException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.InvalidPathnameException
InvalidPathnameException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.InvalidPathnameException
InvalidRecordException - Exception in org.apache.hadoop.registry.client.exceptions: Raised if an attempt to parse a record failed.
InvalidRecordException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.InvalidRecordException
InvalidRecordException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.InvalidRecordException
ipcEndpoint(String, InetSocketAddress) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create an IPC endpoint
isClientSASLEnabled() - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Is the system property enabling the SASL client set?
isSecure() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Flag to indicate whether or not the registry is secure.
isSecureRegistry() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Flag to indicate the cluster is secure
isValid(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Check for an id:password tuple being valid.

J

join(String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Join two paths, guaranteeing that there will not be exactly one separator between the two, and exactly one at the front of the path.
JsonSerDeser<T> - Class in org.apache.hadoop.registry.client.binding: Support for marshalling objects to and from JSON.
JsonSerDeser(Class<T>) - Constructor for class org.apache.hadoop.registry.client.binding.JsonSerDeser: Create an instance bound to a specific type

K

KEY_REGISTRY_CLIENT_AUTH - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Registry client authentication policy.
KEY_REGISTRY_CLIENT_AUTHENTICATION_ID - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Registry client authentication ID
KEY_REGISTRY_CLIENT_AUTHENTICATION_PASSWORD - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Registry client authentication password.
KEY_REGISTRY_CLIENT_JAAS_CONTEXT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Key to define the JAAS context.
KEY_REGISTRY_ENABLED - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: flag to indicate whether or not the registry should be enabled in the RM: "hadoop.registry.rm.enabled"
KEY_REGISTRY_KERBEROS_REALM - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: The kerberos realm: "hadoop.registry.kerberos.realm".
KEY_REGISTRY_SECURE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Key to set if the registry is secure: "hadoop.registry.secure".
KEY_REGISTRY_SYSTEM_ACCOUNTS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: A comma separated list of Zookeeper ACL identifiers with system access to the registry in a secure cluster: "hadoop.registry.system.accounts".
KEY_REGISTRY_USER_ACCOUNTS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: A comma separated list of Zookeeper ACL identifiers with system access to the registry in a secure cluster: "hadoop.registry.user.accounts".
KEY_REGISTRY_ZK_CONNECTION_TIMEOUT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Zookeeper connection timeout in milliseconds: "hadoop.registry.zk.connection.timeout.ms".
KEY_REGISTRY_ZK_QUORUM - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: List of hostname:port pairs defining the zookeeper quorum binding for the registry "hadoop.registry.zk.quorum"
KEY_REGISTRY_ZK_RETRY_CEILING - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Zookeeper retry limit in milliseconds, during exponential backoff: "hadoop.registry.zk.retry.ceiling.ms".
KEY_REGISTRY_ZK_RETRY_INTERVAL - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Zookeeper connect interval in milliseconds: "hadoop.registry.zk.retry.interval.ms".
KEY_REGISTRY_ZK_RETRY_TIMES - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Zookeeper connection retry count before failing: "hadoop.registry.zk.retry.times".
KEY_REGISTRY_ZK_ROOT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Root path in the ZK tree for the registry: "hadoop.registry.zk.root"
KEY_REGISTRY_ZK_SESSION_TIMEOUT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Zookeeper session timeout in milliseconds: "hadoop.registry.zk.session.timeout.ms"
KEY_REGISTRY_ZKSERVICE_JAAS_CONTEXT - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: Key to define the JAAS context for the ZK service: "hadoop.registry.zk.service.service.jaas.context".
KEY_ZKSERVICE_ALLOW_FAILED_SASL_CLIENTS - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: Should failed SASL clients be allowed: "hadoop.registry.zk.service.allow.failed.sasl.clients"? Default is the ZK default: true
KEY_ZKSERVICE_DIR - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: Directory containing data: "hadoop.registry.zk.service.dir"
KEY_ZKSERVICE_HOST - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: host to register on: "hadoop.registry.zk.service.host".
KEY_ZKSERVICE_PORT - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: port; 0 or below means "any": "hadoop.registry.zk.service.port"
KEY_ZKSERVICE_TICK_TIME - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys: ZK servertick time: "hadoop.registry.zk.service.ticktime"

L

lastPathEntry(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Get the last entry in a path; for an empty path returns "".
list(String) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: List all entries under a registry path, returning the relative names of the entries.
list(String) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
list(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
listServiceRecords(RegistryOperations, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: List service records directly under a path
load(FileSystem, Path) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Load from a Hadoop filesystem
logCurrentHadoopUser() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Log details about the current Hadoop user at INFO.
ls(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli

M

main(String[]) - Static method in class org.apache.hadoop.registry.cli.RegistryCli
map(String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a single entry map
maybeCreate(String, CreateMode, List<ACL>, boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create a path if it does not exist.
MicroZookeeperService - Class in org.apache.hadoop.registry.server.services: This is a small, localhost Zookeeper service instance that is contained in a YARN service...it's been derived from Apache Twill.
MicroZookeeperService(String) - Constructor for class org.apache.hadoop.registry.server.services.MicroZookeeperService: Create an instance
MicroZookeeperServiceKeys - Interface in org.apache.hadoop.registry.server.services: Service keys for configuring the MicroZookeeperService.
mknode(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
mknode(String, boolean) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Create a path.
mknode(String, boolean) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
mknode(String, boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService

N

NoChildrenForEphemeralsException - Exception in org.apache.hadoop.registry.client.exceptions: This is a manifestation of the Zookeeper restrictions about what nodes may act as parents.
NoChildrenForEphemeralsException(String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoChildrenForEphemeralsException
NoChildrenForEphemeralsException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoChildrenForEphemeralsException
NoChildrenForEphemeralsException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoChildrenForEphemeralsException
NoPathPermissionsException - Exception in org.apache.hadoop.registry.client.exceptions: Raised on path permission exceptions.
NoPathPermissionsException(String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoPathPermissionsException
NoPathPermissionsException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoPathPermissionsException
NoPathPermissionsException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoPathPermissionsException
NoPathPermissionsException(String, PathIOException) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoPathPermissionsException
NoRecordException - Exception in org.apache.hadoop.registry.client.exceptions: Raised if there is no ServiceRecord resolved at the end of the specified path.
NoRecordException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoRecordException
NoRecordException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.NoRecordException

O

onAMContainerFinished(ContainerId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Actions to take when the AM container is completed
onApplicationAttemptAdded(ApplicationAttemptId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
onApplicationAttemptRegistered(ApplicationAttemptId, String, int, String) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
onApplicationAttemptUnregistered(ApplicationAttemptId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Actions to take when an application attempt is completed
onApplicationCompleted(ApplicationId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Actions to take when an application is completed
onApplicationLaunched(ApplicationId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
onApplicationMasterRegistered(ApplicationAttemptId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Actions to take as an AM registers itself with the RM.
onContainerFinished(ContainerId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Actions to take when the AM container is completed
onStateStoreEvent(ApplicationId, String) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: This is the event where the user is known, so the user directory can be created
operationFailure(String, String, Exception) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create an IOE when an operation fails
operationFailure(String, String, Exception, List<ACL>) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create an IOE when an operation fails
org.apache.hadoop.registry.cli - package org.apache.hadoop.registry.cli
org.apache.hadoop.registry.client.api - package org.apache.hadoop.registry.client.api: YARN Registry Client API.
org.apache.hadoop.registry.client.binding - package org.apache.hadoop.registry.client.binding: Registry binding utility classes.
org.apache.hadoop.registry.client.exceptions - package org.apache.hadoop.registry.client.exceptions: Registry Service Exceptions
org.apache.hadoop.registry.client.impl - package org.apache.hadoop.registry.client.impl: Registry client services
org.apache.hadoop.registry.client.impl.zk - package org.apache.hadoop.registry.client.impl.zk: Core Zookeeper support.
org.apache.hadoop.registry.client.types - package org.apache.hadoop.registry.client.types: This package contains all the data types which can be saved to the registry and/or marshalled to and from JSON.
org.apache.hadoop.registry.client.types.yarn - package org.apache.hadoop.registry.client.types.yarn
org.apache.hadoop.registry.server - package org.apache.hadoop.registry.server: Server-side classes for the registry
org.apache.hadoop.registry.server.integration - package org.apache.hadoop.registry.server.integration: This package contains the classes which integrate with the YARN resource manager.
org.apache.hadoop.registry.server.services - package org.apache.hadoop.registry.server.services: Basic services for the YARN registry The RegistryAdminService extends the shared Yarn Registry client with registry setup and (potentially asynchronous) administrative actions.
OVERWRITE - Static variable in interface org.apache.hadoop.registry.client.api.BindFlags: The entry should be created even if an existing entry is there.

P

parentOf(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Get the parent of a path
parse(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Parse a string down to an ID, adding a realm if needed
parseACLs(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Parse an ACL list.
path - Variable in class org.apache.hadoop.registry.client.types.RegistryPathStatus: Short path in the registry to this entry
PATH_SYSTEM_SERVICES - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: path to system services off the root : "/services/".
PATH_USER_SERVICES - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: path to system services under a user's home path : "/services/".
PATH_USERS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: path to users off the root: "/users/".
PERMANENT - Static variable in interface org.apache.hadoop.registry.client.types.yarn.PersistencePolicies: The record persists until removed manually: "permanent".
PERMISSIONS_REGISTRY_READERS - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: Permissions for readers: 1.
PERMISSIONS_REGISTRY_SYSTEM_SERVICES - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: Permissions for system services: 31
PERMISSIONS_REGISTRY_USER_ROOT - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: Permissions for a user's root entry: 15.
PersistencePolicies - Interface in org.apache.hadoop.registry.client.types.yarn: Persistence policies for ServiceRecord
processResult(CuratorFramework, CuratorEvent) - Method in class org.apache.hadoop.registry.server.services.DeleteCompletionCallback
PROP_ZK_ALLOW_FAILED_SASL_CLIENTS - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: should the ZK Server Allow failed SASL clients: "zookeeper.allowSaslFailedClients".
PROP_ZK_ENABLE_SASL_CLIENT - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: Enable SASL secure clients: "zookeeper.sasl.client".
PROP_ZK_KINIT_PATH - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: Path to a kinit binary: "zookeeper.kinit".
PROP_ZK_SASL_CLIENT_CONTEXT - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: System property for the JAAS client context : "zookeeper.sasl.clientconfig".
PROP_ZK_SASL_CLIENT_USERNAME - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: The SASL client username: "zookeeper.sasl.client.username".
PROP_ZK_SERVER_MAINTAIN_CONNECTION_DESPITE_SASL_FAILURE - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: Should ZK Server allow failed SASL clients to downgrade to classic authentication on a SASL auth failure: "zookeeper.maintain_connection_despite_sasl_failure".
PROP_ZK_SERVER_REALM - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: Kerberos realm of the server: "zookeeper.server.realm".
PROP_ZK_SERVER_SASL_CONTEXT - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: The SASL Server context, referring to a context in the JVM's JAAS context file: "zookeeper.sasl.serverconfig"
PROTOCOL_FILESYSTEM - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Addresses are URIs of Hadoop Filesystem paths: "hadoop/filesystem".
PROTOCOL_HADOOP_IPC - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Hadoop IPC, "classic" or protobuf : "hadoop/IPC".
PROTOCOL_IIOP - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Corba IIOP: "IIOP".
PROTOCOL_REST - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: REST: "REST".
PROTOCOL_RMI - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Java RMI: "RMI".
PROTOCOL_SUN_RPC - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: SunOS RPC, as used by NFS and similar: "sunrpc".
PROTOCOL_TCP - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Custom TCP protocol: "tcp".
PROTOCOL_THRIFT - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Thrift-based protocols: "thrift".
PROTOCOL_UDP - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Custom UPC-based protocol : "udp".
PROTOCOL_UNKNOWN - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Default value —the protocol is unknown : """"
PROTOCOL_WEBUI - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Web page: "webui".
PROTOCOL_WSAPI - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: Web Services: "WS-*".
PROTOCOL_ZOOKEEPER_BINDING - Static variable in interface org.apache.hadoop.registry.client.types.ProtocolTypes: A zookeeper binding: "zookeeper".
protocolType - Variable in class org.apache.hadoop.registry.client.types.Endpoint: Protocol type.
ProtocolTypes - Interface in org.apache.hadoop.registry.client.types: some common protocol types
purge(String, RegistryAdminService.NodeSelector, RegistryAdminService.PurgePolicy, BackgroundCallback) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Recursive operation to purge all matching records under a base path.
purgeAppAttemptRecords(ApplicationAttemptId) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: remove all application attempt entries
purgeRecordsAsync(String, String, String) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Queue an async operation to purge all matching records under a base path.
purgeRecordsAsync(String, String, String, RegistryAdminService.PurgePolicy, BackgroundCallback) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Queue an async operation to purge all matching records under a base path.

R

RECORD_TYPE - Static variable in class org.apache.hadoop.registry.client.types.ServiceRecord: A type string which MUST be in the serialized json.
REGISTRY_CLIENT_AUTH_ANONYMOUS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: No authentication; client is anonymous
REGISTRY_CLIENT_AUTH_DIGEST - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Username/password is the authentication mechanism.
REGISTRY_CLIENT_AUTH_KERBEROS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Registry client uses Kerberos: authentication is automatic from logged in user
REGISTRY_PREFIX - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: prefix for registry configuration options: "hadoop.registry.".
RegistryAdminService - Class in org.apache.hadoop.registry.server.services: Administrator service for the registry.
RegistryAdminService(String) - Constructor for class org.apache.hadoop.registry.server.services.RegistryAdminService: Construct an instance of the service
RegistryAdminService(String, RegistryBindingSource) - Constructor for class org.apache.hadoop.registry.server.services.RegistryAdminService: construct an instance of the service, using the specified binding source to bond to ZK
RegistryAdminService.AsyncPurge - Class in org.apache.hadoop.registry.server.services: An async registry purge action taking a selector which decides what to delete
RegistryAdminService.AsyncPurge(String, RegistryAdminService.NodeSelector, RegistryAdminService.PurgePolicy, BackgroundCallback) - Constructor for class org.apache.hadoop.registry.server.services.RegistryAdminService.AsyncPurge
RegistryAdminService.NodeSelector - Interface in org.apache.hadoop.registry.server.services: Comparator used for purge logic
RegistryAdminService.PurgePolicy - Enum in org.apache.hadoop.registry.server.services: Policy to purge entries
RegistryBindingSource - Interface in org.apache.hadoop.registry.client.impl.zk: Interface which can be implemented by a registry binding source
RegistryCli - Class in org.apache.hadoop.registry.cli: Command line for registry operations.
RegistryCli(PrintStream, PrintStream) - Constructor for class org.apache.hadoop.registry.cli.RegistryCli
RegistryCli(RegistryOperations, Configuration, PrintStream, PrintStream) - Constructor for class org.apache.hadoop.registry.cli.RegistryCli
RegistryConstants - Interface in org.apache.hadoop.registry.client.api: Constants for the registry, including configuration keys and default values.
RegistryInternalConstants - Interface in org.apache.hadoop.registry.client.impl.zk: Internal constants for the registry.
RegistryIOException - Exception in org.apache.hadoop.registry.client.exceptions: Base exception for registry operations.
RegistryIOException(String, PathIOException) - Constructor for exception org.apache.hadoop.registry.client.exceptions.RegistryIOException: Build an exception from any other Path IO Exception.
RegistryIOException(String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.RegistryIOException
RegistryIOException(String, String) - Constructor for exception org.apache.hadoop.registry.client.exceptions.RegistryIOException
RegistryIOException(String, String, Throwable) - Constructor for exception org.apache.hadoop.registry.client.exceptions.RegistryIOException
RegistryOperations - Interface in org.apache.hadoop.registry.client.api: Registry Operations
RegistryOperationsClient - Class in org.apache.hadoop.registry.client.impl: This is the client service for applications to work with the registry.
RegistryOperationsClient(String) - Constructor for class org.apache.hadoop.registry.client.impl.RegistryOperationsClient
RegistryOperationsClient(String, RegistryBindingSource) - Constructor for class org.apache.hadoop.registry.client.impl.RegistryOperationsClient
RegistryOperationsFactory - Class in org.apache.hadoop.registry.client.api: A factory for registry operation service instances.
RegistryOperationsService - Class in org.apache.hadoop.registry.client.impl.zk: The Registry operations service.
RegistryOperationsService(String) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
RegistryOperationsService() - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
RegistryOperationsService(String, RegistryBindingSource) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
RegistryPathStatus - Class in org.apache.hadoop.registry.client.types: Output of a RegistryOperations.stat() call
RegistryPathStatus(String, long, long, int) - Constructor for class org.apache.hadoop.registry.client.types.RegistryPathStatus: Construct an instance
RegistryPathUtils - Class in org.apache.hadoop.registry.client.binding: Basic operations on paths: manipulating them and creating and validating path elements.
RegistryPathUtils() - Constructor for class org.apache.hadoop.registry.client.binding.RegistryPathUtils
RegistrySecurity - Class in org.apache.hadoop.registry.client.impl.zk: Implement the registry security ...
RegistrySecurity(String) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Create an instance
RegistrySecurity.AclListInfo - Class in org.apache.hadoop.registry.client.impl.zk: on-demand stringifier for a list of ACLs
RegistrySecurity.AclListInfo(List<ACL>) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.AclListInfo
RegistrySecurity.UgiInfo - Class in org.apache.hadoop.registry.client.impl.zk: On demand string-ifier for UGI with extra details
RegistrySecurity.UgiInfo(UserGroupInformation) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.UgiInfo
RegistryTypeUtils - Class in org.apache.hadoop.registry.client.binding: Static methods to work with registry types —primarily endpoints and the list representation of addresses.
RegistryTypeUtils() - Constructor for class org.apache.hadoop.registry.client.binding.RegistryTypeUtils
RegistryUtils - Class in org.apache.hadoop.registry.client.binding: Utility methods for working with a registry.
RegistryUtils() - Constructor for class org.apache.hadoop.registry.client.binding.RegistryUtils
RegistryUtils.ServiceRecordMarshal - Class in org.apache.hadoop.registry.client.binding: Static instance of service record marshalling
RegistryUtils.ServiceRecordMarshal() - Constructor for class org.apache.hadoop.registry.client.binding.RegistryUtils.ServiceRecordMarshal
removeService(Service) - Method in class org.apache.hadoop.registry.server.services.AddingCompositeService
requireAddressType(String, Endpoint) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Require a specific address type on an endpoint
resetDigestACLs() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Reset the digest ACL list
resolve(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
resolve(String) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Resolve the record at a path
resolve(String) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
resolve(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
restEndpoint(String, URI...) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a REST endpoint from a list of URIs
retrieveAddressesUriType(Endpoint) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Get a single URI endpoint
retrieveAddressURLs(Endpoint) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Get the address URLs.
rm(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
RMRegistryOperationsService - Class in org.apache.hadoop.registry.server.integration: Handle RM events by updating the registry
RMRegistryOperationsService(String) - Constructor for class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
RMRegistryOperationsService(String, RegistryBindingSource) - Constructor for class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
run(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli

S

SASLAUTHENTICATION_PROVIDER - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: Name of the SASL auth provider which has to be added to ZK server to enable sasl: auth patterns: "org.apache.zookeeper.server.auth.SASLAuthenticationProvider".
save(FileSystem, Path, T, boolean) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Save a cluster description to a hadoop filesystem
SCHEME_DIGEST - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: ID scheme for digest auth: "digest".
SCHEME_SASL - Static variable in interface org.apache.hadoop.registry.client.impl.zk.ZookeeperConfigOptions: ID scheme for SASL: "sasl".
SelectByYarnPersistence - Class in org.apache.hadoop.registry.server.integration: Select an entry by the YARN persistence policy
SelectByYarnPersistence(String, String) - Constructor for class org.apache.hadoop.registry.server.integration.SelectByYarnPersistence
serviceclassPath(String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Create a service classpath
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Init the service.
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Init the service: this sets up security based on the configuration
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService: Extend the parent service initialization by verifying that the service knows —in a secure cluster— the realm in which it is executing.
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Initialize the service, including choosing a path for the data
serviceInit(Configuration) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Init operation sets up the system ACLs.
servicePath(String, String, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: Create a path to a service under a user and service class
ServiceRecord - Class in org.apache.hadoop.registry.client.types: JSON-marshallable description of a single component.
ServiceRecord() - Constructor for class org.apache.hadoop.registry.client.types.ServiceRecord: Create a service record with no ID, description or registration time.
ServiceRecord(ServiceRecord) - Constructor for class org.apache.hadoop.registry.client.types.ServiceRecord: Deep cloning constructor
serviceStart() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Start the service.
serviceStart() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: Startup: start ZK.
serviceStart() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Start the service, including creating base directories with permissions
serviceStop() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Close the ZK connection if it is open
serviceStop() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: When the service is stopped, it deletes the data directory and its contents
serviceStop() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Stop the service: halt the executor.
set(String, Object) - Method in class org.apache.hadoop.registry.client.types.ServiceRecord: Handle unknown attributes by storing them in the ServiceRecord.attributes map
setPurgeOnCompletionPolicy(RegistryAdminService.PurgePolicy) - Method in class org.apache.hadoop.registry.server.integration.RMRegistryOperationsService
setupSecurity() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService: set up security.
setZKSaslClientProperties(String, String) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Set the client properties.
shouldSelect(String, RegistryPathStatus, ServiceRecord) - Method in class org.apache.hadoop.registry.server.integration.SelectByYarnPersistence
shouldSelect(String, RegistryPathStatus, ServiceRecord) - Method in interface org.apache.hadoop.registry.server.services.RegistryAdminService.NodeSelector
size - Variable in class org.apache.hadoop.registry.client.types.RegistryPathStatus: Entry size in bytes, as returned by the storage infrastructure.
split(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: split a path into elements, stripping empty elements
splitAclPairs(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Split up a list of the form sasl:mapred@,digest:5f55d66, sasl@yarn@EXAMPLE.COM into a list of possible ACL values, trimming as needed The supplied realm is added to entries where the string begins "sasl:" the string ends with "@" No attempt is made to validate any of the acl patterns.
stat(String) - Method in interface org.apache.hadoop.registry.client.api.RegistryOperations: Get the status of a path
stat(String) - Method in class org.apache.hadoop.registry.client.impl.FSRegistryOperationsService
stat(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService
statChildren(RegistryOperations, String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils: List children of a directory and retrieve their RegistryPathStatus values.
stopExecutor() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Stop the executor if it is not null.
submit(Callable<V>) - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Submit a callable
SUBPATH_COMPONENTS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: path under a service record to point to components of that service: "/components/".
supplyBindingInformation() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Supply the binding information.
supplyBindingInformation() - Method in interface org.apache.hadoop.registry.client.impl.zk.RegistryBindingSource: Supply the binding information for this registry
supplyBindingInformation() - Method in class org.apache.hadoop.registry.server.services.MicroZookeeperService
syserr - Variable in class org.apache.hadoop.registry.cli.RegistryCli
sysout - Variable in class org.apache.hadoop.registry.cli.RegistryCli

T

time - Variable in class org.apache.hadoop.registry.client.types.RegistryPathStatus: Timestamp
toBytes(T) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert JSON To bytes
toDigestId(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Given a digest, create an ID from it
toDigestId(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Create a Digest ID from an id:pass pair
toJson(T) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert an instance to a JSON string
toString(T) - Method in class org.apache.hadoop.registry.client.binding.JsonSerDeser: Convert an instance to a string form for output.
toString() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService
toString() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.AclListInfo
toString() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.UgiInfo
toString() - Method in class org.apache.hadoop.registry.client.impl.zk.ZKPathDumper: Trigger the recursive registry dump.
toString() - Method in class org.apache.hadoop.registry.client.types.Endpoint
toString() - Method in class org.apache.hadoop.registry.client.types.RegistryPathStatus
toString() - Method in class org.apache.hadoop.registry.client.types.ServiceRecord
toString() - Method in class org.apache.hadoop.registry.server.integration.SelectByYarnPersistence
toString() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService.AsyncPurge
type - Variable in class org.apache.hadoop.registry.client.types.ServiceRecord: The type field.

U

uri(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a URI
urlEndpoint(String, String, URI...) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a URL endpoint from a list of URIs
USER_HOMEDIR_ACL_PERMISSIONS - Static variable in class org.apache.hadoop.registry.server.services.RegistryAdminService: The ACL permissions for the user's homedir ACL.

V

VALID_PATH_ENTRY_PATTERN - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: Pattern of a single entry in the registry path.
validate() - Method in class org.apache.hadoop.registry.client.types.Endpoint: Validate the record by checking for null fields and other invalid conditions
validateContext(String) - Static method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: Resolve the context of an entry.
validateElementsAsDNS(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Validate ZK path as valid for a DNS hostname.
validateEndpoint(String, Endpoint) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Validate the endpoint by checking for null fields and other invalid conditions
validatePath(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistryOperationsService: Validate a path
validateServiceRecord(String, ServiceRecord) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Validate the record by checking for null fields and other invalid conditions
validateZKPath(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils: Validate ZK path with the path itself included in the exception text
valueOf(String) - Static method in enum org.apache.hadoop.registry.server.services.RegistryAdminService.PurgePolicy: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.hadoop.registry.server.services.RegistryAdminService.PurgePolicy: Returns an array containing the constants of this enum type, in the order they are declared.
verifyRealmValidity() - Method in class org.apache.hadoop.registry.server.services.RegistryAdminService: Method to validate the validity of the kerberos realm.

W

webEndpoint(String, URI...) - Static method in class org.apache.hadoop.registry.client.binding.RegistryTypeUtils: Create a Web UI endpoint from a list of URIs
WorldReadWriteACL - Static variable in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity: An ACL list containing the RegistrySecurity.ALL_READWRITE_ACCESS entry.

Y

YARN_ID - Static variable in class org.apache.hadoop.registry.client.types.yarn.YarnRegistryAttributes: ID.
YARN_PERSISTENCE - Static variable in class org.apache.hadoop.registry.client.types.yarn.YarnRegistryAttributes
YarnRegistryAttributes - Class in org.apache.hadoop.registry.client.types.yarn: YARN specific attributes in the registry
YarnRegistryAttributes() - Constructor for class org.apache.hadoop.registry.client.types.yarn.YarnRegistryAttributes

Z

ZK_PREFIX - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants: Prefix for zookeeper-specific options: "hadoop.registry.zk."
zkCreate(String, CreateMode, byte[], List<ACL>) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create a path with given data.
zkDelete(String, boolean, BackgroundCallback) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Delete a directory/directory tree.
zkGetACLS(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Get the ACLs of a path
zkList(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: List all children of a path
zkMkParentPath(String, List<ACL>) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Recursively make a path
zkMkPath(String, CreateMode, boolean, List<ACL>) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create a directory.
ZKPathDumper - Class in org.apache.hadoop.registry.client.impl.zk: This class dumps a registry tree to a string.
ZKPathDumper(CuratorFramework, String, boolean) - Constructor for class org.apache.hadoop.registry.client.impl.zk.ZKPathDumper: Create a path dumper -but do not dump the path until asked
zkPathExists(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Probe for a path existing
zkPathMustExist(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Verify a path exists
zkRead(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Read data on a path
ZKSERVICE_PREFIX - Static variable in interface org.apache.hadoop.registry.server.services.MicroZookeeperServiceKeys
zkSet(String, CreateMode, byte[], List<ACL>, boolean) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Create or update an entry
zkStat(String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Stat the file
zkUpdate(String, byte[]) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService: Update the data for a path
ZOOKEEPER_AUTH_PROVIDER - Static variable in interface org.apache.hadoop.registry.client.impl.zk.RegistryInternalConstants: String to use as the prefix when declaring a new auth provider: "zookeeper.authProvider".
ZookeeperConfigOptions - Interface in org.apache.hadoop.registry.client.impl.zk: Configuration options which are internal to Zookeeper, as well as some other ZK constants

A B C D E F G H I J K L M N O P R S T U V W Y Z