왜 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 아무 것도 표시되지 않았습니다. 내가 스크립트에서 문제를 볼 didnt는 $ pig -x local analysis1.pig

Answer 1

:

나는 로컬 모드에서 .pig 파일을했다. 잘 작동합니다. 샘플 입력을 붙여 넣을 수 있습니까?

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)