input1 = load 'your_path' as (key: chararray);
input2 = load 'your_path' as (key: chararray);
cross_results = cross input1, input2;
final_results = filter cross_results by input1::key < input2::key;
如果“a、b、c”只是一个记录中的一个包,则可以使用 flatten . 例如,
-- Assume your input x is something like {A, B, C} in one row
y = foreach x generate flatten($0) as f1, flatten($0) as f2;
final_results = filter y by f1 < f2;
1条答案
按热度按时间4ioopgfo1#
如果你的意见是
您希望输出:
你可以用
cross
加入以获得结果。例如:如果“a、b、c”只是一个记录中的一个包,则可以使用
flatten
. 例如,由于您的描述不是很详尽,我只能提供上述解决方案。你可能需要调整它。