博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java客户端连接Hbase,并创建表(超详细)
阅读量:5207 次
发布时间:2019-06-14

本文共 1822 字,大约阅读时间需要 6 分钟。

public static void Test() throws URISyntaxException, IOException {
System.out.println("开始执行"); //初始化Hbase连接 Configuration configuration = HBaseConfiguration.create(); //加载配置文件 configuration.addResource(new Path(ClassLoader.getSystemResource("hbase-site.xml").toURI())); configuration.addResource(new Path(ClassLoader.getSystemResource("core-site.xml").toURI())); Connection connection = ConnectionFactory.createConnection(configuration); System.out.println("连接成功!"); //设置表名 TableName tableName = TableName.valueOf("xuehu01"); //将表名传递给HTableDescriptor HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName); //创建列族 HColumnDescriptor mycg = new HColumnDescriptor("mycg"); //将列族添加进表中 hTableDescriptor.addFamily(mycg); //Admin是操作表的类,具有创建 Admin admin = connection.getAdmin(); admin.createTable(hTableDescriptor); if (admin.tableExists(hTableDescriptor.getTableName())) {
admin.disableTable(hTableDescriptor.getTableName()); admin.deleteTable(hTableDescriptor.getTableName()); } admin.createTable(hTableDescriptor); System.out.println("创建列族"); //设置列族的压缩方式为GZ mycg.setCompactionCompressionType(Compression.Algorithm.GZ); //把最大版本数修改为ALL.VERSION,其实就是Integer.MAX_VALUE mycg.setMaxVersions(HConstants.ALL_VERSIONS); //把列族的定义更新到表定义里面去 hTableDescriptor.modifyFamily(mycg); //不过此时对表的修改还没有真正执行下去,只有调用Admin类来进行操作的时候才真正开始执行 //当执行了modifyTable方法后,对表的修改才真正完成 admin.modifyTable(tableName,hTableDescriptor); //删掉之前建立的列族 //首先进行停用表 admin.disableTable(tableName); //然后进行删除列族 admin.deleteColumn(tableName,"mycf".getBytes("UTF-8")); admin.deleteTable(tableName); admin.close(); connection.close(); }

转载于:https://www.cnblogs.com/xuehu666/p/10599741.html

你可能感兴趣的文章
oracle生成主键
查看>>
秦旭光第一周任务
查看>>
java - day11 - OverRideTest
查看>>
Objective-C 内存管理之dealloc方法中变量释放处理
查看>>
iOS开发 viewWillAppear:(BOOL)animated真机调试的时候不执行了怎么办
查看>>
2019年高速免费
查看>>
实验三— —敏捷开发与XP实践
查看>>
POJ 1691 Painting A Board(DFS)
查看>>
Python【每日一问】15
查看>>
第二篇:库相关操作
查看>>
mongodb分页查询,排序
查看>>
C语言位运算+实例讲解(转)
查看>>
Fiddler 简介
查看>>
uva 10817 - Headmaster's Headache ( 状态压缩dp)
查看>>
c函数调用过程原理及函数栈帧分析
查看>>
[置顶] cuzy sdk之起源
查看>>
析构函数构造函数CPerson派生出CEmployee类
查看>>
配置环境将win32项目移植到Android
查看>>
Maven 安装
查看>>
jquery之selectors
查看>>