HBase 客户端 API
本章描述了用于 HBase 的 java 客户端 API，用于执行 CRUD 对 HBase 表的操作。 HBase 是用 Java 编写的，并具有 Java Native API。因此，它提供了对数据操作语言 (DML) 的编程访问。
类 HBase 配置
将 HBase 配置文件添加到配置中。这个类属于 org.apache.hadoop.hbase package.
方法和说明
| S.No. | 方法和描述 |
|---|---|
| 1 |
静态 org.apache.hadoop.conf.Configuration create() 此方法使用 HBase 资源创建配置。 |
HTable 类
HTable 是一个 HBase 内部类，代表一个 HBase 表。它是用于与单个 HBase 表通信的表的实现。这个类属于 org.apache.hadoop.hbase.client class.
构造函数
| S.No. | 构造函数和描述 |
|---|---|
| 1 |
HTable() |
| 2 |
HTable(TableName tableName, ClusterConnection 连接, ExecutorService pool) 使用此构造函数，你可以创建一个对象来访问 HBase 表。 |
方法和说明
| S.No. | 方法和描述 |
|---|---|
| 1 |
void close() 释放 HTable 的所有资源。 |
| 2 |
void delete(Delete delete) 删除指定的单元格/行。 |
| 3 |
boolean exists(Get get) 使用此方法，你可以测试表中是否存在由 Get 指定的列。 |
| 4 |
结果获取(获取获取) 从给定行中检索某些单元格。 |
| 5 |
org.apache.hadoop.conf.Configuration getConfiguration() 返回此实例使用的配置对象。 |
| 6 |
表名 getName() 返回此表的表名实例。 |
| 7 |
HTableDescriptor getTableDescriptor() 返回此表的表描述符。 |
| 8 |
字节[] getTableName() 返回此表的名称。 |
| 9 |
void put(Put put) 使用此方法，你可以将数据插入表中。 |
类看跌期权
此类用于对单行执行 Put 操作。它属于 org.apache.hadoop.hbase.client package.
构造函数
| S.No. | 构造函数和描述 |
|---|---|
| 1 |
放(字节[]行) 使用此构造函数，你可以为指定的行创建一个 Put 操作。 |
| 2 |
放(字节[] rowArray，int rowOffset，int rowLength) 使用此构造函数，你可以复制传入的行键以保留本地。 |
| 3 |
Put(byte[] rowArray, int rowOffset, int rowLength, long ts) 使用此构造函数，你可以复制传入的行键以保留本地。 |
| 4 |
Put(byte[] 行，长 ts) 使用这个构造函数，我们可以使用给定的时间戳为指定的行创建一个 Put 操作。 |
Methods
| S.No. | 方法和描述 |
|---|---|
| 1 |
把 add(byte[] family, byte[] qualifier, byte[] value) 将指定的列和值添加到此 Put 操作。 |
| 2 |
把 add(byte[] family, byte[] qualifier, long ts, byte[] value) 将指定的列和值以及指定的时间戳作为其版本添加到此 Put 操作。 |
| 3 |
put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) 将指定的列和值以及指定的时间戳作为其版本添加到此 Put 操作。 |
| 4 |
put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value) 将指定的列和值以及指定的时间戳作为其版本添加到此 Put 操作。 |
类获取
此类用于对单行执行 Get 操作。这个类属于 org.apache.hadoop.hbase.client package.
构造函数
| S.No. | 构造函数和描述 |
|---|---|
| 1 |
获取(字节 [] 行) 使用此构造函数，你可以为指定行创建 Get 操作。 |
| 2 | 得到(得到) |
Methods
| S.No. | 方法和描述 |
|---|---|
| 1 |
获取 addColumn(byte[] family, byte[] qualifier) 从具有指定限定符的特定族中检索列。 |
| 2 |
获取 addFamily(byte[] family) 检索指定族的所有列。 |
类删除
此类用于对单行执行删除操作。要删除整行，请使用要删除的行实例化 Delete 对象。这个类属于 org.apache.hadoop.hbase.client package.
构造函数
| S.No. | 构造函数和描述 |
|---|---|
| 1 |
删除(字节 [] 行) 为指定行创建删除操作。 |
| 2 |
删除(字节[] rowArray，int rowOffset，int rowLength) 为指定的行和时间戳创建删除操作。 |
| 3 |
Delete(byte[] rowArray, int rowOffset, int rowLength, long ts) 为指定的行和时间戳创建删除操作。 |
| 4 |
删除(byte[] 行，长时间戳) 为指定的行和时间戳创建删除操作。 |
Methods
| S.No. | 方法和描述 |
|---|---|
| 1 |
删除 addColumn(byte[] family, byte[] qualifier) 删除指定列的最新版本。 |
| 2 |
删除 addColumns(byte[] family, byte[] qualifier, long timestamp) 删除时间戳小于或等于指定时间戳的指定列的所有版本。 |
| 3 |
删除 addFamily(byte[] family) 删除指定族的所有列的所有版本。 |
| 4 |
删除 addFamily(byte[] family, long timestamp) 删除时间戳小于或等于指定时间戳的指定族的所有列。 |
班级成绩
此类用于获取 Get 或 Scan 查询的单行结果。
构造函数
| S.No. | 构造函数 |
|---|---|
| 1 |
Result() 使用此构造函数，你可以创建一个没有 KeyValue 有效负载的空 Result；如果你调用原始 Cells()，则返回 null。 |
Methods
| S.No. | 方法和描述 |
|---|---|
| 1 |
byte[] getValue(byte[] family, byte[] qualifier) 此方法用于获取指定列的最新版本。 |
| 2 |
字节[] getRow() 此方法用于检索与创建此 Result 的行相对应的行键。 |