Return-Path: X-Original-To: apmail-accumulo-user-archive@www.apache.org Delivered-To: apmail-accumulo-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 84D7410B35 for ; Mon, 16 Sep 2013 19:55:53 +0000 (UTC) Received: (qmail 12784 invoked by uid 500); 16 Sep 2013 19:55:52 -0000 Delivered-To: apmail-accumulo-user-archive@accumulo.apache.org Received: (qmail 12723 invoked by uid 500); 16 Sep 2013 19:55:51 -0000 Mailing-List: contact user-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@accumulo.apache.org Delivered-To: mailing list user@accumulo.apache.org Received: (qmail 12714 invoked by uid 99); 16 Sep 2013 19:55:51 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Sep 2013 19:55:51 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of cjnolet@gmail.com designates 209.85.223.177 as permitted sender) Received: from [209.85.223.177] (HELO mail-ie0-f177.google.com) (209.85.223.177) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Sep 2013 19:55:44 +0000 Received: by mail-ie0-f177.google.com with SMTP id qd12so8213401ieb.22 for ; Mon, 16 Sep 2013 12:55:23 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=mDiA/41xhkZHTaxUX0V5+S06sUUNKcendiED22GVep0=; b=ZM2CeustGSM5hU9g5wE8RLEAAP9oxRqT7Z0Nn/Ic2s+YcYm/1izVMxHkpdw6l+Y2cA nthc13RblBqyJirHuG5ditW7ltoF5JjCRLAFbaIt3N/AOZSmrq2PDjsdFRNmlqp8Bdkv ALW6eO4Tp9ApWfiTeqn/uDkL6R78fTjvvHpPV8BPiNNyAhBi6BwajeOIujg8Lg4q3Bvp r5KXZ015X5WO/1XAZfgOrRETU6sWeejCySSqO6iNhBduPVOvY2refaq0KiL0AYQIwQiF E466BjZTCP2jkgKYXHMvxvzikFOgL71+VWN1DEo6fPGNHutzfnl4VcV4JG5EFRpB42JZ D+dg== MIME-Version: 1.0 X-Received: by 10.50.62.211 with SMTP id a19mr6963809igs.18.1379361323511; Mon, 16 Sep 2013 12:55:23 -0700 (PDT) Received: by 10.64.7.136 with HTTP; Mon, 16 Sep 2013 12:55:23 -0700 (PDT) In-Reply-To: References: Date: Mon, 16 Sep 2013 15:55:23 -0400 Message-ID: Subject: Re: Using Hadoop's MulitpleInputs with AccumuloInputFormat in a MR job From: Corey Nolet To: user@accumulo.apache.org Content-Type: multipart/alternative; boundary=047d7bd75920b478a204e68595a8 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bd75920b478a204e68595a8 Content-Type: text/plain; charset=ISO-8859-1 Aaron, We are currently re-working the AccumuloInputFormat for Accumulo 1.6 to provide inputs from multiple tables (each with their own set of configured iterators, ranges, columns). Check out ACCUMULO-391. On Mon, Sep 16, 2013 at 11:41 AM, Aaron wrote: > I was curious if this is possible (i am thinking it isn't): from the Java > API, Accumulo 1.5, Hadoop 1.2.1 > > Want to set 2 different iterators on a scan, and send those results to 2 > different Mappers. > > So, how'd i do this with files as inputs, is just to use MultipleInputs > class, with 2 different Path, and 2 different Mapper Classes, maybe the > same InputFormat (e.g Text or Sequence) > > Since I'm using AccumulInputFormat, I would think I'd be ok..maybe with a > null Path in the MulitpleInputs.addInputPath(), but it's the static > addIterator() on the AccumuloInputFormat that I think is where I lose. > > Can I have 2 different AccumuloInputFormats, with different iterators? I > think the answer is no, and briefly looking at the source, believe that to > be correct..but, was curious if others have done have done something. > > Cheers, > Aaron > --047d7bd75920b478a204e68595a8 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Aaron,

We are currently re-working the A= ccumuloInputFormat for Accumulo 1.6 to provide inputs from multiple tables = (each with their own set of configured iterators, ranges, columns). Check o= ut ACCUMULO-391.




On Mon, Sep 16, 2013 at 11:41 AM, Aaron <aarongmldt@gmail.com><= /span> wrote:
I was curious if this is po= ssible (i am thinking it isn't): =A0from the Java API, Accumulo 1.5, Ha= doop 1.2.1

Want to set 2 different iterators on a scan, and send those = results to 2 different Mappers.

So, how'd i do this with files as inputs, is just t= o use MultipleInputs class, with 2 different Path, and 2 different Mapper C= lasses, maybe the same InputFormat (e.g Text or Sequence)

Since I'm using AccumulInputFormat, I would think I'd be= ok..maybe with a null Path in the MulitpleInputs.addInputPath(), but it= 9;s the static addIterator() on the AccumuloInputFormat that I think is whe= re I lose.

Can I have 2 different AccumuloInputFormats, with diffe= rent iterators? =A0I think the answer is no, and briefly looking at the sou= rce, believe that to be correct..but, was curious if others have done have = done something.

Cheers,
Aaron

--047d7bd75920b478a204e68595a8--