Hi,
as per the mail subject I wanted to ask you if a State access (read and
write) is synchronized.
I have the following stream:
val airtrafficEvents = stream
.keyBy(_.flightInfo.flight)
.map(new UpdateIdFunction())
where UpdateIdFunction is a RichMapFunction with a ValueState and a
MapState,
Hello,
state is local to each parallel instance of an operator. Coupled with
the fact that the "map" method is always called by the same thread (and
never concurrently) the ValueState (or any state for that matter) will
always return the latest values.
On 10.09.2017 14:39, Federico D'Ambrosi
Hi,
Thank you very much, Chesnay, for this clarification.
2017-09-11 19:36 GMT+02:00 Chesnay Schepler :
> Hello,
>
> state is local to each parallel instance of an operator. Coupled with the
> fact that the "map" method is always called by the same thread (and never
> concurrently) the ValueStat
