最近我學習了hbase協處理器,我用端點來累計一列hbase表。例如,名爲「pendings」的hbase表,其家族是「資產」,我累計了「asset:amount」的所有值。該表還有其他欄,例如「asset:customer_name」。我想要做的第一件事是通過「asset:customer_name」來累計「asset:amount」組的值。但是我發現groupby沒有API,或者我沒有找到它。你知道如何實現GROUPBY或者如何使用HBASE提供的API嗎?如何使用hbase協處理器來實現groupby?
2
A
回答
1
您應該使用端點來完成這項工作。
你在這篇文章中有一個總和的例子:https://blogs.apache.org/hbase/entry/coprocessor_introduction。
你基本上需要添加的是追加你的行鍵和客戶名稱,形成你的新密鑰「MyKey」。您應該保留上次看到的MyKey的變量,並且當前的MyKey與前一個MyKey不同時,您應該發出前一個與其總和並覆蓋以前的MyKey到當前的MyKey。
您必須確保在客戶端執行聚合,因爲您可以在URL中提供的示例中完成聚合,因爲您可能在兩個不同區域的邊緣有客戶。
0
使用端點協處理器可以做到這一點。你應該做的就是:首先定義相關接口(reduce)協議擴展CoprocessorProtocol,然後對其進行實現,最後編寫客戶端邏輯。
相關問題
- 1. HBase的InternalScanner和過濾協處理器
- 2. HBase內部加入和協處理器
- 3. 如何在zynq 7020上使用C/C++實現FPGA協處理?
- 4. 如何在hbase協處理器中攔截掃描
- 5. 如何協處理器部署到CDH4 HBase的集羣
- 6. 如何使用webgl實現批處理?
- 7. 使用DDD,如何實現批處理?
- 8. thrift hbase客戶端 - 支持過濾器和協處理器
- 9. GroupBy:如何處理空組?
- 10. 任何方式實現與HBase中的checkAndPut一起批處理
- 11. 來自intel的Xeon處理器的協處理器架構
- 12. Aerospike是否有類似HBase的協處理器?
- 13. HBase 0.92是否支持協處理器二級索引?
- 14. 如何使用openssl使用霓虹協處理器?
- 15. 如何使用jQuery DataTables插件實現服務器端處理?
- 16. 如何使用WebRTC實現HTTP協議?
- 17. 如何使用gdb轉儲ARM協處理器寄存器?
- 18. 下載處理器實現
- 19. 如何使用角度js來處理多個請求來實現進度條?
- 20. 如何在XSLT處理器中使用HTML5的「about:」協議
- 21. nCache的通用型處理器實現
- 22. 如何使用C#實現IMAP協議(服務器端)#
- 23. 如何實現協議
- 24. 理解協議實現與例如UIAlertViewDelegate
- 25. Hbase如何處理重複記錄?
- 26. 如何使用wait通知處理器來停止invokehttp處理器?
- 27. 如何在LINQ中實現groupby
- 28. 如何在HBase中實現分頁?
- 29. 如何實現Android和HBase連接?
- 30. 使用Spring批處理實現ETL