Question

使用HBase Shell读取数据

HTable类的get命令和get()方法用于从HBase中的表读取数据。使用get命令，您一次可以获取一行数据。其语法如下：

get '<table name>','row1'

以下示例显示如何使用get命令。让我们扫描emp表的第一行。

hbase(main):012:0> get 'emp', '1'
COLUMN  CELL
 personal data:city                                timestamp=2021-01-04T09:35:39.345, value=hyderahad
 personal data:designation                         timestamp=2021-01-04T09:36:18.466, value=manager
 personal data:name                               timestamp=2021-01-04T09:38:44.128, value=raju
 personal data:salary                             timestamp=2021-01-04T09:36:42.145, value=50000
1 row(s)
Took 0.4045 seconds

读取指定的列

下面给出的是使用get方法读取特定列的语法。

hbase> get 'table name', 'rowid', {COLUMN ⇒ 'column family:column name'}

下面给出了读取HBase表中特定列的示例。

hbase:006:0> get 'emp','row1', {COLUMN => 'personal data:name'}
COLUMN           CELL
 personal data:name                               timestamp=2021-01-04T10:48:33.531, value=raju
1 row(s)
Took 0.0822 seconds

使用Java API读取数据

要从HBase表读取数据，请使用HTable类的get()方法。此方法需要Get类的实例。请按照下面给出的步骤从HBase表中检索数据。

步骤1：连接

 // Instantiating Configuration class
Configuration config = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(config);

步骤2：Table类

// Instantiating Table class
Table table = connection.getTable(tb);

步骤3：实例化Get类

您可以使用Table类的get()方法从HBase表中检索数据。此方法从给定的行中提取一个单元格。它需要一个Get类对象作为参数。如下所示创建它。

Get get = new Get(toBytes("row1"));

步骤4：读取数据

检索数据时，您可以按ID获得单个行，或按一组行ID获得一组行，或者扫描整个表或行的子集。

您可以使用Get类中的add方法变体检索HBase表数据。
要从特定列族获取特定列，请使用以下方法。

get.addFamily(personal)

要从特定列族获取所有列，请使用以下方法。

get.addColumn(personal, name)

步骤5：获取结果

通过将Get类实例传递给HTable类的get方法来获取结果。此方法返回Result类对象，该对象保存请求的结果。下面给出了get()方法的用法。

Result result = table.get(g);

步骤6：从结果实例中读取值

的结果类提供的getValue()方法来从它的实例中读取的值。如下所示使用它从Result实例读取值。

byte [] value = result.getValue(Bytes.toBytes("personal data"),Bytes.toBytes("name"));
byte [] value1 = result.getValue(Bytes.toBytes("personal data"),Bytes.toBytes("city"));

下面给出的是从HBase表读取值的完整程序。

import java.io.IOException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.client.Result;
public class InsertData {
   public static void main(String[] args) throws IOException {
      // Instantiating Configuration class
      Configuration config = HBaseConfiguration.create();
      Connection connection = ConnectionFactory.createConnection(config);
      TableName tb = TableName.valueOf("emp");
      // Instantiating Table class
      Table table = connection.getTable(tb);
      // Instantiating Get class
      // accepts a row name.
      Get g = new Get(Bytes.toBytes("row1"));
      // Reading the data
      Result result = table.get(g);
      // Reading values from Result class object
      byte[] value = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("name"));
      byte[] value1 = result.getValue(Bytes.toBytes("personal data"), Bytes.toBytes("city"));
      // Printing the values
      String name = Bytes.toString(value);
      String city = Bytes.toString(value1);
      System.out.println("name: " + name + " city: " + city);
   }
}

编译并执行上述程序，如下所示。

$javac RetriveData.java
$java RetriveData

以下应该是输出：

name: Raju city: Delhi