Java 类org.apache.hadoop.hbase.protobuf.generated.MasterProtos.ShutdownRequest 实例源码

@Override
public ShutdownResponse shutdown(RpcController controller,
    ShutdownRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " shutdown");
  master.shutdown();
  return ShutdownResponse.newBuilder().build();
}

/**
 * Shuts down the HBase cluster
 * @throws IOException if a remote or network exception occurs
 */
@Override
public synchronized void shutdown() throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      PayloadCarryingRpcController controller = rpcControllerFactory.newController();
      controller.setCallTimeout(callTimeout);
      controller.setPriority(HConstants.HIGH_QOS);
      master.shutdown(controller, ShutdownRequest.newBuilder().build());
      return null;
    }
  });
}

@Override
public ShutdownResponse shutdown(RpcController controller,
    ShutdownRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " shutdown");
  master.shutdown();
  return ShutdownResponse.newBuilder().build();
}

/**
 * Shuts down the HBase cluster
 * @throws IOException if a remote or network exception occurs
 */
@Override
public synchronized void shutdown() throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      master.shutdown(null,ShutdownRequest.newBuilder().build());
      return null;
    }
  });
}

@Override
public ShutdownResponse shutdown(RpcController controller, ShutdownRequest request)
throws ServiceException {
  LOG.info(getClientIdAuditPrefix() + " shutdown");
  shutdown();
  return ShutdownResponse.newBuilder().build();
}

/**
 * Shuts down the HBase cluster
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void shutdown() throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      master.shutdown(null,ShutdownRequest.newBuilder().build());
      return null;
    }
  });
}

@Override
public ShutdownResponse shutdown(RpcController controller,
    ShutdownRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " shutdown");
  master.shutdown();
  return ShutdownResponse.newBuilder().build();
}

/**
 * Shuts down the HBase cluster
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void shutdown() throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call(int callTimeout) throws ServiceException {
      master.shutdown(null,ShutdownRequest.newBuilder().build());
      return null;
    }
  });
}

@Override
public ShutdownResponse shutdown(RpcController controller, ShutdownRequest request)
throws ServiceException {
  LOG.info(getClientIdAuditPrefix() + " shutdown");
  shutdown();
  return ShutdownResponse.newBuilder().build();
}

/**
 * Shuts down the HBase cluster
 * @throws IOException if a remote or network exception occurs
 */
public synchronized void shutdown() throws IOException {
  executeCallable(new MasterCallable<Void>(getConnection()) {
    @Override
    public Void call() throws ServiceException {
      master.shutdown(null,ShutdownRequest.newBuilder().build());
      return null;
    }
  });
}