beam
beam copied to clipboard
Support MapState in DataflowRunner
We could do so by implementing on top of MultimapState similar to fnapi harness https://github.com/apache/beam/blob/master/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java#L454