Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id E944E1812F for ; Wed, 27 Jan 2016 11:53:07 +0000 (UTC) Received: (qmail 27981 invoked by uid 500); 27 Jan 2016 11:53:07 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 27913 invoked by uid 500); 27 Jan 2016 11:53:07 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 27902 invoked by uid 99); 27 Jan 2016 11:53:07 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Jan 2016 11:53:07 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 3F5B6C0D4B for ; Wed, 27 Jan 2016 11:53:07 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.426 X-Spam-Level: *** X-Spam-Status: No, score=3.426 tagged_above=-999 required=6.31 tests=[HTML_MESSAGE=3, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.554] autolearn=disabled Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id C4lRglDN0UHH for ; Wed, 27 Jan 2016 11:53:06 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with SMTP id 8CC1320426 for ; Wed, 27 Jan 2016 11:53:06 +0000 (UTC) Received: (qmail 27892 invoked by uid 99); 27 Jan 2016 11:53:06 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Jan 2016 11:53:06 +0000 Received: from mail-qg0-f41.google.com (mail-qg0-f41.google.com [209.85.192.41]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id 3B88A1A003F for ; Wed, 27 Jan 2016 11:53:06 +0000 (UTC) Received: by mail-qg0-f41.google.com with SMTP id 6so4198392qgy.1 for ; Wed, 27 Jan 2016 03:53:06 -0800 (PST) X-Gm-Message-State: AG10YORgSl7ATsYqDoa2YJzlhaQdvRz0M1Zzkq+AF/W+lsQQwCKkMMsE0TRof3E/4Pd13wgmeqzLrsrkJwzCS/5y MIME-Version: 1.0 X-Received: by 10.140.100.141 with SMTP id s13mr33482869qge.25.1453895585450; Wed, 27 Jan 2016 03:53:05 -0800 (PST) Received: by 10.140.82.70 with HTTP; Wed, 27 Jan 2016 03:53:05 -0800 (PST) Date: Wed, 27 Jan 2016 17:23:05 +0530 X-Gmail-Original-Message-ID: Message-ID: Subject: Cassandra query start value From: Priyanka Gugale To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=001a11c1752ae964a5052a4f71a1 --001a11c1752ae964a5052a4f71a1 Content-Type: text/plain; charset=UTF-8 Hi, CassandraPOJOInputOpeartor in Malhar accepts query in the form: "select * from %t where token(%p) > %s limit %l" Where %s is start value. *What is "start value" here?* >From javadoc in code it looks like %s is the row number in table from where you want to start scan. But looking at code it should be "primaryKeyValue" of row from where you want to start scan. (I didn't find any way in cql to scan starting from some row number, unless you have rowNumber column in your table.) If this understanding is correct we should rename this to something like startRowPrimaryKey and update javadoc. -Priyanka --001a11c1752ae964a5052a4f71a1--