- 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
-
- 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
-
- 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
- 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_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.
- 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
- 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"
- 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.
- 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
-
- 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.
- 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
-
- 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
-
- 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
-
- 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
-