十五、HBase客户端API

深藏阁楼爱情的钟 2022-05-19 09:50 219阅读 0赞

本章介绍用于对HBase表上执行CRUD操作的HBase Java客户端API。 HBase是用Java编写的，并具有Java原生API。因此，它提供了编程访问数据操纵语言(DML)。

## HBaseConfiguration类 ##

添加 HBase 的配置到配置文件。这个类属于org.apache.hadoop.hbase包。

### 方法及说明 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>方法及说明</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>static org.apache.hadoop.conf.Configuration create()</strong></p> <p>此方法创建使用HBase的资源配置</p> </td> 
  </tr> 
 </tbody> 
</table>

## HTable类 ##

HTable表示HBase表中HBase的内部类。它用于实现单个HBase表进行通信。这个类属于org.apache.hadoop.hbase.client类。

### 构造函数 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>HTable()</strong></p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>HTable(TableName tableName, ClusterConnection connection, ExecutorService pool)</strong></p> <p>使用此构造方法，可以创建一个对象来访问HBase表。</p> </td> 
  </tr> 
 </tbody> 
</table>

### 方法及说明 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>void close()</strong></p> <p>释放HTable的所有资源</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>void delete(Delete delete)</strong></p> <p>删除指定的单元格/行</p> </td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td> <p><strong>boolean exists(Get get)</strong></p> <p>使用这个方法，可以测试列的存在，在表中，由Get指定获取。</p> </td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td> <p><strong>Result get(Get get)</strong></p> <p>检索来自一个给定的行某些单元格。</p> </td> 
  </tr> 
  <tr> 
   <td>5</td> 
   <td> <p><strong>org.apache.hadoop.conf.Configuration getConfiguration()</strong></p> <p>返回此实例的配置对象。</p> </td> 
  </tr> 
  <tr> 
   <td>6</td> 
   <td> <p><strong>TableName getName()</strong></p> <p>返回此表的表名称实例。</p> </td> 
  </tr> 
  <tr> 
   <td>7</td> 
   <td> <p><strong>HTableDescriptor getTableDescriptor()</strong></p> <p>返回此表的表描述符。</p> </td> 
  </tr> 
  <tr> 
   <td>8</td> 
   <td> <p><strong>byte[] getTableName()</strong></p> <p>返回此表的名称。</p> </td> 
  </tr> 
  <tr> 
   <td>9</td> 
   <td> <p><strong>void put(Put put)</strong></p> <p>使用此方法，可以将数据插入到表中。</p> </td> 
  </tr> 
 </tbody> 
</table>

## Put类 ##

此类用于为单个行执行PUT操作。它属于org.apache.hadoop.hbase.client包。

### 构造函数 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数和描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Put(byte[] row)</strong></p> <p>使用此构造方法，可以创建一个将操作指定行。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>Put(byte[] rowArray, int rowOffset, int rowLength)</strong></p> <p>使用此构造方法，可以使传入的行键的副本，以保持到本地。</p> </td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td> <p><strong>Put(byte[] rowArray, int rowOffset, int rowLength, long ts)</strong></p> <p>使用此构造方法，可以使传入的行键的副本，以保持到本地。</p> </td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td> <p><strong>Put(byte[] row, long ts)</strong></p> <p>使用此构造方法，我们可以创建一个Put操作指定行，用一个给定的时间戳。</p> </td> 
  </tr> 
 </tbody> 
</table>

### 方法 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>方法及描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Put add(byte[] family, byte[] qualifier, byte[] value)</strong></p> <p>添加指定的列和值到 Put 操作。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>Put add(byte[] family, byte[] qualifier, long ts, byte[] value)</strong></p> <p>添加指定的列和值，使用指定的时间戳作为其版本到Put操作。</p> </td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td> <p><strong>Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value)</strong></p> <p>添加指定的列和值，使用指定的时间戳作为其版本到Put操作。</p> </td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td> <p><strong>Put add(byte[] family, ByteBuffer qualifier, long ts, ByteBuffer value)</strong></p> <p>添加指定的列和值，使用指定的时间戳作为其版本到Put操作。</p> </td> 
  </tr> 
 </tbody> 
</table>

## Get类 ##

此类用于对单行执行get操作。这个类属于org.apache.hadoop.hbase.client包。

### 构造函数 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数和描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Get(byte[] row)</strong></p> <p>使用此构造方法，可以为指定行创建一个Get操作。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td><strong>Get(Get get)</strong></td> 
  </tr> 
 </tbody> 
</table>

### 方法 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数和描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Get addColumn(byte[] family, byte[] qualifier)</strong></p> <p>检索来自特定列家族使用指定限定符</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>Get addFamily(byte[] family)</strong></p> <p>检索从指定系列中的所有列。</p> </td> 
  </tr> 
 </tbody> 
</table>

## Delete类 ##

这个类用于对单行执行删除操作。要删除整行，实例化一个Delete对象用于删除行。这个类属于org.apache.hadoop.hbase.client包。

### 构造函数 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造方法和描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Delete(byte[] row)</strong></p> <p>创建一个指定行的Delete操作。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>Delete(byte[] rowArray, int rowOffset, int rowLength)</strong></p> <p>创建一个指定行和时间戳的Delete操作。</p> </td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td> <p><strong>Delete(byte[] rowArray, int rowOffset, int rowLength, long ts)</strong></p> <p>创建一个指定行和时间戳的Delete操作。</p> </td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td> <p><strong>Delete(byte[] row, long timestamp)</strong></p> <p>创建一个指定行和时间戳的Delete操作。</p> </td> 
  </tr> 
 </tbody> 
</table>

### 方法 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造方法和描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Delete addColumn(byte[] family, byte[] qualifier)</strong></p> <p>删除指定列的最新版本。</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>Delete addColumns(byte[] family, byte[] qualifier, long timestamp)</strong></p> <p>删除所有版本具有时间戳小于或等于指定的时间戳的指定列。</p> </td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td> <p><strong>Delete addFamily(byte[] family)</strong></p> <p>删除指定的所有列族的所有版本。</p> </td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td> <p><strong>Delete addFamily(byte[] family, long timestamp)</strong></p> <p>删除指定列具有时间戳小于或等于指定的时间戳的列族。</p> </td> 
  </tr> 
 </tbody> 
</table>

## Result类 ##

这个类是用来获取Get或扫描查询的单行结果。

### 构造函数 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>构造函数</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>Result()</strong></p> <p>使用此构造方法，可以创建无Key Value的有效负载空的结果;如果调用Cells()返回null。</p> </td> 
  </tr> 
 </tbody> 
</table>

### 方法 ###

<table> 
 <tbody> 
  <tr> 
   <th>S.No.</th> 
   <th>方法及描述</th> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td> <p><strong>byte[] getValue(byte[] family, byte[] qualifier)</strong></p> <p>此方法用于获取指定列的最新版本</p> </td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td> <p><strong>byte[] getRow()</strong></p> <p>此方法用于检索对应于从结果中创建行的行键。</p> </td> 
  </tr> 
 </tbody> 
</table>