2017-02-24 108 views
0

在問這個問題之前,我搜尋了很多東西來解決下面的問題,但無法解決,如果有人可以幫助解決這個問題。無法使用Java連接到HBase?

我已經安裝了hadoop1 2.5.0和HBase 0.98.6(在pseudo dist模式下)。我試圖運行一個簡單的java程序從hbase中檢索數據。我的所有節點都在運行。 我的代碼是 -

Configuration conf = HBaseConfiguration.create(); 
conf.set("hbase.master","hadoopHost:60000"); 
conf.set("hbase.zookeeper.quorum", hBaseZookeeperHostName); 
conf.set("hbase.zookeeper.property.clientPort", "2181"); 
System.out.println("hello"); 
HTableInterface table = HConnectionManager.createConnection(conf).getTable("user".getBytes()); 
System.out.println(table.getTableDescriptor().getColumnFamilies().toString()); 

在打印打招呼,之後其被卡住了一段時間,結束根本沒有任何錯誤或警告。

我對這個大數據世界非常陌生,如果有人能夠把他/她的時間解決這個問題。

回答

0

有兩種方法可以爲HBase連接創建配置。

  1. 我們可以在您的Class中使用下面的行來創建一個連接,然後在您的classpath中設置hbase-site.xml。

    配置conf = HBaseConfiguration.create; HTableInterface table = HConnectionManager.createConnection(conf).getTable(「user」.getBytes());

通過這種方式,hbase-site.xml中定義的值將用於創建連接。

  • 如果要覆蓋HBase的-site.xml中可以從類路徑除去HBase的-site.xml中的值和設定的參數根據需要像你在上面提到碼。
  • 由於您試圖使用默認值,我建議您去選擇一個。