사용 필터는

Question

내가 돼지 라틴어로 초보자입니다 실패와 나는 FILTER 문에 대한 문제를 발견했다. 예 봐 :

1,2,3 
2,3,4 
3,4,5 
4,5,6 

내가 그의 첫 번째 필드 '3'인 레코드를 선택합니다 :

우리가 내용이있는 데이터 파일 (TEST.TXT)가 가정하자. 돼지 스크립트는 다음과 같습니다.

t = LOAD 'test.txt' USING PigStorage(','); 
t1 = FOREACH t GENERATE $0 AS i0:chararray, $1 AS i1:chararray, $2 AS i2:chararray; 
f1 = FILTER t1 BY i0 == '3'; 
DUMP f1 

작업은 성공적으로 실행되지만 출력 결과는 아무 것도 아닙니다. F1 쇼를 EXPLAIN :

#-------------------------------------------------- 
# Map Reduce Plan         
#-------------------------------------------------- 
MapReduce node scope-27 
Map Plan 
f1: Store(fakefile:org.apache.pig.builtin.PigStorage) - scope-26 
| 
|---f1: Filter[bag] - scope-22 
    | | 
    | Equal To[boolean] - scope-25 
    | | 
    | |---Project[chararray][0] - scope-23 
    | | 
    | |---Constant(3) - scope-24 
    | 
    |---t1: New For Each(false,false,false)[bag] - scope-21 
     | | 
     | Project[bytearray][0] - scope-15 
     | | 
     | Project[bytearray][1] - scope-17 
     | | 
     | Project[bytearray][2] - scope-19 
     | 
     |---t: Load(file:///Users/woody/test.txt:PigStorage(',')) - scope-14-------- 
Global sort: false 
---------------- 

을 그러나, 나는에 머리 2 개 라인을 변경하는 경우 :

t1 = LOAD 'test.txt' USING PigStorage(',') AS (i0:chararray, i1:chararray, i2:chararray) 

이 작업은 잘 작동하고 결과가 (즉, LOAD 문에서 스키마를 지정) 또한 맞습니다. 이 경우 EXPLAIN f1은 다음을 표시합니다.

#-------------------------------------------------- 
# Map Reduce Plan         
#-------------------------------------------------- 
MapReduce node scope-33 
Map Plan 
f1: Store(fakefile:org.apache.pig.builtin.PigStorage) - scope-32 
| 
|---f1: Filter[bag] - scope-28 
    | | 
    | Equal To[boolean] - scope-31 
    | | 
    | |---Project[chararray][0] - scope-29 
    | | 
    | |---Constant(3) - scope-30 
    | 
    |---t1: New For Each(false,false,false)[bag] - scope-27 
     | | 
     | Cast[chararray] - scope-19 
     | | 
     | |---Project[bytearray][0] - scope-18 
     | | 
     | Cast[chararray] - scope-22 
     | | 
     | |---Project[bytearray][1] - scope-21 
     | | 
     | Cast[chararray] - scope-25 
     | | 
     | |---Project[bytearray][2] - scope-24 
     | 
     |---t1: Load(file:///Users/woody/test.txt:PigStorage(',')) - scope-17-------- 
Global sort: false 
---------------- 

돼지의 버그입니까? 또는 그것을 피할 수있는 좋은 방법이 있습니까? 내 컴퓨터에

돼지 --version은 다음과 같습니다

Apache Pig version 0.9.2 (r1232772) 
compiled Jan 18 2012, 07:57:19 

Answer 1

은 내가 생성이이 데이터 유형을 제공하지만, 실제의 캐스팅을 수행하지 않는 것을 알고

GENERATE $0 AS i0:chararray 

당신 수동으로 전송해야합니다.

t1 = FOREACH t GENERATE (chararray) $0 AS i0, (chararray) $1 AS i1, (chararray) $2 AS i2; 

이것은 직관력이 떨어지며 아마도 버그 일 수 있습니다.

Answer 2

흥미롭게도,이 정말 버그가 아닙니다, 그래서 알려진 문제 및 '해결되지 않습니다'로 간주 것으로 보인다. 그것은 이상한 행동이며 FILTER 기능 사용과 관련하여 과거에 경험했던 약간의 유익 함을 설명하는 것 같습니다.

다음과 비슷하고, 주석 스트림 '해결되지 않습니다'폐쇄되었습니다 https://issues.apache.org/jira/browse/PIG-1341

가 부하시 캐스트에 미묘한 차이가있을 나타나지 않으며, 이것은 다른 사람들을 도울 수 http://ofps.oreilly.com/titles/9781449302641/data_model.html#type_strength

이전의 대답은 자리 -에 있습니다 - 내가 그것을 예상 된 결과를 반환 않습니다 확인했습니다.

이

명시 적으로 미래에 더 캐스팅 저를 묻는 메시지를 표시 할 수 있습니다 - 좋은 질문과 대답을. 아무 것도 추가하지 않아서 죄송합니다.하지만 게시 할 주제가 충분하다고 생각했습니다.

Answer 3

이 작동합니다 :

톤 = LOAD '테스트를.txt 'USING PigStorage (', ') AS (i0 : int, i1 : int, i2 : int);

t = FILTER t BY i0 == 3;

덤프 t;