Mailing-List: contact user-help@accumulo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@accumulo.apache.org
Received-SPF: pass (athena.apache.org: domain of betteridge@gmail.com
 designates 209.85.214.169 as permitted sender)
MIME-Version: 1.0
Sender: betteridge@gmail.com
In-Reply-To: 
 <CADczPYSVR7augphONa+GKQN2CJLooKLtPG0-XCNVK6SdSgBSLA@mail.gmail.com>
References: 
 <CAMy4Ni_U-GYQmdeCuHYsxEGvPVesozq-VPPcto_1Fn0_Fcxfkg@mail.gmail.com>
	<1408983286.411379.1334966125632.JavaMail.root@linzimmb04o.imo.intelink.gov>
	<CADczPYSVR7augphONa+GKQN2CJLooKLtPG0-XCNVK6SdSgBSLA@mail.gmail.com>
Date: Sat, 21 Apr 2012 06:08:46 -0400
Message-ID: 
 <CAMy4Ni_j_+_B76t-fMVwPx7S1L8Fe9sUayWoaYDWoD839=X=xw@mail.gmail.com>
Subject: Re: multiple splits with AccumuloInputFormat
From: Justin Betteridge <justin@betteridge.us>
To: user@accumulo.apache.org
Content-Type: multipart/alternative; boundary=f46d0444edd332058204be2d9701

--f46d0444edd332058204be2d9701
Content-Type: text/plain; charset=ISO-8859-1

Worked perfectly.  Thank you!

Justin

On Fri, Apr 20, 2012 at 10:02 PM, John Vines <john.w.vines@ugov.gov> wrote:

> 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 <betteridge@gmail.com>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
>>
>>
>

--f46d0444edd332058204be2d9701
Content-Type: text/html; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

<div class=3D"gmail_extra">Worked perfectly. =A0Thank you!</div><div class=
=3D"gmail_extra"><br></div><div class=3D"gmail_extra">Justin<br><br><div cl=
ass=3D"gmail_quote">On Fri, Apr 20, 2012 at 10:02 PM, John Vines <span dir=
=3D"ltr">&lt;<a href=3D"mailto:john.w.vines@ugov.gov" target=3D"_blank">joh=
n.w.vines@ugov.gov</a>&gt;</span> wrote:<br>
<blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1p=
x #ccc solid;padding-left:1ex">If you supply multiple Ranges and call Accum=
uloInputFormat.disableAutoAdjustRanges(), each Range will get it&#39;s own =
mapper.<span class=3D"HOEnZb"><font color=3D"#888888"><br>
<br>John</font></span><div class=3D"HOEnZb"><div class=3D"h5"><br><br><div =
class=3D"gmail_quote">On Fri, Apr 20, 2012 at 7:55 PM, Justin Betteridge <s=
pan dir=3D"ltr">&lt;<a href=3D"mailto:betteridge@gmail.com" target=3D"_blan=
k">betteridge@gmail.com</a>&gt;</span> wrote:<br>


<blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1p=
x #ccc solid;padding-left:1ex"><div class=3D"gmail_quote">Hi,<div><br></div=
><div>The documentation shows how to restrict the rows used as input for a =
MapReduce job using AccumuloInputFormat and a set of Ranges. =A0But then al=
l 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). =
=A0Is there some way to tell AccumuloInputFormat to send each Range to a se=
parate map task? =A0<br>


<br>Thanks,<br>Justin</div>
</div><br>
</blockquote></div><br>
</div></div></blockquote></div><br></div>

--f46d0444edd332058204be2d9701--