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 B39D2200D54 for ; Fri, 8 Dec 2017 19:47:33 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id B216A160C0D; Fri, 8 Dec 2017 18:47:33 +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 CF5D4160BFD for ; Fri, 8 Dec 2017 19:47:32 +0100 (CET) Received: (qmail 28978 invoked by uid 500); 8 Dec 2017 18:47:31 -0000 Mailing-List: contact dev-help@spark.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list dev@spark.apache.org Received: (qmail 28962 invoked by uid 99); 8 Dec 2017 18:47:31 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 Dec 2017 18:47:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 9FF1C1A0ADC for ; Fri, 8 Dec 2017 18:47:30 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -0.401 X-Spam-Level: X-Spam-Status: No, score=-0.401 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_H2=-2.8, RCVD_IN_SORBS_SPAM=0.5, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-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 (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id V8EgDcaVLhtD for ; Fri, 8 Dec 2017 18:47:29 +0000 (UTC) Received: from mail-ua0-f175.google.com (mail-ua0-f175.google.com [209.85.217.175]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with ESMTPS id 8AD6F5F2AB for ; Fri, 8 Dec 2017 18:47:28 +0000 (UTC) Received: by mail-ua0-f175.google.com with SMTP id p33so8110071uag.9 for ; Fri, 08 Dec 2017 10:47:28 -0800 (PST) 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 :cc; bh=gF9gOpZrDrUn5tZWJ7mOriqhehn//QYK40I6YrIf2m4=; b=Eld8SawENZ0KR1RM4htilXnF99/QZdtp1QVcUAEem4i5LmRiCc9Ka8LDnTRP/5PSox dwAhuu12Hfp/z5ORV9962fVfjfZW9ckBvlgPpt7+VOrX1875P8xyJOdRiY6wj7tN5Str eV3f5teF7exojLoGOI36NadcjcFh/0Urh6Tem7W686Ouf2qicw9IGWbBQL2oBKPNB+qx f3hAfp5VhudLkOQs2NCQKRMcZEp0+qWGEJPe/c/3YIt2+e0vDx/YTDpeDBS/TRtlVk+w anBh+inXrQ89P/NBPmt3YDx6zvzjNMe7PUNwoW3yuQ9m5eyG/yccUuJ8zIIkbAfdBLrt tGAA== 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:cc; bh=gF9gOpZrDrUn5tZWJ7mOriqhehn//QYK40I6YrIf2m4=; b=Se91c+SLc56cef/6p7T+p8mTpPPe+W5Hbh2zYLZV/x56X//Opa42taGUFnFijIte55 kyiRcbepxWHAmDE9bGkZPhg9m9N0GR3OUd3uW1D7+yFOOUo3tPAh6H5tVpor3GDR3IY7 hYy+C9RHeKKJwYc1RpCBoSwSjnvDuhPsT7YVi6cFt89RXCuSdXyGXDugz7gKxLA/CCDh npXY5wNdTx1M9h3BV6Ivz3ETRQFhyg/0pyIcv8st+ch1gHP83vAsXHnuoDQm9r1VcN4I 6YCWyVxSeQd4Y002AOi6zeGRBOrEGHj84r4bS+m2ICn89xbI2pC6oKgvlq4JKj0Qylqq QOYg== X-Gm-Message-State: AKGB3mJi1POJz/yjBJBLGKgQnFIYHFYMICzQK07EcfyMCTi/5P9lqBLL Ez2j4flf94+C83i5o4sG2f2RRm31PcrooHHHQxM= X-Google-Smtp-Source: AGs4zMbtIFgctLKf3xO3Y1lKIXbGc/+5fW0trV1ZXuKGTzvH+i9vXcIPwjNs71V0ZebqW4O3kkXgJSwivcyFcxtzsmI= X-Received: by 10.176.75.175 with SMTP id v47mr19100179uaf.157.1512758841616; Fri, 08 Dec 2017 10:47:21 -0800 (PST) MIME-Version: 1.0 Received: by 10.176.78.40 with HTTP; Fri, 8 Dec 2017 10:47:21 -0800 (PST) In-Reply-To: References: From: Stavros Kontopoulos Date: Fri, 8 Dec 2017 20:47:21 +0200 Message-ID: Subject: Re: queryable state & streaming To: Burak Yavuz Cc: dev@spark.apache.org Content-Type: multipart/alternative; boundary="f4030436158262addd055fd89d58" archived-at: Fri, 08 Dec 2017 18:47:33 -0000 --f4030436158262addd055fd89d58 Content-Type: text/plain; charset="UTF-8" Cool Burak do you have a pointer, should I take the initiative for a first design document or Databricks is working on it? Best, Stavros On Fri, Dec 8, 2017 at 8:40 PM, Burak Yavuz wrote: > Hi Stavros, > > Queryable state is definitely on the roadmap! We will revamp the > StateStore API a bit, and a queryable StateStore is definitely one of the > things we are thinking about during that revamp. > > Best, > Burak > > On Dec 8, 2017 9:57 AM, "Stavros Kontopoulos" > wrote: > >> Just to re-phrase my question: Would query-able state make a viable SPIP? >> >> Regards, >> Stavros >> >> On Thu, Dec 7, 2017 at 1:34 PM, Stavros Kontopoulos < >> st.kontopoulos@gmail.com> wrote: >> >>> Hi, >>> >>> Maybe this has been discussed before. Given the fact that many streaming >>> apps out there use state extensively, could be a good idea to make Spark >>> expose streaming state with an external API like other systems do (Kafka >>> streams, Flink etc), in order to facilitate interactive queries? >>> >>> Regards, >>> Stavros >>> >> >> --f4030436158262addd055fd89d58 Content-Type: text/html; charset="UTF-8" Content-Transfer-Encoding: quoted-printable
Cool Burak do you have a pointer, should I take the initia= tive for a first design document or Databricks is working on it?

Best,
Stavros

=
On Fri, Dec 8, 2017 at 8:40 PM, Burak Yavuz <brk= yvz@gmail.com> wrote:
Hi Stavros,

Query= able state is definitely on the roadmap! We will revamp the StateStore API = a bit, and a queryable StateStore is definitely one of the things we are th= inking about during that revamp.

Best,
Burak

On Dec 8, 2017 9:57 AM, "Stavros Kontopoulos" <st.kontopoulos@gmail.com= > wrote:
Just to re-phrase my question: Would=C2=A0query-able state make a viable SPIP?

Regards,
Stavros

On T= hu, Dec 7, 2017 at 1:34 PM, Stavros Kontopoulos <st.kontopoulos@gma= il.com> wrote:
Hi,

Maybe this has been discussed before. Given the fact that many streaming = apps out there use state extensively, could be a good idea to make Spark ex= pose streaming state=C2=A0with an e= xternal API like other systems do (= Kafka streams, Flink etc),=C2=A0in = order to facilitate interactive queries?

Regards,
Stavros


--f4030436158262addd055fd89d58--