Re: Flink Streaming State Management
Posted by
Hilmi Yildirim on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Streaming-State-Management-tp1673p1678.html
Hi Gyula,
thank you.
Best Regards,
Hilmi
Am 17.06.2015 um 09:44 schrieb Gyula
Fóra:
Hey Hilmi,
Flink currently supports user defined state through the
Checkpointed interface. Using this interface the user can define
what state should the system be aware of when doing snapshots
for fault tolerance. The state returned in the snapshotState
method will be checkpointed (and restored upon failure).
Currently there is no explicit update function so the user
need to implement his state updates as part of the operator
logic (inside the map function for instance). After the 0.9.0
we will change the state interfaces to have explicit update
functions, you can preview some of the functionality in the PR
Matthias referenced, or here is a document for a more detailed
discussion of this feature:
Cheers,
Gyula