Java 类org.apache.hadoop.hbase.protobuf.generated.AdminProtos.UpdateFavoredNodesResponse 实例源码

项目:ditb    文件:RSRpcServices.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  List<UpdateFavoredNodesRequest.RegionUpdateInfo> openInfoList = request.getUpdateInfoList();
  UpdateFavoredNodesResponse.Builder respBuilder = UpdateFavoredNodesResponse.newBuilder();
  for (UpdateFavoredNodesRequest.RegionUpdateInfo regionUpdateInfo : openInfoList) {
    HRegionInfo hri = HRegionInfo.convert(regionUpdateInfo.getRegion());
    regionServer.updateRegionFavoredNodesMapping(hri.getEncodedName(),
      regionUpdateInfo.getFavoredNodesList());
  }
  respBuilder.setResponse(openInfoList.size());
  return respBuilder.build();
}
项目:pbase    文件:RSRpcServices.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
                                                     UpdateFavoredNodesRequest request) throws ServiceException {
    List<UpdateFavoredNodesRequest.RegionUpdateInfo> openInfoList = request.getUpdateInfoList();
    UpdateFavoredNodesResponse.Builder respBuilder = UpdateFavoredNodesResponse.newBuilder();
    for (UpdateFavoredNodesRequest.RegionUpdateInfo regionUpdateInfo : openInfoList) {
        HRegionInfo hri = HRegionInfo.convert(regionUpdateInfo.getRegion());
        regionServer.updateRegionFavoredNodesMapping(hri.getEncodedName(),
                regionUpdateInfo.getFavoredNodesList());
    }
    respBuilder.setResponse(openInfoList.size());
    return respBuilder.build();
}
项目:HIndex    文件:HRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  List<UpdateFavoredNodesRequest.RegionUpdateInfo> openInfoList = request.getUpdateInfoList();
  UpdateFavoredNodesResponse.Builder respBuilder = UpdateFavoredNodesResponse.newBuilder();
  for (UpdateFavoredNodesRequest.RegionUpdateInfo regionUpdateInfo : openInfoList) {
    HRegionInfo hri = HRegionInfo.convert(regionUpdateInfo.getRegion());
    updateRegionFavoredNodesMapping(hri.getEncodedName(),
        regionUpdateInfo.getFavoredNodesList());
  }
  respBuilder.setResponse(openInfoList.size());
  return respBuilder.build();
}
项目:PyroDB    文件:RSRpcServices.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  List<UpdateFavoredNodesRequest.RegionUpdateInfo> openInfoList = request.getUpdateInfoList();
  UpdateFavoredNodesResponse.Builder respBuilder = UpdateFavoredNodesResponse.newBuilder();
  for (UpdateFavoredNodesRequest.RegionUpdateInfo regionUpdateInfo : openInfoList) {
    HRegionInfo hri = HRegionInfo.convert(regionUpdateInfo.getRegion());
    regionServer.updateRegionFavoredNodesMapping(hri.getEncodedName(),
      regionUpdateInfo.getFavoredNodesList());
  }
  respBuilder.setResponse(openInfoList.size());
  return respBuilder.build();
}
项目:c5    文件:HRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  List<UpdateFavoredNodesRequest.RegionUpdateInfo> openInfoList = request.getUpdateInfoList();
  UpdateFavoredNodesResponse.Builder respBuilder = UpdateFavoredNodesResponse.newBuilder();
  for (UpdateFavoredNodesRequest.RegionUpdateInfo regionUpdateInfo : openInfoList) {
    HRegionInfo hri = HRegionInfo.convert(regionUpdateInfo.getRegion());
    updateRegionFavoredNodesMapping(hri.getEncodedName(),
        regionUpdateInfo.getFavoredNodesList());
  }
  respBuilder.setResponse(openInfoList.size());
  return respBuilder.build();
}
项目:ditb    文件:MockRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  return null;
}
项目:pbase    文件:MockRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  return null;
}
项目:HIndex    文件:MockRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  return null;
}
项目:PyroDB    文件:MockRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  return null;
}
项目:c5    文件:MockRegionServer.java   
@Override
public UpdateFavoredNodesResponse updateFavoredNodes(RpcController controller,
    UpdateFavoredNodesRequest request) throws ServiceException {
  return null;
}