2012-09-07 3 views
0

매퍼는이 두 번을 호출합니다.Mapper output.collect()?

out.collect(new Text("Car"),new Text("Subaru"); 
out.collect(new Text("Cr-v"),new Text("Honda"); 

reduce()도 두 번 호출됩니까?

+0

더 많은 문맥을 제공 할 수 있습니까? 저는 하둡 (Hadoop) 직업에 대해 이야기하고 있다고 가정합니다. 그러나 세부 사항이 없으면 당신이 말하는 것에 대해 생각해 내기가 어렵습니다. –

+0

그 하둡 욥 – user1647267

답변

2

난 당신이 한 쌍의 각 [키 (값 목록)]에 대해 한 번에 대한 OutputCollector.collect(K,V)?

reduce() 호출되는 얘기 가정합니다. 설명하기 위해, 당신이라고 가정 해 봅시다 :

다음 reduce()
out.collect(new Text("Car"),new Text("Subaru"); 
out.collect(new Text("Car"),new Text("Honda"); 
out.collect(new Text("Car"),new Text("Ford"); 
out.collect(new Text("Truck"),new Text("Dodge"); 
out.collect(new Text("Truck"),new Text("Chevy"); 

은 쌍 그래서 예에서, 그래, 기능 reduce()가 두 번 호출 될

reduce(Car, <Subaru, Honda, Ford>) 
reduce(Truck, <Dodge, Chevy>) 

으로 두 번 호출 될 것이다. 도움이되기를 바랍니다.

+0

고마워. 내게 많은 도움이되었다. – user1647267

관련 문제