Return-Path: X-Original-To: apmail-flink-user-archive@minotaur.apache.org Delivered-To: apmail-flink-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 019E918CF6 for ; Wed, 17 Jun 2015 07:36:33 +0000 (UTC) Received: (qmail 98349 invoked by uid 500); 17 Jun 2015 07:36:32 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 98277 invoked by uid 500); 17 Jun 2015 07:36:32 -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 98267 invoked by uid 99); 17 Jun 2015 07:36:32 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 17 Jun 2015 07:36:32 +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 6613E182238 for ; Wed, 17 Jun 2015 07:36:32 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0 X-Spam-Level: X-Spam-Status: No, score=0 tagged_above=-999 required=6.31 tests=[SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-us-west.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id aUiMwoei8Sph for ; Wed, 17 Jun 2015 07:36:22 +0000 (UTC) Received: from mail-wg0-f44.google.com (mail-wg0-f44.google.com [74.125.82.44]) by mx1-us-west.apache.org (ASF Mail Server at mx1-us-west.apache.org) with ESMTPS id 9F39A249EA for ; Wed, 17 Jun 2015 07:36:21 +0000 (UTC) Received: by wgbhy7 with SMTP id hy7so29257605wgb.2 for ; Wed, 17 Jun 2015 00:36:14 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:message-id:date:user-agent:mime-version:to :subject:content-type:content-transfer-encoding; bh=ifS9daG3cgln702EqA1YnqQVTPh2QgWkTVCkv7i22Dc=; b=cDbK8NiagViJLDCwAWFETlsOMOSNCA34Hyn679EeGNa78ls0VCInkNMTgzN/T9xMUy Iuu8tg/s/40NqN4o7BYiVj3ZZOA2dywGxBWyjAI1TqLE10Uf9fxRHfiG9Xl3aXaL9zpA DDCP5gsZUW2uYCiM+n92OYIHtyYwWq9lMKltyMijr0T1UdV4TgHyZi/Lmf1gPD97MlPW oZvPL0SB0iMdnLR5ghP6ipQATog7EE0BxYMEPUaF4jWCvXPKFQIZO0+2CrLBDQSYpyFc M7cTpyikrNnVS91L9g4yvY308BGAiFteJrZ1Bdf4G2ppnjtzTTK62XlUFcgNRowB6fzh R17A== X-Gm-Message-State: ALoCoQn3RAeTQkt794drpKYPmXINXfWCoimnt0xD2TBVP7tUKupv8xcfKmMO6rTC+Ca4kYVcw5ek X-Received: by 10.180.186.99 with SMTP id fj3mr52424399wic.10.1434526574108; Wed, 17 Jun 2015 00:36:14 -0700 (PDT) Received: from [172.27.32.56] ([91.213.91.28]) by mx.google.com with ESMTPSA id gz3sm24810318wib.0.2015.06.17.00.36.12 for (version=TLSv1.2 cipher=ECDHE-RSA-AES128-GCM-SHA256 bits=128/128); Wed, 17 Jun 2015 00:36:13 -0700 (PDT) From: Hilmi Yildirim X-Google-Original-From: Hilmi Yildirim Message-ID: <5581236B.9040302@neofonie.de> Date: Wed, 17 Jun 2015 09:36:11 +0200 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:31.0) Gecko/20100101 Thunderbird/31.7.0 MIME-Version: 1.0 To: user@flink.apache.org Subject: Flink Streaming State Management Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 8bit Hi, does Flink Streaming support state management? For example, I have a state which will be used inside the streaming operations but the state can be updated. For example: stream.map( use state for operation).updateState(update state). Best Regards, Hilmi -- -- Hilmi Yildirim Software Developer R&D http://www.neofonie.de Besuchen Sie den Neo Tech Blog für Anwender: http://blog.neofonie.de/ Folgen Sie uns: https://plus.google.com/+neofonie http://www.linkedin.com/company/neofonie-gmbh https://www.xing.com/companies/neofoniegmbh Neofonie GmbH | Robert-Koch-Platz 4 | 10115 Berlin Handelsregister Berlin-Charlottenburg: HRB 67460 Geschäftsführung: Thomas Kitlitschko