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

@Override
public StopMasterResponse stopMaster(RpcController controller,
    StopMasterRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " stop");
  master.stopMaster();
  return StopMasterResponse.newBuilder().build();
}

/**
 * Shuts down the current HBase master only.
 * Does not shutdown the cluster.
 * @see #shutdown()
 * @throws IOException if a remote or network exception occurs
 */
@Override
public synchronized void stopMaster() 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.stopMaster(controller, StopMasterRequest.newBuilder().build());
      return null;
    }
  });
}

@Override
public StopMasterResponse stopMaster(RpcController controller,
    StopMasterRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " stop");
  master.stopMaster();
  return StopMasterResponse.newBuilder().build();
}

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

@Override
public StopMasterResponse stopMaster(RpcController controller, StopMasterRequest request)
throws ServiceException {
  LOG.info(getClientIdAuditPrefix() + " stop");
  stopMaster();
  return StopMasterResponse.newBuilder().build();
}

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

@Override
public StopMasterResponse stopMaster(RpcController controller,
    StopMasterRequest request) throws ServiceException {
  LOG.info(master.getClientIdAuditPrefix() + " stop");
  master.stopMaster();
  return StopMasterResponse.newBuilder().build();
}

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

@Override
public StopMasterResponse stopMaster(RpcController controller, StopMasterRequest request)
throws ServiceException {
  LOG.info(getClientIdAuditPrefix() + " stop");
  stopMaster();
  return StopMasterResponse.newBuilder().build();
}

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