If you supply multiple Ranges and call AccumuloInputFormat.disableAutoAdjustRanges(), each Range will get it's own mapper.
John On Fri, Apr 20, 2012 at 7:55 PM, Justin Betteridge <[email protected]>wrote: > Hi, > > The documentation shows how to restrict the rows used as input for a > MapReduce job using AccumuloInputFormat and a set of Ranges. But then all > of the specified records get sent to only 1 map task (the total amount of > data for my job is relatively small, but takes a long time to process). Is > there some way to tell AccumuloInputFormat to send each Range to a separate > map task? > > Thanks, > Justin > >
