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

项目：ditb 文件：RequestConverter.java

/**
 * Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
 * @param updateRegionInfos
 * @return a protocol buffer UpdateFavoredNodesRequest
 */
public static UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(
    final List<Pair<HRegionInfo, List<ServerName>>> updateRegionInfos) {
  UpdateFavoredNodesRequest.Builder ubuilder = UpdateFavoredNodesRequest.newBuilder();
  for (Pair<HRegionInfo, List<ServerName>> pair : updateRegionInfos) {
    RegionUpdateInfo.Builder builder = RegionUpdateInfo.newBuilder();
    builder.setRegion(HRegionInfo.convert(pair.getFirst()));
    for (ServerName server : pair.getSecond()) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
    ubuilder.addUpdateInfo(builder.build());
  }
  return ubuilder.build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
 * @param updateRegionInfos
 * @return a protocol buffer UpdateFavoredNodesRequest
 */
public static UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(
    final List<Pair<HRegionInfo, List<ServerName>>> updateRegionInfos) {
  UpdateFavoredNodesRequest.Builder ubuilder = UpdateFavoredNodesRequest.newBuilder();
  for (Pair<HRegionInfo, List<ServerName>> pair : updateRegionInfos) {
    RegionUpdateInfo.Builder builder = RegionUpdateInfo.newBuilder();
    builder.setRegion(HRegionInfo.convert(pair.getFirst()));
    for (ServerName server : pair.getSecond()) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
    ubuilder.addUpdateInfo(builder.build());
  }
  return ubuilder.build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
 * @param updateRegionInfos
 * @return a protocol buffer UpdateFavoredNodesRequest
 */
public static UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(
    final List<Pair<HRegionInfo, List<ServerName>>> updateRegionInfos) {
  UpdateFavoredNodesRequest.Builder ubuilder = UpdateFavoredNodesRequest.newBuilder();
  for (Pair<HRegionInfo, List<ServerName>> pair : updateRegionInfos) {
    RegionUpdateInfo.Builder builder = RegionUpdateInfo.newBuilder();
    builder.setRegion(HRegionInfo.convert(pair.getFirst()));
    for (ServerName server : pair.getSecond()) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
    ubuilder.addUpdateInfo(builder.build());
  }
  return ubuilder.build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
 * @param updateRegionInfos
 * @return a protocol buffer UpdateFavoredNodesRequest
 */
public static UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(
    final List<Pair<HRegionInfo, List<ServerName>>> updateRegionInfos) {
  UpdateFavoredNodesRequest.Builder ubuilder = UpdateFavoredNodesRequest.newBuilder();
  for (Pair<HRegionInfo, List<ServerName>> pair : updateRegionInfos) {
    RegionUpdateInfo.Builder builder = RegionUpdateInfo.newBuilder();
    builder.setRegion(HRegionInfo.convert(pair.getFirst()));
    for (ServerName server : pair.getSecond()) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
    ubuilder.addUpdateInfo(builder.build());
  }
  return ubuilder.build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a protocol buffer UpdateFavoredNodesRequest to update a list of favorednode mappings
 * @param updateRegionInfos
 * @return a protocol buffer UpdateFavoredNodesRequest
 */
public static UpdateFavoredNodesRequest buildUpdateFavoredNodesRequest(
    final List<Pair<HRegionInfo, List<ServerName>>> updateRegionInfos) {
  UpdateFavoredNodesRequest.Builder ubuilder = UpdateFavoredNodesRequest.newBuilder();
  for (Pair<HRegionInfo, List<ServerName>> pair : updateRegionInfos) {
    RegionUpdateInfo.Builder builder = RegionUpdateInfo.newBuilder();
    builder.setRegion(HRegionInfo.convert(pair.getFirst()));
    for (ServerName server : pair.getSecond()) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
    ubuilder.addUpdateInfo(builder.build());
  }
  return ubuilder.build();
}