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 5F906200C7F for ; Wed, 10 May 2017 06:21:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 5E455160BC3; Wed, 10 May 2017 04:21:31 +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 7C685160BB6 for ; Wed, 10 May 2017 06:21:30 +0200 (CEST) Received: (qmail 70344 invoked by uid 500); 10 May 2017 04:21:29 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 70332 invoked by uid 99); 10 May 2017 04:21:29 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 May 2017 04:21:29 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 8F87C182172 for ; Wed, 10 May 2017 04:21:28 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.38 X-Spam-Level: ** X-Spam-Status: No, score=2.38 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd3-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 (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id i8hd8enrV9cB for ; Wed, 10 May 2017 04:21:26 +0000 (UTC) Received: from mail-oi0-f45.google.com (mail-oi0-f45.google.com [209.85.218.45]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 675145F36C for ; Wed, 10 May 2017 04:21:25 +0000 (UTC) Received: by mail-oi0-f45.google.com with SMTP id w10so23057533oif.0 for ; Tue, 09 May 2017 21:21:25 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20161025; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=/zqhfFY0pXbxq6tfowQKwTXJDRdJSimOzsYlYuljEgQ=; b=W64DraNkKHPwQOiNkp387NKLQfFILZwt75z+NqeOWw8QO18gUhToM595kijPAi8Ofy Dfx2C0juJ+l6POWfy4w+0i/9+vC1CUR/QIBOtuTWyZmpkh3LWOKsKCiC1Z/tMZWA1SSC RA8d6rOQ7bL0K/b8ScYMFeqKc2nXSF2ulSPzPmPNSnLPFup/XlsbcOQq4TJG6SiqRSCe Q1lK+pPIefAgKBDX18bxDy0E565Y4CArANqHer8qQtuZcyJKzOwlWumZDndo7AzaSwIk uzymjx2TzpRQDpUTEs/EfNBHT4jhCzfag5jVbynAzqTgsIC6NWSs4CZ5pc8JIHl5dqlJ 9F2w== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20161025; h=x-gm-message-state:mime-version:in-reply-to:references:from:date :message-id:subject:to; bh=/zqhfFY0pXbxq6tfowQKwTXJDRdJSimOzsYlYuljEgQ=; b=U1prlEew06R1N8DjoWiUIxVuD10ZvojGNhiYpgbYJ/lRcUgeVSI9YkOHaDKsbHxj6C CE7FVAg4dt2+gaVrEsX/ROc17PBJsbI6mq8i3gvh1FbmV4Ajp//zlpOmUQAoKrisj9kg 9781d+Y7G4AhWSO3qtJVKHki1zfrUMbiZ8v8qnJhmfCa6T7VdKCXJqx0L+V/5MKeEsxl 9ya7lWwI+QZWi/bMoPXCY3F681kMcO6yyvlJ0xMLOABn62OvR0qWLKriveJfncjxqb6k elgactLcniuVTAgPrE7PHraNE0iYwW/3xIVQ++YKJKukjMU3bDVRbtSOzoRkLa2HPEg+ kACQ== X-Gm-Message-State: AODbwcAU9ZbrVBbIkfmMTCc0mvtoRPWY5EgMZ1anyibwSBT+EIN/0Xfr wTHeVUqT88v10veypR0Ktz2KS5bgrw== X-Received: by 10.157.53.54 with SMTP id o51mr1504115otc.41.1494390083943; Tue, 09 May 2017 21:21:23 -0700 (PDT) MIME-Version: 1.0 Received: by 10.157.14.104 with HTTP; Tue, 9 May 2017 21:21:23 -0700 (PDT) In-Reply-To: References: <506cebfc-bbb9-ba70-8066-f03db1398fa6@openbet.com> From: Guozhang Wang Date: Tue, 9 May 2017 21:21:23 -0700 Message-ID: Subject: Re: [DISCUSS] KIP-155 Add range scan for windowed state stores To: "dev@kafka.apache.org" Content-Type: multipart/alternative; boundary=001a11c02b361c0327054f23ce8a archived-at: Wed, 10 May 2017 04:21:31 -0000 --001a11c02b361c0327054f23ce8a Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Thanks, the KIP sounds good to me. There is no implementation proposal in the JIRA / KIP yet, would you like you drive the implementation also? Guozhang On Tue, May 9, 2017 at 8:29 AM, Xavier L=C3=A9aut=C3=A9 wrote: > I updated the KIP to reflect Michal's comment. Unless there are any furth= er > comments, I will initiate a vote this evening. > > On Mon, May 8, 2017 at 11:01 AM Xavier L=C3=A9aut=C3=A9 wrote: > > > That sounds reasonable, Michal. Given the underlying implementation use= s > > the same segmented bytes store I don't think it should be too difficult > to > > add. > > > > On Mon, May 8, 2017 at 2:04 AM Michal Borowiecki < > > michal.borowiecki@openbet.com> wrote: > > > >> Hi Xavier, > >> > >> I like your KIP. Do you think the same should apply to session stores? > >> > >> IMHO, all three should be on par wrt the ability to query key ranges > >> (although I understand the implementation concerns for windowed stores > are > >> more involved than for normal key value stores). > >> > >> Thanks, > >> > >> Michal > >> > >> On 08/05/17 08:18, Xavier L=C3=A9aut=C3=A9 wrote: > >> > >> Hi everyone, > >> > >> I am proposing to add the ability to range scan windowed state stores = in > >> Kafka Streams. The required interface changes are relatively minimal a= nd > >> follow our existing conventions for state stores. Let me know if that > >> sounds reasonable. > >> https://cwiki.apache.org/confluence/display/KAFKA/KIP+ > 155+-+Add+range+scan+for+windowed+state+stores > >> https://issues.apache.org/jira/browse/KAFKA-5192 > >> > >> Thank you, > >> Xavier > >> > >> > >> > >> -- > >> Michal Borowiecki > >> Senior Software Engineer L4 > >> T: +44 208 742 1600 <+44%2020%208742%201600> > >> > >> > >> +44 203 249 8448 <+44%2020%203249%208448> > >> > >> > >> > >> E: michal.borowiecki@openbet.com > >> W: www.openbet.com > >> OpenBet Ltd > >> > >> Chiswick Park Building 9 > >> > >> 566 Chiswick High Rd > >> > >> London > >> > >> W4 5XT > >> > >> UK > >> > >> This message is confidential and intended only for the addressee. If y= ou > >> have received this message in error, please immediately notify the > >> postmaster@openbet.com and delete it from your system as well as any > >> copies. The content of e-mails as well as traffic data may be monitore= d > by > >> OpenBet for employment and security purposes. To protect the environme= nt > >> please do not print this e-mail unless necessary. OpenBet Ltd. > Registered > >> Office: Chiswick Park Building 9, 566 Chiswick High Road, London, W4 > 5XT, > >> United Kingdom. A company registered in England and Wales. Registered > no. > >> 3134634. VAT no. GB927523612 > >> > > > --=20 -- Guozhang --001a11c02b361c0327054f23ce8a--