用户注册



邮箱:

密码:

用户登录


邮箱:

密码:
记住登录一个月忘记密码?

发表随想


还能输入:200字
云代码 - java代码库

HBase 切分表 分割表

2013-04-29 作者: 神马举报

[java]代码库

public void split(String tableName,int number,int timeout) throws Exception {
  
    Configuration HBASE_CONFIG = new Configuration();
  
    HBASE_CONFIG.set(“hbase.zookeeper.quorum”, GlobalConf.ZOOKEEPER_QUORUM);
  
    HBASE_CONFIG.set(“hbase.zookeeper.property.clientPort”, GlobalConf.ZOOKEEPER_PORT);
  
    HBaseConfiguration cfg = new HBaseConfiguration(HBASE_CONFIG);
  
    HBaseAdmin hAdmin = new HBaseAdmin(cfg);
  
    HTable hTable = new HTable(cfg,tableName);
  
    int oldsize = 0;
  
    t =  System.currentTimeMillis();
  
    while(true){
  
       int size = hTable.getRegionsInfo().size();
  
       logger.info(“the region number=”+size);
  
       if(size>=number ) break;
  
       if(size!=oldsize){
  
           hAdmin.split(hTable.getTableName());
  
           oldsize = size;
  
       }
  
       else if(System.currentTimeMillis()-t>timeout){
  
           break;
  
       }
  
       Thread.sleep(1000*10);
  
    }
  
}


网友评论    (发表评论)


发表评论:

评论须知:

  • 1、评论每次加2分,每天上限为30;
  • 2、请文明用语,共同创建干净的技术交流环境;
  • 3、若被发现提交非法信息,评论将会被删除,并且给予扣分处理,严重者给予封号处理;
  • 4、请勿发布广告信息或其他无关评论,否则将会删除评论并扣分,严重者给予封号处理。


扫码下载

加载中,请稍后...

输入口令后可复制整站源码

加载中,请稍后...