+1 You should be able to use the Prism runner to implement this locally.
Prism passes the full suite of java MultimapState tests, and will ensure the implementation works on runners like Google Cloud Dataflow. I do not recommend spending time implementing multimap state in the python direct runner if it's not already supported. On Tue, Jun 17, 2025, 10:58 AM Shunping Huang via dev <dev@beam.apache.org> wrote: > +1 > I think it will be great to have that in Python SDK. > > On Sun, Jun 15, 2025 at 5:22 PM Rakesh Kumar <rakeshcu...@gmail.com> > wrote: > >> Hey Everyone, >> >> While updating the stateful processing document [1] I noticed that Java >> SDK has MultimapState >> <https://docs.google.com/document/d/1zm16QCxWEWNy4qW1KKoA3DmQBOLrTSPimXiqQkTxokc/edit?tab=t.0#heading=h.f4ova073h88e> >> [2] >> but it is missing from Python SDK. This was introduced as part of this PR: >> https://github.com/apache/beam/pull/23491 >> If no one has an objection, then I would like to implement this as part >> of the Python SDK. >> >> Thank you, >> Rakesh >> >> >> 1. https://github.com/apache/beam/pull/35209 >> 2. >> https://docs.google.com/document/d/1zm16QCxWEWNy4qW1KKoA3DmQBOLrTSPimXiqQkTxokc/edit?tab=t.0#heading=h.f4ova073h88e >> >>
