Package | Description |
---|---|
org.apache.hadoop.registry.cli | |
org.apache.hadoop.registry.client.api |
YARN Registry Client API.
|
org.apache.hadoop.registry.client.binding |
Registry binding utility classes.
|
org.apache.hadoop.registry.client.impl |
Registry client services
|
org.apache.hadoop.registry.client.impl.zk |
Core Zookeeper support.
|
org.apache.hadoop.registry.server.integration |
This package contains the classes which integrate with the YARN resource
manager.
|
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. |
Constructor and Description |
---|
RegistryCli(RegistryOperations reg,
org.apache.hadoop.conf.Configuration conf,
PrintStream sysout,
PrintStream syserr) |
Modifier and Type | Method and Description |
---|---|
static RegistryOperations |
RegistryOperationsFactory.createAnonymousInstance(org.apache.hadoop.conf.Configuration conf)
Create and initialize an anonymous read/write registry operations instance.
|
static RegistryOperations |
RegistryOperationsFactory.createAuthenticatedInstance(org.apache.hadoop.conf.Configuration conf,
String id,
String password)
Create and initialize an operations instance authenticated with write
access via an
id:password pair. |
static RegistryOperations |
RegistryOperationsFactory.createInstance(org.apache.hadoop.conf.Configuration conf)
Create and initialize a registry operations instance.
|
static RegistryOperations |
RegistryOperationsFactory.createInstance(String name,
org.apache.hadoop.conf.Configuration conf)
Create and initialize a registry operations instance.
|
static RegistryOperations |
RegistryOperationsFactory.createKerberosInstance(org.apache.hadoop.conf.Configuration conf,
String jaasContext)
Create and initialize an secure, Kerberos-authenticated instance.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,ServiceRecord> |
RegistryUtils.extractServiceRecords(RegistryOperations operations,
String parentpath)
Extract all service records under a list of stat operations...this
non-atomic action skips entries that are too short or simply not matching.
|
static Map<String,ServiceRecord> |
RegistryUtils.extractServiceRecords(RegistryOperations operations,
String parentpath,
Collection<RegistryPathStatus> stats)
Extract all service records under a list of stat operations...this
skips entries that are too short or simply not matching
|
static Map<String,ServiceRecord> |
RegistryUtils.extractServiceRecords(RegistryOperations operations,
String parentpath,
Map<String,RegistryPathStatus> stats)
Extract all service records under a list of stat operations...this
non-atomic action skips entries that are too short or simply not matching.
|
static Map<String,ServiceRecord> |
RegistryUtils.listServiceRecords(RegistryOperations registryOperations,
String path)
List service records directly under a path
|
static Map<String,RegistryPathStatus> |
RegistryUtils.statChildren(RegistryOperations registryOperations,
String path)
List children of a directory and retrieve their
RegistryPathStatus values. |
Modifier and Type | Class and Description |
---|---|
class |
RegistryOperationsClient
This is the client service for applications to work with the registry.
|
Modifier and Type | Class and Description |
---|---|
class |
RegistryOperationsService
The Registry operations service.
|
Modifier and Type | Class and Description |
---|---|
class |
RMRegistryOperationsService
Handle RM events by updating the registry
|
Modifier and Type | Class and Description |
---|---|
class |
RegistryAdminService
Administrator service for the registry.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.