想优化hbase批量写入速度,搞了个偏门套路,也不知道会不会出问题:
1)使用HTable ,
hTable = new HTable(conf, TableName.valueOf("storm_wxgz"));
hTable.setWriteBufferSize(10 * 1024 * 1024);//10M
hTable.setAutoFlushTo(false);
2)使用定时器,每一秒去刷新一次
![](https://img.laitimes.com/img/__Qf2AjLwojIjJCLyojI0JCLiAzNfRHLGZkRGZkRfJ3bs92YsYTMfVmepNHL6tmeOJTWE9EeNpHW4Z0MMBjVtJWd0ckW65UbM5WOHJWa5kHT20ESjBjUIF2X0hXZ0xCMx81dvRWYoNHLrdEZwZ1Rh5WNXp1bwNjW1ZUba9VZwlHdssmch1mclRXY39CXldWYtlWPzNXZj9mcw1ycz9WL49zZuBnL4ADOzQjMwIjM0ETMwkTMwIzLc52YucWbp5GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.png)
也不知道对查询是否有影响。
想优化hbase批量写入速度,搞了个偏门套路,也不知道会不会出问题:
1)使用HTable ,
hTable = new HTable(conf, TableName.valueOf("storm_wxgz"));
hTable.setWriteBufferSize(10 * 1024 * 1024);//10M
hTable.setAutoFlushTo(false);
2)使用定时器,每一秒去刷新一次
也不知道对查询是否有影响。