내가지도 내가 감속기의 출력을 원하는이입력/출력 흐름은
-지도에서> reduce->지도
처럼 체인을 줄일 수있는지도 감소 chaining.i에 대한 도움이 필요 체인 감소 마지막 매퍼에서 사용할 수
예를 들어, 내 감속기에서 나는 직원의 최대 급여를 받고 있는데이 값은 다음 매퍼에서 사용되고 그 최대 급여 value.so와 함께 레코드를 찾을 수 있습니다 내 마지막 매퍼는 감속기의 출력과 파일의 내용을 가져와야합니까? 가능합니까? if if can 문제는 무엇인가? 더 좋은 해결책은 무엇입니까?
나는이 문제를 이해하고 있는지 확신 할 수 없지만 도움을 주겠다.
직원 급여가 포함 된 일부 입력 (input1이라고 부름)을
Key: someEmployee Value: max salary과 같은 출력 (출력 1로 지정할 수 있음)으로 축소했습니다.
이제 다른 매퍼가 input1과 output1의 데이터를 매핑해야합니까?
만약 그렇다면, u 옵션이 거의없는 것, 필요에 따라 하나를 선택할 수 있습니다.
첫 번째 감속기 출력을 조작하십시오. 예를 들어Key: someEmployee Value: [email protected]@salary_1,salary_2,salary_3...salary_n
형식의 output1을 생성하고 새 작업을 생성 한 다음 새 매퍼 입력을 output1로 설정하십시오.
하는 하나 매퍼에 여러 개의 입력을 얻는 방법을 설명 this issue를 읽어보십시오
내 감속기의 최대 급여,이 최대 급여를 찾을 수 있도록 하란으로 어려움을 겪고, 하둡 새로운 스피 죄송 내용 파일의 다음 매퍼에 대한 입력, 그래서 내가 최대 연봉과 기록을 찾을 수 있어야합니다. – user1585111
첫 번째 솔루션은 정확히 무엇이 필요합니다. 다른 mapreduce 작업을 만들고 첫 번째 단계에서 생성 된 출력 파일을 입력으로 입력하십시오. – Roy
내 대답이 도움이 되었습니까? 다른 거 필요해? 그렇지 않다면, 마크는 대답입니다. – Roy