最近、hbase コプロセッサを学びました。エンドポイントを使用して、hbase テーブルの 1 つの列を蓄積しました。テーブルには、「asset:customer_name」などの他の列があります。私が最初にやりたいことは、「asset:customer_name」ごとに「asset:amount」グループの値を累積することです。しかし、groupby の API がないか、見つかりませんでした。GROUPBY の実装方法や、HBASE が提供する API の使用方法を知っていますか?
3592 次
2 に答える
2
この作業を行うには、エンドポイントを使用する必要があります。
この記事に合計の例があります: https://blogs.apache.org/hbase/entry/coprocessor_introduction。
基本的に追加する必要があるのは、行キーと顧客名を追加して、新しいキー「MyKey」を形成することです。最後に見た MyKey の変数を保持し、現在の MyKey が前の MyKey と異なる場合は、前の MyKey をその合計とともに発行し、前の MyKey を現在の MyKey に上書きする必要があります。
2 つの異なるリージョンの端に顧客がいる可能性があるため、URL で提供されている例で行われているように、クライアント側で集計を実行する必要があります。
于 2013-02-25T16:41:28.883 に答える
0
エンドポイントコプロセッサーを使用すると、それが可能になります。あなたがすべきことは、最初に関連するインターフェースを定義して (reduce) プロトコルが CoprocessorPotocol を拡張し、次にそれを実装し、最後にクライアント側のロジックをコーディングすることです。
于 2013-06-07T02:29:42.820 に答える