Re: Flink Streaming State Management

Posted by rmetzger0 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Streaming-State-Management-tp1673p1715.html

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 <[hidden email]> 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