- AclListInfo(List<ACL>) - Constructor for class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.AclListInfo
-
- 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
- addNIOTCP(InetAddress, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Create the thread (Callable) monitoring the TCP listener.
- addNIOUDP(InetAddress, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Create the thread monitoring the socket for inbound UDP requests.
- addRecord(Record) - Method in class org.apache.hadoop.registry.server.dns.SecureableZone
-
Adds a Record to the Zone.
- 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
-
- addSplitReverseZones(Configuration, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Create the zones based on the zone count.
- 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".
- ApplicationServiceRecordProcessor - Class in org.apache.hadoop.registry.server.dns
-
A processor for generating application DNS records from registry service
records.
- ApplicationServiceRecordProcessor(ServiceRecord, String, String, ZoneSelector) - Constructor for class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application service record processor.
- applySecurityEnvironment(CuratorFrameworkFactory.Builder) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity
-
Apply the security environment to this curator instance.
- AsyncPurge(String, RegistryAdminService.NodeSelector, RegistryAdminService.PurgePolicy, BackgroundCallback) - Constructor for class org.apache.hadoop.registry.server.services.RegistryAdminService.AsyncPurge
-
- 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
-
- call() - Method in class org.apache.hadoop.registry.server.dns.LookupTask
-
- 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.
- close() - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS.CloseableLock
-
- CloseableLock(Lock) - Constructor for class org.apache.hadoop.registry.server.dns.RegistryDNS.CloseableLock
-
- 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"
- CONTAINER - Static variable in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
- ContainerServiceRecordProcessor - Class in org.apache.hadoop.registry.server.dns
-
A processor for generating container DNS records from registry service
records.
- ContainerServiceRecordProcessor(ServiceRecord, String, String, ZoneSelector) - Constructor for class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Create a container service record processor.
- 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..
- create(Name, T) - Method in interface org.apache.hadoop.registry.server.dns.RecordCreatorFactory.RecordCreator
-
- createAAAAInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application AAAA record descriptor.
- createAAAAInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Creates a container AAAA (IPv6) record descriptor.
- 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
- createAInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application A record descriptor.
- createAInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Creates a container A (IPv4) record descriptor.
- 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.
- createClient(String, Configuration) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory
-
- createCNAMEInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application CNAME record descriptor.
- 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
-
- 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.DNSOperationsFactory
-
Create and initialize a DNS operations instance.
- createInstance(String, DNSOperationsFactory.DNSImplementation, Configuration) - Static method in class org.apache.hadoop.registry.client.api.DNSOperationsFactory
-
Create and initialize a registry operations instance.
- 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.
- createKerberosInstance(Configuration, String, String, String) - Static method in class org.apache.hadoop.registry.client.api.RegistryOperationsFactory
-
Create a kerberos registry service client
- createPTRInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Creates a container PTR record descriptor.
- 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
- createSRVInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application SRV record descriptor.
- createTXTInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Create an application TXT record descriptor.
- createTXTInfo(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Create a container TXT record descriptor.
- 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
- DEFAULT_DNS_ENABLED - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Defaut value for enabling the DNS in the Registry: false.
- DEFAULT_DNS_PORT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Default DNS port number.
- DEFAULT_DNS_SPLIT_REVERSE_ZONE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Default value for splitting the reverse zone.
- DEFAULT_DNSSEC_PRIVATE_KEY_FILE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Default DNSSEC private key file path.
- 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, ServiceRecord) - Method in interface org.apache.hadoop.registry.client.api.DNSOperations
-
Delete a service's registered endpoints.
- 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
-
- delete(String, ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Delete the DNS records generated by the provided service record.
- 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
- destroy() - Method in class org.apache.hadoop.registry.server.dns.PrivilegedRegistryDNSStarter
-
- 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.
- DNS_PREFIX - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Prefix for dns-specific options: "hadoop.registry.dns."
- DNSOperations - Interface in org.apache.hadoop.registry.client.api
-
DNS Operations.
- DNSOperationsFactory - Class in org.apache.hadoop.registry.client.api
-
A factory for DNS operation service instances.
- DNSOperationsFactory.DNSImplementation - Enum in org.apache.hadoop.registry.client.api
-
DNS Implementation type.
- 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_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
-
- errorMessage(Message, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Generate an error message based on inbound query.
- 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.
- 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
- getAppConfigurationEntry(String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity.JaasConfiguration
-
- 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.
- getNXTRecord(Record, Zone) - Method in class org.apache.hadoop.registry.server.dns.SecureableZone
-
Return a NXT record appropriate for the query.
- getPath() - Method in class org.apache.hadoop.registry.server.dns.BaseServiceRecordProcessor
-
Return the path associated with the record.
- getRecords(Name, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Requests records for the given resource name.
- getRecordTypes() - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Returns the record types associated with a container service record.
- getRecordTypes() - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Returns the record types associated with a container service record.
- getRecordTypes() - Method in interface org.apache.hadoop.registry.server.dns.ServiceRecordProcessor
-
Return the DNS record types valid for this processor.
- getRegistrySecurity() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService
-
Get the registry security helper.
- getReverseZoneName(Configuration) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Returns the list of reverse lookup zones.
- getReverseZoneNetworkAddress(String, int, int) - Static method in class org.apache.hadoop.registry.server.dns.ReverseZoneUtils
-
Given a baseIp, range and index, return the network address for the
reverse zone.
- getSubnetCountForReverseZones(Configuration) - Static method in class org.apache.hadoop.registry.server.dns.ReverseZoneUtils
-
When splitting the reverse zone, return the number of subnets needed,
given the range and netmask.
- getSystemACLs() - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity
-
Get the system principals
- getUsername(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryPathUtils
-
Return the username found in the ZK path.
- getZoneCount() - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Return the number of zones in the map.
- 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
- IN_ADDR_ARPA - Static variable in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
- 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
- init(DaemonContext) - Method in class org.apache.hadoop.registry.server.dns.PrivilegedRegistryDNSStarter
-
- initializeChannels(Configuration) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
- initTypeToInfoMapping(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ApplicationServiceRecordProcessor
-
Initializes the DNS record type to descriptor mapping based on the
provided service record.
- initTypeToInfoMapping(ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.ContainerServiceRecordProcessor
-
Initializes the DNS record type to descriptor mapping based on the
provided service record.
- initTypeToInfoMapping(ServiceRecord) - Method in interface org.apache.hadoop.registry.server.dns.ServiceRecordProcessor
-
Initialize the mapping between DNS record type and record information
for the given service record.
- 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.
- KEY_DNS_BIND_ADDRESS - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNS bind address.
- KEY_DNS_DOMAIN - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNS domain name key.
- KEY_DNS_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.dns.enabled".
- KEY_DNS_PORT - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNS port number key.
- KEY_DNS_SPLIT_REVERSE_ZONE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Split Reverse Zone.
- KEY_DNS_SPLIT_REVERSE_ZONE_RANGE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Split Reverse Zone IP Range.
- KEY_DNS_TTL - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNS Record TTL.
- KEY_DNS_ZONE_IP_MAX - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Zone subnet IP max.
- KEY_DNS_ZONE_IP_MIN - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Zone subnet IP min.
- KEY_DNS_ZONE_MASK - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Zone subnet mask.
- KEY_DNS_ZONE_SUBNET - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
Zone subnet.
- KEY_DNS_ZONES_DIR - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNS Record TTL.
- KEY_DNSSEC_ENABLED - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNSSEC Enabled?
- KEY_DNSSEC_PRIVATE_KEY_FILE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNSSEC private key file.
- KEY_DNSSEC_PUBLIC_KEY - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
DNSSEC Enabled?
- 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"
- 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/".
- PathListener - Interface in org.apache.hadoop.registry.client.impl.zk
-
- 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
-
- PrivilegedRegistryDNSStarter - Class in org.apache.hadoop.registry.server.dns
-
This class is used to allow the RegistryDNSServer to run on a privileged
port (e.g.
- PrivilegedRegistryDNSStarter() - Constructor for class org.apache.hadoop.registry.server.dns.PrivilegedRegistryDNSStarter
-
- 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.
- RECORD_TYPE - Static variable in class org.apache.hadoop.registry.client.types.ServiceRecord
-
A type string which MUST be in the serialized json.
- RecordCreatorFactory - Class in org.apache.hadoop.registry.server.dns
-
A factory for creating DNS records.
- RecordCreatorFactory.HostPortInfo - Class in org.apache.hadoop.registry.server.dns
-
An object for storing the host and port info used to generate SRV records.
- RecordCreatorFactory.RecordCreator<R extends org.xbill.DNS.Record,T> - Interface in org.apache.hadoop.registry.server.dns
-
A DNS Record creator.
- register(String, ServiceRecord) - Method in interface org.apache.hadoop.registry.client.api.DNSOperations
-
Register a service based on a service record.
- register(String, ServiceRecord) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Register DNS records based on the provided service record.
- registerPathListener(PathListener) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService
-
Registers a listener to path related events.
- registerRecordDescriptor(int, BaseServiceRecordProcessor.RecordDescriptor) - Method in class org.apache.hadoop.registry.server.dns.BaseServiceRecordProcessor
-
Add the DNS record descriptor object to the record type to descriptor
mapping.
- registerRecordDescriptor(int, List<BaseServiceRecordProcessor.RecordDescriptor>) - Method in class org.apache.hadoop.registry.server.dns.BaseServiceRecordProcessor
-
Add the DNS record descriptor objects to the record type to descriptor
mapping.
- 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_CLIENT_AUTH_SIMPLE - Static variable in interface org.apache.hadoop.registry.client.api.RegistryConstants
-
- 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.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.
- RegistryDNS - Class in org.apache.hadoop.registry.server.dns
-
A DNS service reflecting the state of the YARN registry.
- RegistryDNS(String) - Constructor for class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Construct the service.
- RegistryDNS.CloseableLock - Class in org.apache.hadoop.registry.server.dns
-
An implementation allowing for obtaining and releasing a lock.
- RegistryDNSServer - Class in org.apache.hadoop.registry.server.dns
-
A server/service that starts and manages the lifecycle of a DNS registry
instance.
- RegistryDNSServer(String, RegistryDNS) - Constructor for class org.apache.hadoop.registry.server.dns.RegistryDNSServer
-
Creates the DNS server.
- 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.JaasConfiguration - Class in org.apache.hadoop.registry.client.impl.zk
-
Creates a programmatic version of a jaas.conf file.
- RegistrySecurity.UgiInfo - Class in org.apache.hadoop.registry.client.impl.zk
-
On demand string-ifier for UGI with extra details
- 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
-
- registryUser(String) - Static method in class org.apache.hadoop.registry.client.binding.RegistryUtils
-
Convert the given user name formatted for the registry.
- 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
- remove() - Method in interface org.apache.hadoop.registry.client.impl.zk.ListenerHandle
-
- removeRecord(Record) - Method in class org.apache.hadoop.registry.server.dns.SecureableZone
-
Removes a record from the Zone.
- 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.
- reverseIP(String) - Method in class org.apache.hadoop.registry.server.dns.BaseServiceRecordProcessor
-
Reverse the string representation of the input IP address.
- ReverseZoneUtils - Class in org.apache.hadoop.registry.server.dns
-
Utilities for configuring reverse zones.
- rm(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
-
- run(String[]) - Method in class org.apache.hadoop.registry.cli.RegistryCli
-
- 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".
- 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".
- SecureableZone - Class in org.apache.hadoop.registry.server.dns
-
A zone implementation geared to support some DNSSEC functionality.
- SecureableZone(ZoneTransferIn) - Constructor for class org.apache.hadoop.registry.server.dns.SecureableZone
-
Creates a Zone by doing the specified zone transfer.
- SecureableZone(Name, int, String) - Constructor for class org.apache.hadoop.registry.server.dns.SecureableZone
-
Creates a Zone by performing a zone transfer to the specified host.
- SecureableZone(Name, String) - Constructor for class org.apache.hadoop.registry.server.dns.SecureableZone
-
Creates a Zone from the records in the specified master file.
- SecureableZone(Name, Record[]) - Constructor for class org.apache.hadoop.registry.server.dns.SecureableZone
-
Creates a Zone from an array of records.
- 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
-
- serveNIOTCP(ServerSocketChannel, InetAddress, int) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Monitor the TCP socket for inbound requests.
- 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.dns.RegistryDNS
-
Initializes the registry.
- serviceInit(Configuration) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNSServer
-
Initializes the DNS server.
- 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
- ServiceRecordMarshal() - Constructor for class org.apache.hadoop.registry.client.binding.RegistryUtils.ServiceRecordMarshal
-
- ServiceRecordProcessor - Interface in org.apache.hadoop.registry.server.dns
-
Manage the processing of service records in order to create DNS records.
- serviceStart() - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService
-
Start the service.
- serviceStart() - Method in class org.apache.hadoop.registry.server.dns.RegistryDNSServer
-
Starts the server.
- 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.dns.RegistryDNS
-
Stops the registry.
- 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
-
- setDNSSECEnabled(Configuration) - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Set the value of the DNSSEC enabled property.
- setKerberosPrincipalAndKeytab(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.CuratorService
-
- setKerberosPrincipalAndKeytab(String, String) - Method in class org.apache.hadoop.registry.client.impl.zk.RegistrySecurity
-
- setPath(String) - Method in class org.apache.hadoop.registry.server.dns.BaseServiceRecordProcessor
-
Set the path associated with the record.
- setTtl(long) - Static method in class org.apache.hadoop.registry.server.dns.RecordCreatorFactory
-
Set the TTL value for the records created by the factory.
- 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
-
- SHUTDOWN_HOOK_PRIORITY - Static variable in class org.apache.hadoop.registry.server.dns.RegistryDNSServer
-
- 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.
- splitIp(String) - Static method in class org.apache.hadoop.registry.server.dns.ReverseZoneUtils
-
- start() - Method in class org.apache.hadoop.registry.server.dns.PrivilegedRegistryDNSStarter
-
- 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
-
- stop() - Method in class org.apache.hadoop.registry.server.dns.PrivilegedRegistryDNSStarter
-
- stopExecutor() - Method in class org.apache.hadoop.registry.server.dns.RegistryDNS
-
Shuts down the leveraged executor service.
- 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
-
- 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.client.api.DNSOperationsFactory.DNSImplementation
-
Returns the enum constant of this type with the specified name.
- 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.client.api.DNSOperationsFactory.DNSImplementation
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- 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.