HBase 常用类介绍:
JAVA API 和 HBase数据库模型之间的关系
| JAVA 类 |
Hbase 数据模型 |
| HBaseAdmin |
数据库(database) |
| HBaseConfiguration |
| HTable |
表(table) |
| HTableDescriptor |
列族(Column Family) |
| Put |
行列操作 |
| Get |
| Scanner |
?
HBaseConfiguration
关系:org.apache.hadoop.hbase.HBaseConfiguration
作用:通过此类可以对HBase进行配置
用法实例:
Configuration config = HBaseConfiguration.create();
config.set(“hbase.zookeeper.quorum”,”slave1,slave2,slave3”);
HBaseAdmin admin = newHBaseAdmin(config);
说明: HBaseConfiguration.create() 默认会从classpath 中查找 hbase-site.xml 中的配置信息,初始化 Configuration。
?
| 返回值 |
函数 |
描述 |
| void |
addResource(Path file) |
通过给定的路径所指的文件来添加资源 |
| void |
clear() |
清空所有已设置的属性 |
| string |
get(String name) |
获取属性名对应的值 |
| String |
getBoolean(String name, boolean defaultValue) |
获取为boolean类型的属性值,如果其属性值类型部位boolean,则返回默认属性值 |
| void |
set(String name, String value) |
通过属性名来设置值 |
| void |
setBoolean(String name, boolean value) |
设置boolean类型的属性值 |
?
HBaseAdmin
关系:org.apache.hadoop.hbase.client.HBaseAdmin
作用:提供了一个接口来管理HBase数据库的表信息。它提供的方法包括:创建表,删除表,列出表项,使表有效或无效,以及添加或删除表列族成员等。
| 返回值 |
函数 |
描述 |
| void |
addColumn(String tableName, HColumnDescriptor column) |
向一个已经存在的表添加咧 |
| checkHBaseAvailable(HBaseConfiguration conf) |
静态函数,查看HBase是否 处于运行状态 |
| createTable(HTableDescriptor desc) |
创建一个表,同步操作 |
| deleteTable(byte[] tableName) |
删除一个已经存在的表 |
| enableTable(byte[] tableName) |
使表处于有效状态 |
| disableTable(byte[] tableName) |
使表处于无效状态 |
| HTableDescriptor[] |
listTables() |
列出所有用户控件表项 |
| void |
modifyTable(byte[] tableName, HTableDescriptor htd) |
修改表的模式,是异步的操作, 可能需要花费一定的时间 |
| boolean |
tableExists(String tableName) |
检查表是否存在 |
用法示例:
?
HBaseAdmin admin =new HBaseAdmin(config);
admin.disableTable("tablename");
?
HTableDescriptor
关系:org.apache.hadoop.hbase.HTableDescriptor
作用:包含了表的名字极其对应表的列族
| 返回值 |
函数 |
描述 |
| void |
addFamily(HColumnDescriptor) |
添加一个列族 |
| HColumnDescriptor |
removeFamily(byte[] column) |
移除一个列族 |
| byte[] |
getName() |
获取表的名字 |
| byte[] |
getValue(byte[] key) |
获取属性的值 |
| void |
setValue(String key, String value) |
设置属性的值 |
用法示例:
HTableDescriptor htd = new HTableDescriptor(table);
htd.addFamily(new HcolumnDescriptor("family"));
?
HColumnDescriptor
关系:org.apache.hadoop.hbase.HColumnDescriptor
作用:维护着关于列族的信息,例如版本号,压缩设置等。它通常在创建表或者为表添加列族的时候使用。列族被创建后不能直接修改,只能通过删除然后重新创建的方式。列族被删除的时候,列族里面的数据也会同时被删除。
| 返回值 |
函数 |
描述 |
| byte[] |
getName() |
获取列族的名字 |
| byte[] |
getValue(byte[] key) |
获取对应的属性的值 |
| void |
setValue(String key, String value) |
设置对应属性的值 |
用法示例:
HTableDescriptor htd = new HTableDescriptor(tablename);
HColumnDescriptor col = newHColumnDescriptor("content:");
htd.addFamily(col);
?
HTable
关系:org.apache.hadoop.hbase.client.HTable
作用:可以用来和HBase表直接通信。此方法对于更新操作来说是非线程安全的。
| 返回值 |
函数 |
描述 |
| void |
checkAdnPut(byte[] row, byte[] family, byte[] qualifier, byte[] value, Put put |
自动的检查row/family/qualifier是否与给定的值匹配 |
| void |
close() |
释放所有的资源或挂起内部缓冲区中的更新 |
| Boolean |
exists(Get get) |
检查Get实例所指定的值是否存在于HTable的列中 |
| Result |
get(Get get) |
获取指定行的某些单元格所对应的值 |
| byte[][] |
getEndKeys() |
获取当前一打开的表每个区域的结束键值 |
| ResultScanner |
getScanner(byte[] family) |
获取当前给定列族的scanner实例 |
| HTableDescriptor |
getTableDescriptor() |
获取当前表的HTableDescriptor实例 |
| byte[] |
getTableName() |
获取表名 |
| static boolean |
isTableEnabled(HBaseConfiguration conf, String tableName) |
检查表是否有效 |
| vo |