2014-05-19 3 views
-2

mapreduce 프로그램에서 두 개의 서로 다른 reduce 함수를 사용하고 싶습니다. 각각은 자체 서명이 있습니다. 서로 다른 서명은 예상되는 다른 키 객체에 있습니다. 할 수 있습니까? 어떻게?Mapreduce에서 두 가지 다른 reduce 함수 사용

+0

당신이하려는 일에 대해 좀 더 구체적으로 밝혀야합니다. 단일 '직업'에 여러 개의 감속기를 의미합니까? 그렇다면 가장 가까운 곳은 아마도 'ChainReducer'와 같은 것일 것입니다. – azurefrog

답변

0

MultipleOutputs 클래스와 단일 감속기를 사용하십시오. 감속기에 대한 출력 키/값 유형 및 출력 형식을 정의해야하지만 Multiple Outputs 클래스의 정적 메서드 호출을 통해 두 가지 출력 (유형이 서로 다름)을 구성합니다. 그런 다음 감속기에 MultipleOutputs 인스턴스를 구성하고 해당 인스턴스를 사용하여 키/값 쌍을 작성합니다. javadoc에는 매우 유용한 예제가 있습니다.

관련 문제