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

项目：ditb 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode,
    final List<ServerName> favoredNodes, Boolean openForReplay) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  if (favoredNodes != null) {
    for (ServerName server : favoredNodes) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
  }
  if(openForReplay != null) {
    builder.setOpenForDistributedLogReplay(openForReplay);
  }
  return builder.build();
}

项目：pbase 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode,
    final List<ServerName> favoredNodes, Boolean openForReplay) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  if (favoredNodes != null) {
    for (ServerName server : favoredNodes) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
  }
  if(openForReplay != null) {
    builder.setOpenForDistributedLogReplay(openForReplay);
  }
  return builder.build();
}

项目：HIndex 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode,
    final List<ServerName> favoredNodes) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  if (favoredNodes != null) {
    for (ServerName server : favoredNodes) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
  }
  return builder.build();
}

项目：PyroDB 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode,
    final List<ServerName> favoredNodes) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  if (favoredNodes != null) {
    for (ServerName server : favoredNodes) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
  }
  return builder.build();
}

项目：c5 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode,
    final List<ServerName> favoredNodes) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  if (favoredNodes != null) {
    for (ServerName server : favoredNodes) {
      builder.addFavoredNodes(ProtobufUtil.toServerName(server));
    }
  }
  return builder.build();
}

项目：DominoHBase 文件：RequestConverter.java

/**
 * Create a RegionOpenInfo based on given region info and version of offline node
 */
private static RegionOpenInfo buildRegionOpenInfo(
    final HRegionInfo region, final int versionOfOfflineNode) {
  RegionOpenInfo.Builder builder = RegionOpenInfo.newBuilder();
  builder.setRegion(HRegionInfo.convert(region));
  if (versionOfOfflineNode >= 0) {
    builder.setVersionOfOfflineNode(versionOfOfflineNode);
  }
  return builder.build();
}