导图社区 HBase Java API
HBase是用Java语言编写的,所以它提供了Java API与HBase进行通信,常用的方法以及增删改查的操作。
编辑于2021-11-08 10:57:34HBase Java API
HBaseAdmin类
操作HBase
用来管理表
从属于
org.apache.hadoop.hbase.client
常用方法
void createTable(HTableDescriptor desc)
创建一个新的表
void createTable(HTableDescriptor desc,byte[][] splitKeys)
创建一个新表使用一组初始指定的分割键限定空区域
void deleteColumn(byte[] tableName, String columnName)
从表中删除列
void deleteColumn(String tableName,String columnName)
删除表中的列
void deleteTable(tableName)
删除表
Descriptor类
包含一个HBase的表结构信息
常用方法
HTableDescriptor addFamily(HColumnDescriptor family)
列家族给定的描述符
HBaseConfiguration类
添加HBase的配置文件
从属于
org.apache.hadoop.hbase
常用方法
static org.apache.hadoop.conf.Configuration create()
此方法创建使用HBase的资源配置
HTable类
HBase表中HBase的内部类
用于实现单个HBase表进行通信
从属于
org.apache.hadoop.hbase.client
常用方法
void close()
释放HTable的所有资源
void delete(Delete delete)
删除指定的单元格/行
boolean exists(Get get)
使用这个方法,可以测试列的存在,在表中,由Get指定获取
Result get(Get get)
检索给定的单元格
org.apache.hadoop.conf.Configuration getConfiguration()
返回此实例的配置对象
TableName getName()
返回此表的表名称实例
HTableDescriptor getTableDescriptor()
返回此表的表描述符
byte[] getTableName()
返回此表的名称
void put(Put put)
使用此方法,可以将数据插入到表中
Put类
用于为单个行执行Put操作
从属于
org.apache.hadoop.hbase.client
常用方法
Put add(byte[] family, byte[] qualifier, byte[] value)
添加指定的列和值到Put操作
Put add(byte[] family, byte[] qualifier, long ts, byte[] value)
添加指定的列和值,使用指定的时间戳作为其版本到Put操作
Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value )
添加指定的列和值,使用指定的时间戳作为其版本到Put操作
Get类
对于单行执行get操作
从属于
org.apache.hadoop.hbase.client
常用方法
Get add(byte[] family, byte[] qualifier)
检索来自特定列家族使用中指定限定符
Get addFamily(byte[] family)
检索指定系列中的所有列
Delete类
对于单行执行删除操作
要删除整行,实例化一个Delete对象用于删除行
从属于
org.apache.hadoop.hbase.client
常用方法
Delete addColumn(byte[] family, byte[] qualifier)
删除指定列的最新版本
Delete addColumn(byte[] family, byte[] qualifier, long timestamp)
删除所有版本具有时间戳小于或等于指定时间戳的指定列
Delete addFamily(byte[] family)
删除指定的所有列族的所有版本
Delete addFamily(byte[] family, long timestamp)
删除指定列具有时间戳小于或等于指定时间戳的列族
Result类
获取Get或扫描查询的单行结果
常用方法
byte[] getValue(byte[] family, byte[] qualifier)
此方法用于获取指定列的最新版本
byte[] getRow()
此方法用于检索对应于从结果中创建行的行键