Hi,
it is not quiet clear to me what your window function is doing, so sharing some
(pseudo) code would be helpful. Is it ever calling a update-function for the
state you are trying to modify? From the information I have it seems not the be
the case and that is a wrong use of the API which requ
Hi,
the objects you get in the WindowFunction are not supposed to be mutated. Any
changes to them are not guaranteed to be synced back to the state backend.
Why are you modifying in the objects? Maybe there's another way of achieving
what you want to do.
Best,
Aljoscha
> On 9. Aug 2018, at 10
Hi all,
This is mingliang, I got a problem with rocksdb backend.
I'm currently using a 15min SessionWindow which also fires every 10s, there's
no pre-aggregation, so the input of WindowFunction would be the whole Iterator
of input object.
For window operator, I assume this collection is also
