Return-Path: X-Original-To: apmail-accumulo-dev-archive@www.apache.org Delivered-To: apmail-accumulo-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 857CF1753A for ; Tue, 1 Sep 2015 03:57:24 +0000 (UTC) Received: (qmail 22241 invoked by uid 500); 1 Sep 2015 03:57:19 -0000 Delivered-To: apmail-accumulo-dev-archive@accumulo.apache.org Received: (qmail 22191 invoked by uid 500); 1 Sep 2015 03:57:19 -0000 Mailing-List: contact dev-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list dev@accumulo.apache.org Received: (qmail 22179 invoked by uid 99); 1 Sep 2015 03:57:19 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Sep 2015 03:57:19 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 77DAF1AB341 for ; Tue, 1 Sep 2015 03:57:18 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.801 X-Spam-Level: X-Spam-Status: No, score=-0.801 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, RCVD_IN_DNSWL_LOW=-0.7, RCVD_IN_MSPIKE_H2=-0.001, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id isu9PadXBrCS for ; Tue, 1 Sep 2015 03:57:07 +0000 (UTC) Received: from mail-qk0-f172.google.com (mail-qk0-f172.google.com [209.85.220.172]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id AB02542B2E for ; Tue, 1 Sep 2015 03:57:07 +0000 (UTC) Received: by qkcj187 with SMTP id j187so29461081qkc.2 for ; Mon, 31 Aug 2015 20:57:07 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=message-id:date:from:user-agent:mime-version:to:subject:references :in-reply-to:content-type:content-transfer-encoding; bh=uuCMwzAKHzU3qFX8C5ms7lIXw+zt9QoAUVoQfm+2DSU=; b=b+qJR8F9TZ2lliHpDGhIA/HEtsrfnYSzo0AYeTeo5h2/Pug/2UxseibiqHhCiHdoFi r/su1I8b3Z8kL0Y0AEY/chq+g3FbFnyMvtpJouyavZDMur7uGRk2RM97moyviKtWvEqe SBXJ17di2YC6RM67YgmzbpZMyvK004qKPdxmLv5C1SRNbM/bCop5hDHO8+FtbnJgrHHE Gk1h3wX65jDFCF/XUOvIqRFrRy/X4JSvNsba1gmSbE+gwfEpRTar2aVm4mzOYBfZN1zB YJjJ+jtVO3vmuDcTsXRrCuXIRqTJ9hNkUEFy0fz/ba0TpbHA6u9fK35hERoNLQu7f9xN RkUw== X-Received: by 10.55.27.203 with SMTP id m72mr15498217qkh.39.1441079827313; Mon, 31 Aug 2015 20:57:07 -0700 (PDT) Received: from hw10447.local (pool-68-134-10-53.bltmmd.fios.verizon.net. [68.134.10.53]) by smtp.googlemail.com with ESMTPSA id z128sm10044709qhd.43.2015.08.31.20.57.06 for (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Mon, 31 Aug 2015 20:57:06 -0700 (PDT) Message-ID: <55E52239.3010701@gmail.com> Date: Mon, 31 Aug 2015 23:57:45 -0400 From: Josh Elser User-Agent: Postbox 3.0.11 (Macintosh/20140602) MIME-Version: 1.0 To: dev@accumulo.apache.org Subject: Re: Specify Range for data in specific column family References: <1441063530184-15012.post@n5.nabble.com> <55E4EA63.1080009@gmail.com> <1441067227918-15016.post@n5.nabble.com> In-Reply-To: Content-Type: text/plain; charset=UTF-8; format=flowed Content-Transfer-Encoding: 7bit Keith Turner wrote: > On Mon, Aug 31, 2015 at 8:27 PM, z11373 wrote: > >> > Hi Josh, >> > Apologize that I still don't get it. >> > How to pass it to the AccumuloInputFormat? >> > If there is no way to do so (means I have to change the code), then I'd >> > think about it. >> > Right now the existing code already using AIF, and I just want to tweak the >> > Range condition. >> > > > Look not in Range but in AccumuloInputFormat methods and you will find the > method you seek. > > Ack, yeah, sorry for the run-around. I spaced on the fact that you said your were using the InputFormat. http://accumulo.apache.org/1.6/apidocs/org/apache/accumulo/core/client/mapreduce/InputFormatBase.html#fetchColumns-org.apache.hadoop.mapreduce.Job-java.util.Collection- In your case, you'd want to do something like: `AccumuloInputFormat.fetchColumns(job, Arrays.asList(new Pair(new Text(myColfam), null));` (sorry if you're using the mapred libraries instead of mapreduce libraries -- note the java package. Both will have the same method, one just accepts a Job and the other a JobConf to match both mapreduce APIs from Hadoop)