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

@Override
public GetClusterStatusResponse getClusterStatus(RpcController controller,
    GetClusterStatusRequest req) throws ServiceException {
  GetClusterStatusResponse.Builder response = GetClusterStatusResponse.newBuilder();
  try {
    master.checkInitialized();
    response.setClusterStatus(master.getClusterStatus().convert());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return response.build();
}

/**
 * @return cluster status
 * @throws IOException if a remote or network exception occurs
 */
@Override
public ClusterStatus getClusterStatus() throws IOException {
  return executeCallable(new MasterCallable<ClusterStatus>(getConnection()) {
    @Override
    public ClusterStatus call(int callTimeout) throws ServiceException {
      PayloadCarryingRpcController controller = rpcControllerFactory.newController();
      controller.setCallTimeout(callTimeout);
      GetClusterStatusRequest req = RequestConverter.buildGetClusterStatusRequest();
      return ClusterStatus.convert(master.getClusterStatus(controller, req).getClusterStatus());
    }
  });
}

@Override
public GetClusterStatusResponse getClusterStatus(RpcController controller,
    GetClusterStatusRequest req) throws ServiceException {
  GetClusterStatusResponse.Builder response = GetClusterStatusResponse.newBuilder();
  try {
    master.checkInitialized();
    response.setClusterStatus(master.getClusterStatus().convert());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return response.build();
}

/**
 * @return cluster status
 * @throws IOException if a remote or network exception occurs
 */
@Override
public ClusterStatus getClusterStatus() throws IOException {
  return executeCallable(new MasterCallable<ClusterStatus>(getConnection()) {
    @Override
    public ClusterStatus call(int callTimeout) throws ServiceException {
      GetClusterStatusRequest req = RequestConverter.buildGetClusterStatusRequest();
      return ClusterStatus.convert(master.getClusterStatus(null, req).getClusterStatus());
    }
  });
}

@Override
public GetClusterStatusResponse getClusterStatus(RpcController controller,
    GetClusterStatusRequest req)
throws ServiceException {
  GetClusterStatusResponse.Builder response = GetClusterStatusResponse.newBuilder();
  response.setClusterStatus(getClusterStatus().convert());
  return response.build();
}

/**
 * @return cluster status
 * @throws IOException if a remote or network exception occurs
 */
public ClusterStatus getClusterStatus() throws IOException {
  return executeCallable(new MasterCallable<ClusterStatus>(getConnection()) {
    @Override
    public ClusterStatus call() throws ServiceException {
      GetClusterStatusRequest req = RequestConverter.buildGetClusterStatusRequest();
      return ClusterStatus.convert(master.getClusterStatus(null,req).getClusterStatus());
    }
  });
}

@Override
public GetClusterStatusResponse getClusterStatus(RpcController controller,
    GetClusterStatusRequest req) throws ServiceException {
  GetClusterStatusResponse.Builder response = GetClusterStatusResponse.newBuilder();
  try {
    master.checkInitialized();
    response.setClusterStatus(master.getClusterStatus().convert());
  } catch (IOException e) {
    throw new ServiceException(e);
  }
  return response.build();
}

/**
 * @return cluster status
 * @throws IOException if a remote or network exception occurs
 */
public ClusterStatus getClusterStatus() throws IOException {
  return executeCallable(new MasterCallable<ClusterStatus>(getConnection()) {
    @Override
    public ClusterStatus call(int callTimeout) throws ServiceException {
      GetClusterStatusRequest req = RequestConverter.buildGetClusterStatusRequest();
      return ClusterStatus.convert(master.getClusterStatus(null,req).getClusterStatus());
    }
  });
}

@Override
public GetClusterStatusResponse getClusterStatus(RpcController controller,
    GetClusterStatusRequest req)
throws ServiceException {
  GetClusterStatusResponse.Builder response = GetClusterStatusResponse.newBuilder();
  response.setClusterStatus(getClusterStatus().convert());
  return response.build();
}

/**
 * @return cluster status
 * @throws IOException if a remote or network exception occurs
 */
public ClusterStatus getClusterStatus() throws IOException {
  return executeCallable(new MasterCallable<ClusterStatus>(getConnection()) {
    @Override
    public ClusterStatus call() throws ServiceException {
      GetClusterStatusRequest req = RequestConverter.buildGetClusterStatusRequest();
      return ClusterStatus.convert(master.getClusterStatus(null,req).getClusterStatus());
    }
  });
}

/**
 * Creates a protocol buffer GetClusterStatusRequest
 *
 * @return A GetClusterStatusRequest
 */
public static GetClusterStatusRequest buildGetClusterStatusRequest() {
  return GET_CLUSTER_STATUS_REQUEST;
}

/**
 * Creates a protocol buffer GetClusterStatusRequest
 *
 * @return A GetClusterStatusRequest
 */
public static GetClusterStatusRequest buildGetClusterStatusRequest() {
  return GET_CLUSTER_STATUS_REQUEST;
}

/**
 * Creates a protocol buffer GetClusterStatusRequest
 *
 * @return A GetClusterStatusRequest
 */
public static GetClusterStatusRequest buildGetClusterStatusRequest() {
  return GET_CLUSTER_STATUS_REQUEST;
}

/**
 * Creates a protocol buffer GetClusterStatusRequest
 *
 * @return A GetClusterStatusRequest
 */
public static GetClusterStatusRequest buildGetClusterStatusRequest() {
  return GET_CLUSTER_STATUS_REQUEST;
}

/**
 * Creates a protocol buffer GetClusterStatusRequest
 *
 * @return A GetClusterStatusRequest
 */
public static GetClusterStatusRequest buildGetClusterStatusRequest() {
  return GET_CLUSTER_STATUS_REQUEST;
}