2014-10-22 3 views
0

Accumulator 인터페이스를 구현하는 UDF를 작성했습니다. 그러나 내 UDF가 작동하려면 들어오는 관계를 정렬해야합니다. 나는 차 종류와이 관리하고있어 다음 Accumulator 문서 당Pig Accumulator는 주문할 수있는 입력 튜플입니까?

out = FOREACH (GROUP test BY key) { 
    sorted = ORDER test BY sub_key; 
    GENERATE MyUDF(sorted); 
} 

, 내 UDF 증분 가방 시리즈를 기대하고있다. 내 UDF가 튜플을 유지 보수하는 총 순서는 유지됩니까? 나는. 각 증분 부대는 내부적으로 주문되었으며 증분 부대가 주문 된 순서입니까?

테스트 할 때 모든 것이 주문되어있는 것처럼 보이지만 돼지 문서가 가방을 "정렬되지 않은"것으로 설명하므로 확신하고 싶습니다.

답변

0

ORDER 연산자를 사용하여 가방 안의 튜플을 정렬 했으므로 UDF는 정렬 된 '정렬 된'가방 안의 튜플을 받게됩니다.