Hi All

I'm developing a beam pipeline to be run on dataflow.

I see that MapState and SetState are both not supported by Dataflow runner
yet. For my use case, I need to have a state per UserID that can hold
multiple events, which I would like to organize by an eventID or a
timestamp or a combination of both.

What is the best way to achieve this per user state holding multiple events
that I can lookup by a second ID? Is there a better way than using a
BagState and iterating each time?


Best
Ziyad

Reply via email to