0

2 つの load ステートメントAB. それぞれに代理キーがあります。両方のキーが格納されたデータと一致する場合、代理キー列を一致させたいと考えています。

次のコードを試しました。

A = LOAD 'a/data/' using PigStorage('\t') as (SourceWebSite:chararray,PropertyID:chararray,ListedOn:chararray,ContactName:chararray,TotalViews:int,Price:chararray);
B = LOAD 'b/data/' using PigStorage('\t') as (SourceWebsite:chararray,PropertyType:chararray,IPLSNO:int,Locality:chararray,City:chararray,Price:chararray);
C = COGROUP A BY Price, B BY Price;
D = FOREACH C GENERATE FLATTEN((IsEmpty(A) ? null : A)), FLATTEN((IsEmpty(B) ? null : B));

上記のコマンドは、すべてのデータを出力します。

4

1 に答える 1