下面列出了org.apache.hadoop.hbase.client.HTable#getRegionLocations ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
private void validateST2(HTable table1) throws IOException {
NavigableMap<HRegionInfo, ServerName> regionLocations;
List<Map.Entry<HRegionInfo, ServerName>> hRegionInfoList;
regionLocations = table1.getRegionLocations();
hRegionInfoList = new ArrayList<>(regionLocations.entrySet());
Map<ServerName, Integer> serverCountMap = new HashMap<>();
for (Map.Entry<HRegionInfo, ServerName> entry : hRegionInfoList) {
if (serverCountMap.get(entry.getValue()) == null) {
serverCountMap.put(entry.getValue(), 1);
} else {
serverCountMap.put(entry.getValue(), serverCountMap.get(entry.getValue()) + 1);
}
}
Assert.assertEquals(Math.min(getServerNameList().size(), regionLocations.size()), serverCountMap.size());
int regionCount;
regionCount = 0;
for (ServerName serverName : getServerNameList()) {
List<HRegionInfo> regionInfoList = getRegionInfoList(serverName, Bytes.toString(table1.getTableName()));
Assert.assertNotEquals(4, regionInfoList.size());
Assert.assertEquals(2, regionInfoList.size());
regionCount += regionInfoList.size();
}
Assert.assertEquals(4, regionCount);
}
private void validateST2(HTable table1) throws IOException {
NavigableMap<HRegionInfo, ServerName> regionLocations;
List<Map.Entry<HRegionInfo, ServerName>> hRegionInfoList;
regionLocations = table1.getRegionLocations();
hRegionInfoList = new ArrayList<>(regionLocations.entrySet());
Map<ServerName, Integer> serverCountMap = new HashMap<>();
for (Map.Entry<HRegionInfo, ServerName> entry : hRegionInfoList) {
if (serverCountMap.get(entry.getValue()) == null) {
serverCountMap.put(entry.getValue(), 1);
} else {
serverCountMap.put(entry.getValue(), serverCountMap.get(entry.getValue()) + 1);
}
}
Assert.assertEquals(Math.min(getServerNameList().size(), regionLocations.size()), serverCountMap.size());
int regionCount;
regionCount = 0;
for (ServerName serverName : getServerNameList()) {
List<HRegionInfo> regionInfoList = getRegionInfoList(serverName, Bytes.toString(table1.getTableName()));
Assert.assertNotEquals(4, regionInfoList.size());
Assert.assertEquals(2, regionInfoList.size());
regionCount += regionInfoList.size();
}
Assert.assertEquals(4, regionCount);
}