Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Accumulo >> mail # user >> Mappers for Accumulo


Copy link to this message
-
Re: Mappers for Accumulo
See AccumuloInputFormat

ArrayList<Range> ranges = new ArrayList<Range>();// populate array
list of row ranges ...AccumuloInputFormat.setRanges(job, ranges);
You should get one mapper per range.
On Fri, Mar 8, 2013 at 12:11 PM, Aji Janis <[EMAIL PROTECTED]> wrote:

> Hello,
>
>  I am trying to figure out how I can configure number of mappers (if its
> even possible) based on a Accumulo row range. My accumulo rowid uses the
> format:
>
> abc/1
> abc/2
> ...
> def/3
> ....
> xyz/13...
>
> If I want to specify three ranges: [abc/1 to abc/3] , [def/1 to def 5] ,
> [jkl/13 to klm 15]. and have one mapper work on one range, is there a way I
> can do this?? How do I even set up my mapreduce job to accept these
> ranges??? Thankyou for all feedback.
>
>
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB