현재 Disco에서 PageRank를 구현 중입니다. 반복 알고리즘으로서, 하나의 반복의 결과는 다음 반복의 입력으로 사용됩니다. 모든 링크를 나타내는 큰 파일이 있습니다. 각 파일은 각 행이 페이지를 나타내며 링크의 값을 나타냅니다. Disco의 경우이 파일을 N 개의 청크로 분해 한 다음 MapReduce를 한 번 실행합니다. 결과적으로, 나는 (페이지
주어진 알고리즘에 대한 데이터를 집계해야하므로 내 알고리즘에서 현재 nr_reduces 1을 사용합니다. 입력을 다음 반복에 전달하려면 "chain_reader"를 사용해야합니다. 그러나 매퍼의 결과는 단일 결과 목록이므로 다음 맵 반복은 단일 매퍼로 수행됩니다. 여러 매퍼를 트리거하기 위해 결과를 분할하는 방법이 있습니까?