0
Accumulator
인터페이스를 구현하는 UDF를 작성했습니다. 그러나 내 UDF가 작동하려면 들어오는 관계를 정렬해야합니다. 나는 차 종류와이 관리하고있어 다음 Accumulator
문서 당Pig Accumulator는 주문할 수있는 입력 튜플입니까?
out = FOREACH (GROUP test BY key) {
sorted = ORDER test BY sub_key;
GENERATE MyUDF(sorted);
}
, 내 UDF 증분 가방 시리즈를 기대하고있다. 내 UDF가 튜플을 유지 보수하는 총 순서는 유지됩니까? 나는. 각 증분 부대는 내부적으로 주문되었으며 증분 부대가 주문 된 순서입니까?
테스트 할 때 모든 것이 주문되어있는 것처럼 보이지만 돼지 문서가 가방을 "정렬되지 않은"것으로 설명하므로 확신하고 싶습니다.