HBase集群RS扩容性能验证Rowkey构建方法

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了HBase集群RS扩容性能验证Rowkey构建方法，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含3565字，纯文字阅读大概需要6分钟。

内容图文

RegionServer节点扩展后，需要将一部分原有Region迁移到新的RegionServer中，使各RegionServer负载均衡。

RegionServer节点扩展后，需要将一部分原有Region迁移到新的RegionServer中，使各RegionServer负载均衡。

为了验证多了一个节点后的HBase的写性能提升，需要使每次put时List中的RowKey平均分配到现有的所有Region中，以达到使所有RegionServer并发处理的目的。

下面的代码是这种均匀RowKey构建的元代码：

import java.util.ArrayList;
import java.util.List;

public class externTest {

public static long TOTAL_NUMS = 145;
public static int REGION_NUMS = 24;
public static long EACH_PUT_NUMS = 48;

public static void buildString() {
int addition = 0;
String str = null;
List list = new ArrayList();
long curNum = 0;

long putNums = TOTAL_NUMS/EACH_PUT_NUMS; //通常等于总put数-1;
long loopsInOnePut = EACH_PUT_NUMS/REGION_NUMS; //一次put所需的内层循环数，也即是curNum自增数

// 处理循环内的
for (long k = 0; k < putNums; k++) {
for (long i = 0; i < loopsInOnePut; i++) {
for (int j = 0; j < REGION_NUMS; j++) {
//A-Z使用同一个数值
addition = j % REGION_NUMS;
str = num2ABC(addition);
//构建本条记录字符串
System.out.println(str + curNum);
list.add(str);
}
curNum++; //一次循环后当前尾数+1
}
// TODO: 执行一次put
System.out.println("put");
list.clear();
}

// 处理循环外的，肯定小于EACH_PUT_NUMS，，最后一次put操作
long lastNums = TOTAL_NUMS % EACH_PUT_NUMS; //还剩多少记录要put
long lastloops = lastNums / REGION_NUMS; //curNum还要自增多少
long numPlus = lastNums % REGION_NUMS; //最后额外补充多少条记录
for (long i = 0; i < lastloops; i++) {
for (int j = 0; j < REGION_NUMS; j++) {
//A-Z使用同一个数值
addition = j % REGION_NUMS;
str = num2ABC(addition);
//构建本条记录字符串
System.out.println(str + curNum);
list.add(str);
}
curNum++; //一次循环后当前尾数+1
}
// 将循环外
for (int j = 0; j < numPlus; j++) {
//A-Z使用同一个数值
addition = j % REGION_NUMS;
str = num2ABC(addition);
//构建本条记录字符串
System.out.println(str + curNum);
list.add(str);
}
// TODO: 执行一次put
System.out.println("put");
list.clear();

return;
}

public static String num2ABC(int num) {
String str = null;
switch (num) {
case 0:
str = new String("A");
break;
case 1:
str = new String("B");
break;
case 2:
str = new String("C");
break;
case 3:
str = new String("D");
break;
case 4:
str = new String("E");
break;
case 5:
str = new String("F");
break;
case 6:
str = new String("G");
break;
case 7:
str = new String("H");
break;
case 8:
str = new String("I");
break;
case 9:
str = new String("J");
break;
case 10:
str = new String("K");
break;
case 11:
str = new String("L");
break;
case 12:
str = new String("M");
break;
case 13:
str = new String("N");
break;
case 14:
str = new String("O");
break;
case 15:
str = new String("P");
break;
case 16:
str = new String("Q");
break;
case 17:
str = new String("R");
break;
case 18:
str = new String("S");
break;
case 19:
str = new String("T");
break;
case 20:
str = new String("U");
break;
case 21:
str = new String("V");
break;
case 22:
str = new String("W");
break;
case 23:
str = new String("X");
break;
default:
str = new String("Z");
break;
}
return str;
}

/**
* @param args
*/
public static void main(String[] args) {
System.out.println("Test my Java!");

buildString();
}
}

内容总结

以上是互联网集市为您收集整理的HBase集群RS扩容性能验证Rowkey构建方法全部内容，希望文章能够帮你解决HBase集群RS扩容性能验证Rowkey构建方法所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---