Apache Pig - 특정 경계 내의 중첩 루프

Question

foreach 구문을 사용하여 가방을 반복한다고 가정합니다. 첫 번째 요소를 제외하고 각 요소에 대해 이전 요소를 모두 반복하여 현재 요소까지 반복 할 수 있습니까?

은 쉽게 시각화 할 수 있도록 다음과 같은 가방에 지정된 위치에 도달 한 foreach 루프 고려해야 할 : 나는 루프에서이 시점에서 무엇을 하시겠습니까 무엇

(1, Element1) 
(2, Element2) 
(3, Element3) 
(4, Element4) 
(5, Element5) <-- You are here 
(6, Element6) 
(7, Element7) 

을 통해 또 다른 루프를 실행을 요소 1에서 4까지는 외부 루프가 요소 6으로 진행하고 내부 루프는 요소 1에서 5로 이동합니다.

나는이 기능이 내장 된 구조를 사용하여 달성 될 수 있음을 매우 의심합니다. 이것은 현재 색인과 bag을 인수로 취하는 UDF를 구현함으로써 원하는 처리를 수행하고 결과를 Pig에 리턴 할 수 있습니까?

Answer 1

'vanilla'Pig에서이 작업을 수행 할 수 없습니까? 사용자 정의 UDF를 작성해야합니다. 여기에 몇 가지 시작 지점이 있습니다.

public class MyUDF extends EvalFunc<Long> 
    public Long exec(Tuple input) throws IOException { 
    Object values = input.get(0); 
    if (values instanceof DataBag) { 
     // you logic goes here 
    } 
    return ... 
}