That is under your application's control. Define a class that implements Partitioner https://hadoop.apache.org/docs/r2.6.3/api/org/apache/hadoop/mapreduce/Partitioner.html and set the name of the class in your job's configuration using job.setPartitionerClass(...).
.. Owen On Tue, Mar 14, 2017 at 2:51 PM, Pushparaj Motamari <pushpara...@gmail.com> wrote: > Hi, > > I want to understand the implementation in the code which assigns > particular reducer with particular keys.I mean, the code which provides the > logic of assigning reducers with a particular key, where Mappers will send > their key,value pairs after mapping. Will it assign based on > hash(key)%(number of reducers) ? > > Regards > > Pushparaj >
