2

によってSequenceFile形式でS3に保存されたjsonデータ形式がありますsecor。Pigを使って分析したい。を使用しelephant-birdて、S3 からフォーマットで取得できましたが、Json を解析するために明らかに必要な にbytearray変換できませんでした。chararray

%declare SEQFILE_LOADER 'com.twitter.elephantbird.pig.load.SequenceFileLoader';
%declare LONG_CONVERTER 'com.twitter.elephantbird.pig.util.LongWritableConverter';
%declare BYTES_CONVERTER 'com.twitter.elephantbird.pig.util.BytesWritableConverter';
%declare TEXT_CONVERTER 'com.twitter.elephantbird.pig.util.TextConverter';

grunt> A = LOAD 's3n://...logs/raw_logs/...events/dt=2015-12-08/1_0_00000000000085594299'
       USING $SEQFILE_LOADER ('-c $LONG_CONVERTER', '-c $BYTES_CONVERTER')
       AS (key: long, value: bytearray);
grunt> B = LIMIT A 1;
grunt> DUMP B;

(85653965,{"key": "val1", other json data, ...})

grunt> DESCRIBE B;

B: {key: long,value: bytearray}

grunt> C = FOREACH B GENERATE (key, (chararray)value);
grunt> DUMP C;

2015-12-08 19:32:09,133 [main] ERROR org.apache.pig.tools.grunt.Grunt -
   ERROR 1075: Received a bytearray from the UDF or Union from two different Loaders.
   Cannot determine how to convert the bytearray to string.

TextConverterinsted を使用すると、次のBytesWritableConverterような空の値が残ります。

(85653965,)

Pig がバイト配列を文字列にキャストしてダンプできたことは明らかなので、それが不可能であるようには見えません。それ、どうやったら出来るの?

4

0 に答える 0