Java 类org.apache.hadoop.hbase.HBaseClusterManager.CommandProvider.Operation 实例源码

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", hbaseHome, confDir,
      op.toString().toLowerCase(), service);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/sbin/hadoop-daemon.sh %s %s %s", hadoopHome, confDir,
      op.toString().toLowerCase(), service);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/zkServer.sh %s", zookeeperHome, op.toString().toLowerCase());
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  execWithRetries(hostname, service, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", getHBaseHome(), getConfig(),
      op.toString().toLowerCase(), service);
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  exec(hostname, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", hbaseHome, confDir,
      op.toString().toLowerCase(), service);
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  execWithRetries(hostname, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", getHBaseHome(), getConfig(),
      op.toString().toLowerCase(), service);
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  exec(hostname, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", hbaseHome, confDir,
      op.toString().toLowerCase(Locale.ROOT), service);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/sbin/hadoop-daemon.sh %s %s %s", hadoopHome, confDir,
      op.toString().toLowerCase(Locale.ROOT), service);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/zkServer.sh %s", zookeeperHome, op.toString().toLowerCase(Locale.ROOT));
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  execWithRetries(hostname, service, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname, int port) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", hbaseHome, confDir,
      op.toString().toLowerCase(), service);
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  execWithRetries(hostname, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", getHBaseHome(), getConfig(),
      op.toString().toLowerCase(), service);
}

private void exec(String hostname, ServiceType service, Operation op) throws IOException {
  exec(hostname, getCommandProvider(service).getCommand(service, op));
}

@Override
public void start(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.START);
}

@Override
public void stop(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.STOP);
}

@Override
public void restart(ServiceType service, String hostname) throws IOException {
  exec(hostname, service, Operation.RESTART);
}

@Override
public String getCommand(ServiceType service, Operation op) {
  return String.format("%s/bin/hbase-daemon.sh %s %s %s", getHBaseHome(), getConfig(),
      op.toString().toLowerCase(), service);
}