Hey Hilmi, here is a great example of how to use the Checkpointed interface: https://github.com/StephanEwen/flink-demos/blob/master/streaming-state-machine/src/main/scala/com/dataartisans/flink/example/eventpattern/StreamingDemo.scala#L82
On Wed, Jun 17, 2015 at 12:44 AM, Hilmi Yildirim <hilmi.yildi...@neofonie.de > wrote: > Hi Matthias, > great! Thank you. > > Best Regards, > Hilmi > > > Am 17.06.2015 um 09:38 schrieb Matthias J. Sax: > >> 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. >>> >>> For example: >>> stream.map( use state for operation).updateState(update state). >>> >>> >>> Best Regards, >>> Hilmi >>> >>> >>> >>> >>>
