Package | Description |
---|---|
org.apache.hadoop.hbase |
Modifier and Type | Field and Description |
---|---|
private static Map<ClusterManager.ServiceType,RESTApiClusterManager.Service> |
RESTApiClusterManager.roleServiceType |
private static Set<ClusterManager.ServiceType> |
CoprocClusterManager.supportedServices |
Modifier and Type | Method and Description |
---|---|
static ClusterManager.ServiceType |
ClusterManager.ServiceType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ClusterManager.ServiceType[] |
ClusterManager.ServiceType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
private static Map<ClusterManager.ServiceType,RESTApiClusterManager.Service> |
RESTApiClusterManager.buildRoleServiceTypeMap() |
private static Set<ClusterManager.ServiceType> |
CoprocClusterManager.buildSupportedServicesSet() |
Modifier and Type | Method and Description |
---|---|
private void |
ZNodeClusterManager.createOpCommand(String hostname,
ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
private void |
HBaseClusterManager.exec(String hostname,
ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
protected org.apache.hadoop.hbase.util.Pair<Integer,String> |
HBaseClusterManager.exec(String hostname,
ClusterManager.ServiceType service,
String... cmd)
Execute the given command on the host using SSH
|
protected org.apache.hadoop.hbase.util.Pair<Integer,String> |
CoprocClusterManager.exec(String hostname,
ClusterManager.ServiceType service,
String... cmd) |
private org.apache.hadoop.hbase.util.Pair<Integer,String> |
HBaseClusterManager.execWithRetries(String hostname,
ClusterManager.ServiceType service,
String... cmd) |
protected String |
HBaseClusterManager.CommandProvider.findPidCommand(ClusterManager.ServiceType service) |
protected String |
HBaseClusterManager.ZookeeperShellCommandProvider.findPidCommand(ClusterManager.ServiceType service) |
abstract String |
HBaseClusterManager.CommandProvider.getCommand(ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
String |
HBaseClusterManager.HBaseShellCommandProvider.getCommand(ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
String |
HBaseClusterManager.HadoopShellCommandProvider.getCommand(ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
String |
HBaseClusterManager.ZookeeperShellCommandProvider.getCommand(ClusterManager.ServiceType service,
HBaseClusterManager.CommandProvider.Operation op) |
protected HBaseClusterManager.CommandProvider |
HBaseClusterManager.getCommandProvider(ClusterManager.ServiceType service) |
protected HBaseClusterManager.CommandProvider |
ZNodeClusterManager.getCommandProvider(ClusterManager.ServiceType service) |
private RESTApiClusterManager.RoleState |
RESTApiClusterManager.getRoleState(ClusterManager.ServiceType service,
String hostname) |
protected String |
HBaseClusterManager.getServiceUser(ClusterManager.ServiceType service) |
boolean |
HBaseClusterManager.isRunning(ClusterManager.ServiceType service,
String hostname,
int port) |
boolean |
ClusterManager.isRunning(ClusterManager.ServiceType service,
String hostname,
int port)
Returns whether the service is running on the remote host.
|
boolean |
RESTApiClusterManager.isRunning(ClusterManager.ServiceType service,
String hostname,
int port) |
boolean |
ZNodeClusterManager.isRunning(ClusterManager.ServiceType service,
String hostname,
int port) |
String |
HBaseClusterManager.CommandProvider.isRunningCommand(ClusterManager.ServiceType service) |
void |
HBaseClusterManager.kill(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.kill(ClusterManager.ServiceType service,
String hostname,
int port)
Kills the service running on the given host
|
void |
RESTApiClusterManager.kill(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.kill(ClusterManager.ServiceType service,
String hostname,
int port) |
private void |
RESTApiClusterManager.performClusterManagerCommand(ClusterManager.ServiceType role,
String hostname,
RESTApiClusterManager.RoleCommand command) |
private static void |
TestRESTApiClusterManager.registerHostProperties(String clusterName,
String serviceName,
String hostId,
ClusterManager.ServiceType serviceType,
Map<String,String> properties) |
void |
HBaseClusterManager.restart(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.restart(ClusterManager.ServiceType service,
String hostname,
int port)
Restart the service on the given host
|
void |
RESTApiClusterManager.restart(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.restart(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
HBaseClusterManager.resume(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.resume(ClusterManager.ServiceType service,
String hostname,
int port)
Resumes the services running on the given host
|
void |
RESTApiClusterManager.resume(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.resume(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
HBaseClusterManager.signal(ClusterManager.ServiceType service,
HBaseClusterManager.Signal signal,
String hostname) |
void |
ZNodeClusterManager.signal(ClusterManager.ServiceType service,
String signal,
String hostname) |
String |
HBaseClusterManager.CommandProvider.signalCommand(ClusterManager.ServiceType service,
String signal) |
void |
HBaseClusterManager.start(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.start(ClusterManager.ServiceType service,
String hostname,
int port)
Start the service on the given host
|
void |
RESTApiClusterManager.start(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.start(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
HBaseClusterManager.stop(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.stop(ClusterManager.ServiceType service,
String hostname,
int port)
Stop the service on the given host
|
void |
RESTApiClusterManager.stop(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.stop(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
HBaseClusterManager.suspend(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ClusterManager.suspend(ClusterManager.ServiceType service,
String hostname,
int port)
Suspends the service running on the given host
|
void |
RESTApiClusterManager.suspend(ClusterManager.ServiceType service,
String hostname,
int port) |
void |
ZNodeClusterManager.suspend(ClusterManager.ServiceType service,
String hostname,
int port) |
private static RuntimeException |
CoprocClusterManager.unsupportedServiceType(ClusterManager.ServiceType serviceType) |
private void |
DistributedHBaseCluster.waitForServiceToStart(ClusterManager.ServiceType service,
org.apache.hadoop.hbase.ServerName serverName,
long timeout) |
private void |
DistributedHBaseCluster.waitForServiceToStop(ClusterManager.ServiceType service,
org.apache.hadoop.hbase.ServerName serverName,
long timeout) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.