Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
Received-SPF: pass (nike.apache.org: domain of mjsax@informatik.hu-berlin.de
 designates 141.20.20.101 as permitted sender)
Message-ID: <558123FD.5020908@informatik.hu-berlin.de>
Date: Wed, 17 Jun 2015 09:38:37 +0200
From: "Matthias J. Sax" <mjsax@informatik.hu-berlin.de>
User-Agent: Mozilla/5.0 (X11; Linux x86_64;
 rv:31.0) Gecko/20100101 Icedove/31.7.0
MIME-Version: 1.0
To: user@flink.apache.org
Subject: Re: Flink Streaming State Management
References: <5581236B.9040302@neofonie.de>
In-Reply-To: <5581236B.9040302@neofonie.de>
Content-Type: multipart/signed; micalg=pgp-sha256;
 protocol="application/pgp-signature";
 boundary="FqGL9A3E5tEDTsUSpMdkT97aGt20USH08"

This is an OpenPGP/MIME signed message (RFC 4880 and 3156)
--FqGL9A3E5tEDTsUSpMdkT97aGt20USH08
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable

Hi Hilmi,

currently, this is not supported. However, state management is already
work in progress and should be available soon. See
https://github.com/apache/flink/pull/747

-Matthias

On 06/17/2015 09:36 AM, Hilmi Yildirim wrote:
> 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.
>=20
> For example:
> stream.map( use state for operation).updateState(update state).
>=20
>=20
> Best Regards,
> Hilmi
>=20
>=20
>=20
>=20


--FqGL9A3E5tEDTsUSpMdkT97aGt20USH08
Content-Type: application/pgp-signature; name="signature.asc"
Content-Description: OpenPGP digital signature
Content-Disposition: attachment; filename="signature.asc"

-----BEGIN PGP SIGNATURE-----
Version: GnuPG v2

iQIcBAEBCAAGBQJVgSP9AAoJEBXkotPFErDWVH0P/iY5cHMmtwVZMffe5FKHBfOq
7DoHBtSghLpAnJuJAkP5mk8Lf67KV+whXrnm98f29xSrO7n+JVIrlEuu67fMxGoj
aEzpnQWvgLZCF2IE4e/M4upP94uum90dgy3+/4JeRLWAsQzrwOYPCcLJJX7j7Jbd
4u4gFKQoafYFIDNRBdiuSo3NTVIUrY8+zfQ2Hzwm8nWhyW9hePRxteyW1kNmelZu
FhcC/W5rqVvEES73e8SDOCZk6blQySFh2N8lOPvp9Isd7pIvmkX+wKpi2AP/MKkQ
DbWSBDpVJtDy1ZXxfZtIgCyVjbSsRJR2Uy2BNf7bLhRABBS3Vvim/8xPL958trmB
fuCZWBm/odDKkGhoM0OEnCF4LoWJm1GFVlztKcB6tS/EyE7qfw2JUYPKhR/wd2is
z7AtbkbkNsmkCENugE4+9mSdfIdgnXOqOFLj5GBKbMlusbIcNOhzA2VsfW36TlBv
MkZc0WjLUQWep9R5A5qiiF7DkLTBdreVvTkRNbqzj2+rYtpvzSNdfjfjFq5vAoO7
LhsjEQ723dqggTsfj5UJEI0Hc95s6VFulLbOXyZxWs2QQQKEzDSUkSJhJOumbTzA
ny9ur3d/2D1KQe3wcmYQP67zeIoGNepuuOlh6wLWYiOJeoKp0qPIseEtsbh/xKlY
9gLcyh5bZJ4fsz7dGRid
=V2is
-----END PGP SIGNATURE-----

--FqGL9A3E5tEDTsUSpMdkT97aGt20USH08--