Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 3EEDD200CF5 for ; Sun, 13 Aug 2017 04:36:45 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 3BAB816485D; Sun, 13 Aug 2017 02:36:45 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 7AA7C16485B for ; Sun, 13 Aug 2017 04:36:44 +0200 (CEST) Received: (qmail 31090 invoked by uid 500); 13 Aug 2017 02:36:43 -0000 Mailing-List: contact user-help@kudu.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@kudu.apache.org Delivered-To: mailing list user@kudu.apache.org Received: (qmail 31079 invoked by uid 99); 13 Aug 2017 02:36:42 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 13 Aug 2017 02:36:42 +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 41B16C0221 for ; Sun, 13 Aug 2017 02:36:42 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -2.401 X-Spam-Level: X-Spam-Status: No, score=-2.401 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H2=-2.8, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id najk79IHDXOu for ; Sun, 13 Aug 2017 02:36:41 +0000 (UTC) Received: from mail-pf0-f172.google.com (mail-pf0-f172.google.com [209.85.192.172]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 587735F24E for ; Sun, 13 Aug 2017 02:36:40 +0000 (UTC) Received: by mail-pf0-f172.google.com with SMTP id h68so29592901pfk.0 for ; Sat, 12 Aug 2017 19:36:40 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=from:content-transfer-encoding:mime-version:subject:message-id:date :to; bh=bzgGTXF59N4NWtx60F9Gl239xK+Z4yn1/6nakc8UqgI=; b=DvvjBLFe6c47GgMtG7LB8d/VewoRuE13asImpcEzweDlrIJueOm7miRKR/q0zc2s9C cJgrqqXtJM+6WDTPmPOHSGBXK3lmLUAI/dUvWpfa7/ADBzFrtm2oatZqJLOvmurbia+5 ChDWKxDMtMthsX6xkiqtRP70qZevvbAVzjC/Q9ypPUp8r4FMJ4zd2nqwjitCaTIx63/y xtUy+F924vhDG5dmpgNYu2CumsQMag6Vuekhr0zeHhZE9IdCY4gyfTdECVr4R5e5uoNN Dx2XP3keRH4hsK50Sz7Op4KNehOVM7LL2asUtCE496ZlGt0pvW+YuMJOs9P+ydC5fbk8 8ucQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:from:content-transfer-encoding:mime-version :subject:message-id:date:to; bh=bzgGTXF59N4NWtx60F9Gl239xK+Z4yn1/6nakc8UqgI=; b=n9RjGga7reiNQOq0dRYGvScb+4n63q4g7jVwogUS6aWYmz1ZXUmnXkLJ0zByZubA9q OPkOV3XXEmydX6y77U4hdOGDtiUS8Rv0/l6cMio0ye10N8WCcC8yJL9mxUtVt9j8V7Lw hR7PE/Je/3bRB/LUf+LB5PhulU22WLOKAVpUzKM1gQ3Gk9OjDe104d8833E3kHa7Hfsk 3jvjo3I6fE41M9SaIX44a+3a9Wa4SWCxwdCidpcbhikHuglQycKXEezZXBkaLrevjNil yTuHxScjW6rmIWLLYyAE7N58XKeVWI7wx4NZfwiZxVKp3Eim3fZ28PwbbpidCq5+PHbx KANQ== X-Gm-Message-State: AHYfb5iUj622QzXDzBMp964dS7hqwn8RAxQ1/ElMHYwgRvh8+XoWhxWh TgF/ihyLi4n6KoCPNvc= X-Received: by 10.84.209.142 with SMTP id y14mr23411062plh.286.1502591792505; Sat, 12 Aug 2017 19:36:32 -0700 (PDT) Received: from [192.168.1.136] (203-7-77-134.dyn.iinet.net.au. [203.7.77.134]) by smtp.gmail.com with ESMTPSA id y8sm7984473pfi.159.2017.08.12.19.36.30 for (version=TLS1_2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Sat, 12 Aug 2017 19:36:31 -0700 (PDT) From: Ananth Gundabattula Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Mime-Version: 1.0 (Mac OS X Mail 10.3 \(3273\)) Subject: Question on consistent ordering of scanner rows Message-Id: <4BAD9D34-F5D4-4031-971B-2CF5B67DF92A@gmail.com> Date: Sun, 13 Aug 2017 12:36:27 +1000 To: user@kudu.apache.org X-Mailer: Apple Mail (2.3273) archived-at: Sun, 13 Aug 2017 02:36:45 -0000 Hello All, I was wondering if there is any guarantee from the kudu scanner that the = rows returned from a single tablet scan are always in the same order = basing on the following assumptions :=20 - There was no change in the underlying kudu tablet for the given scan = range when the reads are being performed multiple times for the same = scan token - I am using Java client - I am using Kudu version 1.4.0 - The client code is using the KuduScanTokenBuilder API to plan the set = of scans that can be performed for a given query. - The client is using the nextRows() followed using hasNext() and next() = methods in the corresponding iterators. - There seems to be a variable called orderMode in the asyncScanner = during a debug session but it looks like this property is not exposed = yet as a public API. The default value seems to be that it is unordered.=20= Perhaps the answer is no per the last point above but would like = confirmation from the community.=20 I am integrating Apache Apex with Apache kudu and am using the scan = token builder API mechanism to plan the scans in a distributed way. = While doing so, I would like to provide the end users of Apache Apex a = mechanism to get a consistent scan ordering as a configurable approach. = Given it is almost impossible to achieve this ordering in a true = distributed fashion for downstream compute nodes, the aim is to provide = consistent ordering within a single Apex partition. Apache apex with = Kudu integration would be providing configurations to map one tablet to = one or multiple apex partitions. While scanning in either of these = mapping styles, I would like to provide further ordering guarantees. = However I am not sure if Apache Kudu would provide a consistent ordering = for the same scan provided the above assumptions hold good. =20 Could you please advise regarding the ordering of scan rows for a single = tablet across multiple launches of the same scan token ? Regards, Ananth=