This closes #1950: State for "Set" data and "Map" data Add SetState and MapState Exclude UsesSetState and UsesMapState tests for Flink runner Exclude UsesSetState and UsesMapState categories from Dataflow runner Add UsesMapState and UsesSetState JUnit categories
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2596d46a Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2596d46a Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2596d46a Branch: refs/heads/master Commit: 2596d46a1ebbcfb72caa5b3a943ffe7d8d7f4ba2 Parents: ed3ef11 a0702f5 Author: Kenneth Knowles <k...@google.com> Authored: Tue Feb 14 13:57:38 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Tue Feb 14 13:57:38 2017 -0800 ---------------------------------------------------------------------- .../translation/utils/ApexStateInternals.java | 18 ++ .../runners/core/InMemoryStateInternals.java | 205 ++++++++++++++ .../apache/beam/runners/core/StateMerging.java | 44 +++ .../org/apache/beam/runners/core/StateTag.java | 8 + .../org/apache/beam/runners/core/StateTags.java | 30 ++ .../core/InMemoryStateInternalsTest.java | 280 +++++++++++++++++-- .../apache/beam/runners/core/StateTagTest.java | 33 +++ .../CopyOnAccessInMemoryStateInternals.java | 46 +++ .../CopyOnAccessInMemoryStateInternalsTest.java | 58 ++++ runners/flink/runner/pom.xml | 2 + .../wrappers/streaming/FlinkStateInternals.java | 18 ++ runners/google-cloud-dataflow-java/pom.xml | 2 + .../apache/beam/sdk/testing/UsesMapState.java | 25 ++ .../apache/beam/sdk/testing/UsesSetState.java | 25 ++ .../apache/beam/sdk/util/state/MapState.java | 93 ++++++ .../apache/beam/sdk/util/state/SetState.java | 71 +++++ .../apache/beam/sdk/util/state/StateBinder.java | 6 + .../apache/beam/sdk/util/state/StateSpecs.java | 89 ++++++ .../apache/beam/sdk/transforms/ParDoTest.java | 94 +++++++ 19 files changed, 1117 insertions(+), 30 deletions(-) ----------------------------------------------------------------------
