hbase-client

0熱度

1回答

的太多hconnections爲了獲得最大的throughoutput，我使用批處理puts和增量將數據放入HBase的，代碼示例： Configuration configuration = HBaseConfiguration.create(); configuration.set("hbase.zookeeper.quorum", "10.2.1.12:2181"); configur

1熱度

1回答

Spark和Hbase客戶端的版本兼容性

我正在嘗試編寫Spark批處理作業。我想把它打包成一個jar並用spark提交。我的程序完全在火花外殼，但是我得到以下錯誤，當我嘗試用火花運行它提交： Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$.$conforms()Lscala/Predef$$less$colon$less; at HBa

2熱度

1回答

Hbase Table.batch需要300秒將800,000個條目插入表

我正在讀取大小爲30 MB的json文件，並創建列族和鍵值。然後創建Put對象，將rowkey和值插入它。創建這樣的put對象列表並調用Table.batch（）並傳遞該列表。當我的數組列表大小爲50000時，我會調用它。然後清除列表並調用下一批。但是，如果最終有800,000個條目的文件需要300秒才能處理。我也厭倦了table.put，但速度更慢。我正在使用hbase 1.1。我從卡夫卡那裏得

-3熱度

1回答

獲取匹配正則表達式的所有列限定符

是否有可能通過模式匹配獲取所有列限定符的名稱？例如。獲取以myNeeded開頭的所有列的限定符_ 謝謝。