[BEAM-1347] Add a BagUserState implementation over the BeamFnStateClient This closes #3760
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ba5c4071 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ba5c4071 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ba5c4071 Branch: refs/heads/master Commit: ba5c4071dfa1831262bc01aa33f06ac0e5561484 Parents: f634aec 8d36a26 Author: Luke Cwik <lc...@google.com> Authored: Mon Aug 28 09:54:38 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Mon Aug 28 09:54:38 2017 -0700 ---------------------------------------------------------------------- .../beam/fn/harness/state/BagUserState.java | 121 +++++++++++++++++++ .../state/LazyCachingIteratorToIterable.java | 72 +++++++++++ .../beam/fn/harness/state/BagUserStateTest.java | 106 ++++++++++++++++ .../fn/harness/state/FakeBeamFnStateClient.java | 110 +++++++++++++++++ .../LazyCachingIteratorToIterableTest.java | 76 ++++++++++++ 5 files changed, 485 insertions(+) ----------------------------------------------------------------------