From user-return-3860-apmail-accumulo-user-archive=accumulo.apache.org@accumulo.apache.org Thu Mar 13 18:24:42 2014 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 6C81410B9C for ; Thu, 13 Mar 2014 18:24:42 +0000 (UTC) Received: (qmail 60891 invoked by uid 500); 13 Mar 2014 18:24:31 -0000 Delivered-To: apmail-accumulo-user-archive@accumulo.apache.org Received: (qmail 58632 invoked by uid 500); 13 Mar 2014 18:24:10 -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 57399 invoked by uid 99); 13 Mar 2014 18:24:06 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 13 Mar 2014 18:24:06 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=5.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [50.205.35.98] (HELO hera.ccri.com) (50.205.35.98) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 13 Mar 2014 18:24:00 +0000 Received: from [192.168.200.1] by hera.ccri.com with esmtpsa (TLSv1:DHE-RSA-AES128-SHA:128) (Exim 4.80.1) (envelope-from ) id 1WOAHz-0001pw-Ar for user@accumulo.apache.org; Thu, 13 Mar 2014 14:23:31 -0400 Message-ID: <5321F7A2.5040602@ccri.com> Date: Thu, 13 Mar 2014 14:23:30 -0400 From: John Armstrong Reply-To: John Armstrong User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:24.0) Gecko/20100101 Thunderbird/24.3.0 MIME-Version: 1.0 To: user@accumulo.apache.org Subject: Too Many Versions! Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Using Accumulo 1.4.3, I have a table configured to keep Many (maxint) versions of each key, with the version being interpreted as a timestamp. Given a set of times I'm interested in, I can pull out the data at exactly those times with no problem. But I also want another behavior: if I don't have a particular time, I want to respond with the most recent version of the data. I'm trying to use this code: void setScannerForTimestamp(Scanner scanner, DateTime timestamp) { if (timestamp == null) { IteratorSetting cfg = new IteratorSetting(10, "vers", VersioningIterator.class) VersioningIterator.setMaxVersions(cfg, 1) scanner.addScanIterator(cfg) } else { TimestampSetIterator.setupIterator(scanner, timestamp) } } where TimestampSetIterator is my own custom iterator that's already working. In my table, I have 76063 different data points, each with 31 versions. When I pass a null timestamp, I expect to get back 76063 entries. Instead, I get 76063*31 = 2357953 entries. That is, it looks like the table is ignoring the part where I setMaxVersions to 1. What am I missing?