爲什麼PIG FILTER不會返回？

Question

嗨有人知道爲什麼FILTER命令在下面的代碼中什麼都不返回？謝謝你！

data = LOAD 'sample1.txt' 
     AS (campaign_id:chararray, 
     date:chararray, 
     time:chararray, 
     keyword:chararray, 
     display_site:chararray, 
       placement:chararray, 
     was_clicked:int, 
     cpc:int); 

count1 = FOREACH (GROUP data ALL) GENERATE COUNT(data); 
DUMP count1; 


clicked = FILTER data BY (was_clicked==1); 

DUMP clicked; 
count2 = FOREACH (GROUP clicked ALL) GENERATE COUNT(clicked); 
DUMP count2; 

我想DUMP data，並看到有一些記錄與（was_clicked == 1）。 DUMP count1顯示（100），如預期。

DUMP clicked什麼也沒有顯示。 DUMP count2什麼都沒顯示。

我叫以本地模式.pig文件：$ pig -x local analysis1.pig

Answer 1

我沒有看到腳本中的任何問題。它的工作正常。你可以粘貼你的樣本輸入嗎？

input.txt 
aaa,1234,5678,bbb,ccc,ddd,2,100 
zzz,1234,5678,bbb,ccc,ddd,1,100 
xxx,1234,5678,bbb,ccc,ddd,1,100 
yyy,1234,5678,bbb,ccc,ddd,2,100 
jjj,1234,5678,bbb,ccc,ddd,1,100 
kkk,1234,5678,bbb,ccc,ddd,4,100 

PigScript：

data = LOAD 'input.txt' using PigStorage(',') 
     AS (campaign_id:chararray, 
     date:chararray, 
     time:chararray, 
     keyword:chararray, 
     display_site:chararray, 
     placement:chararray, 
     was_clicked:int, 
     cpc:int); 
count1 = FOREACH (GROUP data ALL) GENERATE COUNT(data); 
dump count1; 
clicked = FILTER data BY (was_clicked==1); 
dump clicked; 
count2 = FOREACH (GROUP clicked ALL) GENERATE COUNT(clicked); 
dump count2; 

output of count1: 
(6) 

Output of clicked: 
(zzz,1234,5678,bbb,ccc,ddd,1,100) 
(xxx,1234,5678,bbb,ccc,ddd,1,100) 
(jjj,1234,5678,bbb,ccc,ddd,1,100) 

Output of count2: 
(3)