上一节:
下一节:

  HBase 读取数据

  • 使用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表读取值的完整程序。 
    
package com.jc2182.www;

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
上一节:
下一节: