2017-05-03 14 views
0

私は ".spc"パターンのバイナリファイルを持っています。これらのファイルを豚マッパジョブでHBaseに保存したいと思います。行キーはファイル名です。ブタでhbaseにバイナリファイルを保存する

A = LOAD 'hdfs-directory/sampleID-uvvis.spc' USING BinStorage(); 

B = FOREACH A GENERATE $0 AS rowkey; 

C = GROUP B BY rowkey; 

STORE C INTO 'hbase://test3' USING BinStorage('colfamily:uvis'); 

をそして、私は以下のようなエラーました:私も負荷後のファイルをチェックし

[main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 2116: 
<line 12, column 0> Output Location Validation Failed for: 'hbase://test3 
More info to follow: 
java.io.IOException: No FileSystem for scheme: hbase 

を:

Dump A 
Input(s): 
Successfully read 0 records (3353 bytes) from: "hdfs-directory-uvvis.spc" 

Output(s): 
Successfully stored 0 records in: "hdfs-directory/tmp/temp- 
707332811/tmp1004712115" 

誰かが助けることができる。ここ

は、私が使用するコマンドは、私にこの問題がありますか? HBaseにバイナリファイルをロードして保存するには?

私はHBaseと豚の仕事に新しいです、任意のアイデアをいただければ幸いです。

答えて

0

org.apache.pig.backend.hadoop.hbase.HBaseStorageクラスのストレージを使用する必要があります。この例を見てみ

https://pig.apache.org/docs/r0.14.0/api/org/apache/pig/backend/hadoop/hbase/HBaseStorage.html

+0

は私が保管するための新しいクラスを使用しようとした、返信していただきありがとうございます。ストレージプロセスが機能します! "入力:" hdfs-directory/sampleID-uvvis.spc "から0レコード(3353バイト)を正常に読み取った 出力( s): 「hbase:// test3」に0レコードが正常に格納されました。 –

関連する問題