Reduce() knowing which map source the current record is coming from.

3 Answer(s)


hi Laxmi,

Not entirely understood your question. Developer can give specific records from mapper to reducer using partitioning concept. Is this what you are looking for?

null

Considering separation of concerns here - if I do not want mapper to know the partitions and reducer can "drop" records based on which mapper the record is from, is there a way without adding prefixes (that seems clumsy!)?