设为首页 加入收藏

TOP

java hbase ddl alter 添加新的列族
2018-12-07 01:44:45 】 浏览:14
Tags:java hbase ddl alter 添加
package cn.hbase.ddl;


import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.HBaseAdmin;


/*
* 2015.10.28 给表添加列族
*/
public class AddFamliyTable {
public static void main(String[] args) throws Exception {
//先创建配置文件,有两种方法,这里用的最简单,直接create
Configuration conf = HBaseConfiguration.create();
//创建连接,有了连接后,
HBaseAdmin admin = new HBaseAdmin(conf);
//判断一下,这个表是否在
if(admin.tableExists(TableName.valueOf("t_3"))){
//新添加列族 alter 't_3',{Name=>'hobbies',VERSION=>5}
//先创建一个列族,才能给这个列族,添加属性
HColumnDescriptor newFamliy = new HColumnDescriptor("hobbies");
admin.addColumn(TableName.valueOf("t_3"), newFamliy);
}
admin.close();
}
}
-------------------------------------------------------------------------------------------------------------------------
总结:
必须先声明一个新列族 new HColumnDescriptor("hobbies");
HBase shell 中的alter 命令,对应的java里的 addColumn()方法

编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇通过HBase Observer同步数据到Ela.. 下一篇hbase编程指南

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(214) }