通過hive插入從hbase讀取數據的問題

我已經創建了一個hbase-hive表。我通過配置單元插入數據。通過hive插入從hbase讀取數據的問題

CREATE TABLE hivetest(cookie string, timespent string, pageviews string, visit string, logdate string) 
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler' 
WITH SERDEPROPERTIES ("hbase.columns.mapping" = "m:timespent, m:pageviews, m:visit, m:logdate") 
TBLPROPERTIES ("hbase.table.name" = "hbasetest");

數據被正確地插入。我可以使用hbase shell訪問相同的數據。但是，我創建了一個在訪問相同數據時返回空指針異常的hbase客戶端。

現在，如果我創建一個虛擬hbase表，並通過hbase shell將一些數據不通過HIVE，並嘗試從hbase客戶端獲取此數據。它不會給出錯誤並返回數據。此外，如果我嘗試通過hbase客戶端將數據放在hbasetest表的某個行中，然後嘗試獲取同一行，則會發生同樣的情況。現在這次它給了我數據。

所以，我的問題是通過配置單元和hbase shell編寫數據有什麼不同？

HBase的客戶：

Configuration conf = HBaseConfiguration.create(); 
    Map variables = System.getenv(); 
    conf.set("hbase.zookeeper.quorum","192.168.0.92"); 
    HTable table; 
    byte family[]; 
    byte qualifier[];   
    table = new HTable(conf, "hivetest"); 
    family = Bytes.toBytes("m"); 
    qualifier = Bytes.toBytes("logdate");    
    Get get = new Get(Bytes.toBytes("cookie_value"));  
    Result r = table.get(get);   
    byte valueObj[] = r.getValue(family, qualifier);  
    byte keyObj[] = r.getRow(); 
    String key = new String(keyObj); 
    String value = new String(valueObj); /* line where exception occur */ 
    System.out.println((new StringBuilder(String.valueOf(key))).append(" = ").append(value).toString());

例外：

Exception in thread "main" java.lang.NullPointerException 
    at java.lang.String.<init>(Unknown Source) 
    at com.hbase.test.HbaseExample.main(HbaseExample.java:51)

來源

2013-09-24 Naresh

您使用的蜂巢版本0.9.0？如果是這樣，該版本有一個錯誤。 SerDe HBaseStorageHandler不會忽略逗號和列族之間的空格。這使存儲的列族名稱與您所期望的不同。

HbaseExample類中的第51行是？

byte valueObj[] = r.getValue(family, qualifier);

嘗試在SERDEPROPERTIES映射中取消逗號符號和列族之間的空格。

見：https://issues.apache.org/jira/browse/HIVE-3243

來源

2013-09-25 14:59:29 chech0x

感謝很多人.... :) – Naresh

歡迎您... GBY – chech0x

通過hive插入從hbase讀取數據的問題

回答

相關問題