beam
beam copied to clipboard
Support SetState in Dataflow runner
We could do so by implementing on top of existing MultiMapState similiar to how it is done for the fnapi harness
https://github.com/apache/beam/blob/master/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java#L370