Package org.apache.hadoop.hbase

Class ZNodeClusterManager

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.ZNodeClusterManager

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, ClusterManager

@Private
public class ZNodeClusterManager
extends org.apache.hadoop.conf.Configured
implements ClusterManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	ZNodeClusterManager.CmdType

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.ClusterManager

ClusterManager.ServiceType

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final String	SIGCONT
private static final String	SIGKILL
private static final String	SIGSTOP

Constructor Summary

Constructors

Constructor	Description
ZNodeClusterManager()

Method Summary

Modifier and Type	Method	Description
private void	createOpCommand(String hostname, ClusterManager.ServiceType service, HBaseClusterManager.CommandProvider.Operation op)
private String	createZNode(String hostname, String cmd)
protected HBaseClusterManager.CommandProvider	getCommandProvider(ClusterManager.ServiceType service)
private String	getZKQuorumServersStringFromHbaseConfig()
boolean	isRunning(ClusterManager.ServiceType service, String hostname, int port)	Returns whether the service is running on the remote host.
void	kill(ClusterManager.ServiceType service, String hostname, int port)	Kills the service running on the given host
void	restart(ClusterManager.ServiceType service, String hostname, int port)	Restart the service on the given host
void	resume(ClusterManager.ServiceType service, String hostname, int port)	Resumes the services running on the given host
void	signal(ClusterManager.ServiceType service, String signal, String hostname)
void	start(ClusterManager.ServiceType service, String hostname, int port)	Start the service on the given host
void	stop(ClusterManager.ServiceType service, String hostname, int port)	Stop the service on the given host
void	suspend(ClusterManager.ServiceType service, String hostname, int port)	Suspends the service running on the given host

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Details

LOG

private static final org.slf4j.Logger LOG

SIGKILL

private static final String SIGKILL

See Also:

• Constant Field Values

SIGSTOP

private static final String SIGSTOP

See Also:

• Constant Field Values

SIGCONT

private static final String SIGCONT

See Also:

• Constant Field Values

Constructor Details

ZNodeClusterManager

public ZNodeClusterManager()

Method Details

getZKQuorumServersStringFromHbaseConfig

private String getZKQuorumServersStringFromHbaseConfig()

createZNode

private String createZNode(String hostname,
 String cmd)
                    throws IOException

Throws:

IOException

getCommandProvider

protected HBaseClusterManager.CommandProvider getCommandProvider(ClusterManager.ServiceType service)
                                                          throws IOException

Throws:

IOException

signal

public void signal(ClusterManager.ServiceType service,
 String signal,
 String hostname)
            throws IOException

Throws:

IOException

createOpCommand

private void createOpCommand(String hostname,
 ClusterManager.ServiceType service,
 HBaseClusterManager.CommandProvider.Operation op)
                      throws IOException

Throws:

IOException

start

public void start(ClusterManager.ServiceType service,
 String hostname,
 int port)
           throws IOException

Description copied from interface: ClusterManager

Start the service on the given host

Specified by:

start in interface ClusterManager

Throws:

IOException

stop

public void stop(ClusterManager.ServiceType service,
 String hostname,
 int port)
          throws IOException

Description copied from interface: ClusterManager

Stop the service on the given host

Specified by:

stop in interface ClusterManager

Throws:

IOException

restart

public void restart(ClusterManager.ServiceType service,
 String hostname,
 int port)
             throws IOException

Description copied from interface: ClusterManager

Restart the service on the given host

Specified by:

restart in interface ClusterManager

Throws:

IOException

kill

public void kill(ClusterManager.ServiceType service,
 String hostname,
 int port)
          throws IOException

Description copied from interface: ClusterManager

Kills the service running on the given host

Specified by:

kill in interface ClusterManager

Throws:

IOException

suspend

public void suspend(ClusterManager.ServiceType service,
 String hostname,
 int port)
             throws IOException

Description copied from interface: ClusterManager

Suspends the service running on the given host

Specified by:

suspend in interface ClusterManager

Throws:

IOException

resume

public void resume(ClusterManager.ServiceType service,
 String hostname,
 int port)
            throws IOException

Description copied from interface: ClusterManager

Resumes the services running on the given host

Specified by:

resume in interface ClusterManager

Throws:

IOException

isRunning

public boolean isRunning(ClusterManager.ServiceType service,
 String hostname,
 int port)
                  throws IOException

Description copied from interface: ClusterManager

Returns whether the service is running on the remote host. This only checks whether the service still has a pid.

Specified by:

isRunning in interface ClusterManager

Throws:

IOException