私はこのデータをロードしています:
data6 = 'item1' 111 { ('thing1', 222, {('value1'),('value2')}) }
このコマンドの使用
A = load 'data6' as ( item:chararray, d:int, things:bag{(thing:chararray, d1:int, values:bag{(v:chararray)})} );
このコマンド全体を平らにしようとしています。
A_flattened = FOREACH A GENERATE item, d, things::thing AS thing; things::d1 AS d1, FLATTEN(things::values) AS value;
しかし、私はこのエラーを受け取ります:
Invalid field projection. Projected field [things::thing] does not exist in schema: item:chararray,d:int,things:bag{:tuple(thing:chararray,d1:int,values:bag{:tuple(v:chararray)})}
内側のthings
タプルに名前を付けてみましたが、同様のエラーが発生します。誰かがここで正しい構文を教えてくれますか?