Java客户端连接Hbase，并创建表（超详细）public static void Test() throws URISyntaxException, IOException
{
System.out.println("开始执⾏");
//初始化Hbase连接
Configuration configuration = ate();
//加载配置⽂件
configuration.addResource(new SystemResource("l").toURI()));
configuration.addResource(new SystemResource("l").toURI()));
Connection connection = ateConnection(configuration);
System.out.println("连接成功！");
//设置表名
TableName tableName = TableName.valueOf("xuehu01");
//将表名传递给HTableDescriptor
HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
drop table if exists admin
//创建列族
HColumnDescriptor mycg = new HColumnDescriptor("mycg");
//将列族添加进表中
hTableDescriptor.addFamily(mycg);
//Admin是操作表的类，具有创建
Admin admin = Admin();
if (admin.TableName()))
{
admin.TableName());
admin.TableName());
}
System.out.println("创建列族");
//设置列族的压缩⽅式为GZ
mycg.setCompactionCompressionType(Compression.Algorithm.GZ);
//把最⼤版本数修改为ALL.VERSION，其实就是Integer.MAX_VALUE
mycg.setMaxVersions(HConstants.ALL_VERSIONS);
//把列族的定义更新到表定义⾥⾯去
//不过此时对表的修改还没有真正执⾏下去，只有调⽤Admin类来进⾏操作的时候才真正开始执⾏
//当执⾏了modifyTable⽅法后，对表的修改才真正完成
//删掉之前建⽴的列族
//⾸先进⾏停⽤表
admin.disableTable(tableName);
//然后进⾏删除列族
admin.deleteColumn(tableName,"mycf".getBytes("UTF-8"));
admin.deleteTable(tableName);
admin.close();
connection.close();
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。