Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io 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 11A0B160C26 for ; Wed, 3 Jan 2018 06:51:45 +0100 (CET) Received: (qmail 29248 invoked by uid 500); 3 Jan 2018 05:51:44 -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 29236 invoked by uid 99); 3 Jan 2018 05:51:44 -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, 03 Jan 2018 05:51:44 +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 81B24180353 for ; Wed, 3 Jan 2018 05:51:42 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.979 X-Spam-Level: * X-Spam-Status: No, score=1.979 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=2, RCVD_IN_DNSWL_NONE=-0.0001, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd3-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=confluent-io.20150623.gappssmtp.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id a72jp2Bq7jEe for ; Wed, 3 Jan 2018 05:51:40 +0000 (UTC) Received: from mail-lf0-f42.google.com (mail-lf0-f42.google.com [209.85.215.42]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 4679C5FB62 for ; Wed, 3 Jan 2018 05:51:40 +0000 (UTC) Received: by mail-lf0-f42.google.com with SMTP id c19so588166lfg.3 for ; Tue, 02 Jan 2018 21:51:40 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=confluent-io.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:from:date:message-id:subject:to; bh=NFevw3bzqQxrK9zBw41wOKpmKdeMk0/v8qGpdLKZNq4=; b=1vBcpp9008+IvAwIB2kE+ZS0Odh0NpXhn482jjB5hr9+q5/uBgSpvMwustg0UCT4G6 ywMKzcy8CC7DS9nZ49/JJ6PWMGBKaDNPw0mYGFVIYHfsQsi50SMDXS0UyIet9qu9ujYr x94/4fWfOsGVqwZK+ciHFFZiJFmGEsY0tQB6PrrF6PwtBUXwoDeN4+JbYeOZxsWU4Nud ncP17ez4G5ljiwJK7XniRtVUhuVnTXYlLmRSBmwZ7EIqWDrDdyz7XkLH88aYNmFxMWkE GU2A4vkn2lG1DEVbPhGZe5QPpE7acaOz7dd9YYwo9tGBSvHfOPSNk2e9qbfusl7MjK3i mv3Q== 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=NFevw3bzqQxrK9zBw41wOKpmKdeMk0/v8qGpdLKZNq4=; b=d58goYjPWpRiQqgDmaAWfItsYTdFs9mFPWMikDVPUr8Xb+IhmRfKSgEu15NiEU8s4d bZVQitR5z/jZ+2XysTSrDpCBK9mOmNnv4yLxAoPRy6Mjdo6JREp/OrPTjJ18YLpXzAEj cn+UTXGafTOori3JNsSaJFKQkgAyEdk6V1gQNDg2yJV4ih03eF3omzaN98psic8QkbT9 WO2DOl5o9GmFp/c6S6Tdh7xovLBheZCOK4pRRS70QSIO3nyCjbbR6r7xXU5BUKuVt/pA UnEiArCU3hDfRYP8DzN9/1ZlM9QLFc2c6eaPcX1qhU/2kvzLQ6GAe7rUlI5VwMj7wlJl 3xOw== X-Gm-Message-State: AKGB3mK8Lkr7ifmmMRU/8zDZBSJc41xdKhzLqAuqO/0yoEF6AQe3HmxH mcyS2Gy6/+OBi3iINXQnDg/6MNnk0oxIDfNcbKSUCPCK X-Google-Smtp-Source: ACJfBovPgrIB1Z50stJPGJcyM+wBYoivAfn5Tr3groabDOFYJKURkWnw+FvHLZdpoWUiRPUwVCQKrXBqhInL2fj4Woo= X-Received: by 10.25.121.5 with SMTP id u5mr230218lfc.50.1514958698710; Tue, 02 Jan 2018 21:51:38 -0800 (PST) MIME-Version: 1.0 Received: by 10.25.56.87 with HTTP; Tue, 2 Jan 2018 21:51:37 -0800 (PST) In-Reply-To: References: From: Ewen Cheslack-Postava Date: Tue, 2 Jan 2018 21:51:37 -0800 Message-ID: Subject: Re: [VOTE] KIP-239 Add queryableStoreName() to GlobalKTable To: dev@kafka.apache.org Content-Type: multipart/alternative; boundary="089e082f8d7c161dc40561d8cf8c" archived-at: Wed, 03 Jan 2018 05:51:46 -0000 --089e082f8d7c161dc40561d8cf8c Content-Type: text/plain; charset="UTF-8" Oh, the KIP passes w/ the required votes. My comment was just on implementation details. I will leave comments about that up to the subsequent PR and to the Kafka Streams folks that are much better suited than me to comment on them :) -Ewen On Tue, Jan 2, 2018 at 9:28 PM, Richard Yu wrote: > After investigation, I have found that the > InternalStreamsBuilder#globalTable method is the only instance where the > constructor for GlobalKTableImpl is called. > The KTableValueGetterSupplier parameter used in this particular constructor > is an instance of KTableSourceValueGetterSupplier. Hence, your requirement > is satisfied. > > Since this is the vote thread, if you have further comments, please comment > on the pull request. > > On Tue, Jan 2, 2018 at 6:38 PM, Ewen Cheslack-Postava > wrote: > > > +1 binding > > > > The idea seems reasonable. Looking at it implementation-wise, seems there > > is a bit of awkwardness because GlobalKTableImpl uses a > > KTableValueGetterSupplier which seems to possibly have multiple stores, > but > > maybe using the more specific KTableSourceValueGetterSupplier > > implementation instead can resolve that. > > > > -Ewen > > > > On Mon, Jan 1, 2018 at 6:22 PM, Ted Yu wrote: > > > > > Gentle reminder: one more binding vote is needed for the KIP to pass. > > > > > > Cheers > > > > > > On Thu, Dec 21, 2017 at 4:13 AM, Damian Guy > > wrote: > > > > > > > +1 > > > > > > > > On Wed, 20 Dec 2017 at 21:09 Ted Yu wrote: > > > > > > > > > Ping for more (binding) votes. > > > > > > > > > > The pull request is ready. > > > > > > > > > > On Fri, Dec 15, 2017 at 12:57 PM, Guozhang Wang < > wangguoz@gmail.com> > > > > > wrote: > > > > > > > > > > > +1 (binding), thanks! > > > > > > > > > > > > On Fri, Dec 15, 2017 at 11:56 AM, Ted Yu > > > wrote: > > > > > > > > > > > > > Hi, > > > > > > > Here is the discussion thread: > > > > > > > > > > > > > > http://search-hadoop.com/m/Kafka/uyzND12QnH514pPO9?subj= > > > > > > > Re+DISCUSS+KIP+239+Add+queryableStoreName+to+GlobalKTable > > > > > > > > > > > > > > Please vote on this KIP. > > > > > > > > > > > > > > Thanks > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > > -- > > > > > > -- Guozhang > > > > > > > > > > > > > > > > > > > > > --089e082f8d7c161dc40561d8cf8c--