認爲這是我的投入,如何在PIG中使用FILTER獲取for循環中的匹配值?
Input (File1):
12345;11
34567;12
.
.
Input (File2):
11;(1,2,3,4,5,6,7,8,9)
12;(9,8,7,6,5,4,3,2,1)
.
.
我希望得到的輸出如下:
Output:
(1,2,3,4,5,6,7,8,9)
(9,8,7,6,5,4,3,2,1)
下面是我所使用FILTER嘗試示例代碼和我面對這一些錯誤。請建議我一些其他選項。
data1 = load '/File1' using PigStorage(';') as (id,number);
data2 = load '/File2' using PigStorage(';') as (numberInfo, collection);
out = foreach data1{
Data_filter = FILTER data2 by (numberInfo matches CONCAT(number,''));
generate Data_filter;
}
是否可以在for循環中執行此操作?請告訴我。提前致謝 !