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 2E504200BE4 for ; Wed, 21 Dec 2016 09:35:15 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 2CDFD160B26; Wed, 21 Dec 2016 08:35:15 +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 77822160B0C for ; Wed, 21 Dec 2016 09:35:14 +0100 (CET) Received: (qmail 2125 invoked by uid 500); 21 Dec 2016 08:35:13 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 2115 invoked by uid 99); 21 Dec 2016 08:35:13 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 Dec 2016 08:35:13 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id AAD4AC14BD for ; Wed, 21 Dec 2016 08:35:12 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.379 X-Spam-Level: ** X-Spam-Status: No, score=2.379 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] autolearn=disabled Authentication-Results: spamd1-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id PxWMm_l5xPZ7 for ; Wed, 21 Dec 2016 08:35:12 +0000 (UTC) Received: from mail-wm0-f51.google.com (mail-wm0-f51.google.com [74.125.82.51]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTPS id 959755F342 for ; Wed, 21 Dec 2016 08:35:11 +0000 (UTC) Received: by mail-wm0-f51.google.com with SMTP id g23so15715455wme.1 for ; Wed, 21 Dec 2016 00:35:11 -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; bh=bccjH8O+creamoIgaLF3PNHiFMMfeIg2lMYiEoXujEo=; b=Lje+ieQMti5aQQsUDlAif6IgwoZ05L3KPZbnB/4pwirV9YY25jje/Em4lkUI3G1O3J Ec9fINmR4A67EIWBpDuvrxCThf6hZRjl3f/2MdwQmDSsz77SgH176buSSNp4JgOEpBYY lglllVoxBHD4rvD57dZQXRTpDssqRLzVy9zOF0otR44oVYU2u7IpsCYtmLpx3xuPneTl R2Ha0o7G8vMEZBMaznob2AsVdeUUCOsDON9yXvwf5HslkNXC1S8nr7BdX77tox2yDzpf KAKXYxsJ/E+PCsaskzUPyZFB9C3C5WErz7JTdCCGLpCnv1LXbZEFm2pUs1wOGXuU/xeU zfnA== 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=bccjH8O+creamoIgaLF3PNHiFMMfeIg2lMYiEoXujEo=; b=Hp0kPM0zHVFKAg3anyOvVwETyk8pj52Es397jQ3kh7TagCCpmnEWIJtQxf4DTePO6U tzZnIwXhxIxGW3LqU5DV+Ol8EFdct3/WQvhUMYmZeZJrPmU8Iofk/wBrhhBNbcdvThGu JxLCqh85cJbfzzVRfhWiB4j4k6vlmTNd8loEHc3rGaN2m+hLr3e4tNkLhNZ/BB87dKr+ CH5F8XOMwz06TbIbiQTn/uhqKNMxk9LfpmKaSqSrkHn6vKZgmCdj5+d1ZlJPQqcHYSGA MboydZ21zWLb2a9QaOj92fuRH5JYwuanJGqZZeGmrVylamiMREGLvyGwmlAxjBXJTJf2 X9ug== X-Gm-Message-State: AIkVDXI2u+kDQpA/BHHAkqP52/3IflVTO8zprfRx+uSkHi2kJdPLinNO9sFJUS8IaomB4/DQ8IbiNwsZ8Hjjvw== X-Received: by 10.28.127.9 with SMTP id a9mr5826888wmd.95.1482309310134; Wed, 21 Dec 2016 00:35:10 -0800 (PST) MIME-Version: 1.0 Received: by 10.194.162.129 with HTTP; Wed, 21 Dec 2016 00:34:39 -0800 (PST) In-Reply-To: References: From: Fabian Hueske Date: Wed, 21 Dec 2016 09:34:39 +0100 Message-ID: Subject: Re: static/dynamic lookups in flink streaming To: user@flink.apache.org Content-Type: multipart/alternative; boundary=001a1141cf7ae0bfd505442707af archived-at: Wed, 21 Dec 2016 08:35:15 -0000 --001a1141cf7ae0bfd505442707af Content-Type: text/plain; charset=UTF-8 Hi Sandeep, I'm sorry but I think I do not understand your question. What do you mean by static or dynamic look ups? Do you want to access an external data store and cache data? Can you give a bit more detail about your use? Best, Fabian 2016-12-20 23:07 GMT+01:00 Meghashyam Sandeep V : > Hi there, > > I know that there are various state backends to persist state. Is there a > similar way to persist static/dynamic look ups and use them while streaming > the data in Flink? > > Thanks, > Sandeep > > --001a1141cf7ae0bfd505442707af Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi Sandeep,

I'm sorry but I thi= nk I do not understand your question.
What do you mean by static or dyn= amic look ups? Do you want to access an external data store and cache data?=

Can you give a bit more detail about your use?

Best, F= abian

20= 16-12-20 23:07 GMT+01:00 Meghashyam Sandeep V <vr1meghashyam@gmail.c= om>:
Hi th= ere,

I know that there are various state backends to per= sist state. Is there a similar way to persist static/dynamic look ups and u= se them while streaming the data in Flink?

Thanks,=
Sandeep


--001a1141cf7ae0bfd505442707af--