[MAPREDUCE-5287] Create a generic InputFormat wrapping any other InputFormat, to control the number of map tasks

• Type: Improvement
• Status: In Progress
• Priority: Minor
• Resolution: Unresolved
• Component/s: mrv1, performance
• Assignee: nicu marasoiu
• Reporter: nicu marasoiu
• Created: 31/May/13 12:11
• Updated: 13/Jun/13 11:50

Description

I wrote a generic InputFormat that wraps any other InputFormat, and creates CompositeInputSplits to reduce the number of map tasks in a controllable manner while preserving data locality. A correspondent CompositeRecordReader is written to iterate through underlying RecordReaders as created by the underlying InputFormat for each underlying raw split.

An application to this is to group TableSplits when the raw splits are coming from multiple regions and are filtered with key ranges. We use this to shard/distribute a time based incremental access to an hbase table.