python - MapReduceジョブでPythonでHBaseをスキャンするには?

Question

mapreduce ジョブの私のプログラムは Python で書かれており、入力として HBase からデータを取得したいと考えています。ネイティブ Java 実装の TableMapper/Reducer など、MapReduce の方法で HBase テーブルのデータをスキャンする方法はありますか。HappyBase は HBase と対話する簡単な方法を提供できることを学びましたが、それはクライアント側でしか機能しません。

Answer 1

HBase からデータを取得する pig スクリプトを作成し、ストリーミングを介して、または jython を使用している場合はUDFを介して Python を統合できます。