org.apache.hadoop.hbase.master.RegionPlan#getSource ( )源码实例Demo

下面列出了org.apache.hadoop.hbase.master.RegionPlan#getSource ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hbase 文件： BalancerTestBase.java

/**
 * This assumes the RegionPlan HSI instances are the same ones in the map, so
 * actually no need to even pass in the map, but I think it's clearer.
 *
 * @param list
 * @param plans
 * @return a list of all added {@link ServerAndLoad} values.
 */
protected List<ServerAndLoad> reconcile(List<ServerAndLoad> list,
                                        List<RegionPlan> plans,
                                        Map<ServerName, List<RegionInfo>> servers) {
  List<ServerAndLoad> result = new ArrayList<>(list.size());

  Map<ServerName, ServerAndLoad> map = new HashMap<>(list.size());
  for (ServerAndLoad sl : list) {
    map.put(sl.getServerName(), sl);
  }
  if (plans != null) {
    for (RegionPlan plan : plans) {
      ServerName source = plan.getSource();

      updateLoad(map, source, -1);
      ServerName destination = plan.getDestination();
      updateLoad(map, destination, +1);

      servers.get(source).remove(plan.getRegionInfo());
      servers.get(destination).add(plan.getRegionInfo());
    }
  }
  result.clear();
  result.addAll(map.values());
  return result;
}

源代码2 项目： hbase 文件： RSGroupableBalancerTestBase.java

protected ArrayListMultimap<String, ServerAndLoad> reconcile(
    ArrayListMultimap<String, ServerAndLoad> previousLoad,
    List<RegionPlan> plans) {
  ArrayListMultimap<String, ServerAndLoad> result = ArrayListMultimap
      .create();
  result.putAll(previousLoad);
  if (plans != null) {
    for (RegionPlan plan : plans) {
      ServerName source = plan.getSource();
      updateLoad(result, source, -1);
      ServerName destination = plan.getDestination();
      updateLoad(result, destination, +1);
    }
  }
  return result;
}

源代码3 项目： hbase-tools 文件： Balance.java

@SuppressWarnings("deprecation")
private void balance(Args args, List<RegionPlan> regionPlanList, Phase phase, boolean asynchronous) throws IOException, InterruptedException {
    int progress = 1;
    for (RegionPlan regionPlan : regionPlanList) {
        String tableName = Bytes.toString(regionPlan.getRegionInfo().getTableName());
        String encodedRegionName = regionPlan.getRegionInfo().getEncodedName();
        String serverNameDest = regionPlan.getDestination().getServerName();
        String serverNameSource;
        if (regionPlan.getSource() == null) {
            serverNameSource = "N/A";
        } else {
            serverNameSource = regionPlan.getSource().getServerName();
        }
        String planStr = progress++ + "/" + regionPlanList.size() + " - move " + encodedRegionName + " of " + tableName + " from " + serverNameSource + " to " + serverNameDest;
        if (phase == Phase.BALANCE) {
            System.out.print(planStr);
        } else {
            System.out.println(planStr);
        }

        if (phase == Phase.BALANCE) {
            Common.moveWithPrintingResult(args, admin, tableName, encodedRegionName, serverNameDest, asynchronous);
        }
    }

    if (asynchronous && phase == Phase.BALANCE)
        Thread.sleep(Constant.SMALL_WAIT_INTERVAL_MS);
}

源代码4 项目： hbase-tools 文件： Balance.java

@SuppressWarnings("deprecation")
private void balance(Args args, List<RegionPlan> regionPlanList, Phase phase, boolean asynchronous) throws IOException, InterruptedException {
    int progress = 1;
    for (RegionPlan regionPlan : regionPlanList) {
        String tableName = Bytes.toString(regionPlan.getRegionInfo().getTableName());
        String encodedRegionName = regionPlan.getRegionInfo().getEncodedName();
        String serverNameDest = regionPlan.getDestination().getServerName();
        String serverNameSource;
        if (regionPlan.getSource() == null) {
            serverNameSource = "N/A";
        } else {
            serverNameSource = regionPlan.getSource().getServerName();
        }
        String planStr = progress++ + "/" + regionPlanList.size() + " - move " + encodedRegionName + " of " + tableName + " from " + serverNameSource + " to " + serverNameDest;
        if (phase == Phase.BALANCE) {
            System.out.print(planStr);
        } else {
            System.out.println(planStr);
        }

        if (phase == Phase.BALANCE) {
            Common.moveWithPrintingResult(args, admin, tableName, encodedRegionName, serverNameDest, asynchronous);
        }
    }

    if (asynchronous && phase == Phase.BALANCE)
        Thread.sleep(Constant.SMALL_WAIT_INTERVAL_MS);
}

源代码5 项目： hbase-tools 文件： Balance.java

@SuppressWarnings("deprecation")
private void balance(Args args, List<RegionPlan> regionPlanList, Phase phase, boolean asynchronous) throws IOException, InterruptedException {
    int progress = 1;
    for (RegionPlan regionPlan : regionPlanList) {
        String tableName = Bytes.toString(regionPlan.getRegionInfo().getTableName());
        String encodedRegionName = regionPlan.getRegionInfo().getEncodedName();
        String serverNameDest = regionPlan.getDestination().getServerName();
        String serverNameSource;
        if (regionPlan.getSource() == null) {
            serverNameSource = "N/A";
        } else {
            serverNameSource = regionPlan.getSource().getServerName();
        }
        String planStr = progress++ + "/" + regionPlanList.size() + " - move " + encodedRegionName + " of " + tableName + " from " + serverNameSource + " to " + serverNameDest;
        if (phase == Phase.BALANCE) {
            System.out.print(planStr);
        } else {
            System.out.println(planStr);
        }

        if (phase == Phase.BALANCE) {
            Common.moveWithPrintingResult(args, admin, tableName, encodedRegionName, serverNameDest, asynchronous);
        }
    }

    if (asynchronous && phase == Phase.BALANCE)
        Thread.sleep(Constant.SMALL_WAIT_INTERVAL_MS);
}

源代码6 项目： hbase-tools 文件： Balance.java

@SuppressWarnings("deprecation")
private void balance(Args args, List<RegionPlan> regionPlanList, Phase phase, boolean asynchronous) throws IOException, InterruptedException {
    int progress = 1;
    for (RegionPlan regionPlan : regionPlanList) {
        String tableName = Bytes.toString(regionPlan.getRegionInfo().getTableName());
        String encodedRegionName = regionPlan.getRegionInfo().getEncodedName();
        String serverNameDest = regionPlan.getDestination().getServerName();
        String serverNameSource;
        if (regionPlan.getSource() == null) {
            serverNameSource = "N/A";
        } else {
            serverNameSource = regionPlan.getSource().getServerName();
        }
        String planStr = progress++ + "/" + regionPlanList.size() + " - move " + encodedRegionName + " of " + tableName + " from " + serverNameSource + " to " + serverNameDest;
        if (phase == Phase.BALANCE) {
            System.out.print(planStr);
        } else {
            System.out.println(planStr);
        }

        if (phase == Phase.BALANCE) {
            Common.moveWithPrintingResult(args, admin, tableName, encodedRegionName, serverNameDest, asynchronous);
        }
    }

    if (asynchronous && phase == Phase.BALANCE)
        Thread.sleep(Constant.SMALL_WAIT_INTERVAL_MS);
}

源代码7 项目： hbase-tools 文件： Balance.java

@SuppressWarnings("deprecation")
private void balance(Args args, List<RegionPlan> regionPlanList, Phase phase, boolean asynchronous) throws IOException, InterruptedException {
    int progress = 1;
    for (RegionPlan regionPlan : regionPlanList) {
        String tableName = Bytes.toString(regionPlan.getRegionInfo().getTableName());
        String encodedRegionName = regionPlan.getRegionInfo().getEncodedName();
        String serverNameDest = regionPlan.getDestination().getServerName();
        String serverNameSource;
        if (regionPlan.getSource() == null) {
            serverNameSource = "N/A";
        } else {
            serverNameSource = regionPlan.getSource().getServerName();
        }
        String planStr = progress++ + "/" + regionPlanList.size() + " - move " + encodedRegionName + " of " + tableName + " from " + serverNameSource + " to " + serverNameDest;
        if (phase == Phase.BALANCE) {
            System.out.print(planStr);
        } else {
            System.out.println(planStr);
        }

        if (phase == Phase.BALANCE) {
            Common.moveWithPrintingResult(args, admin, tableName, encodedRegionName, serverNameDest, asynchronous);
        }
    }

    if (asynchronous && phase == Phase.BALANCE)
        Thread.sleep(Constant.SMALL_WAIT_INTERVAL_MS);
}

方法所在类

org.apache.hadoop.hbase.master.RegionPlan