You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/08/28 16:54:46 UTC
[2/2] beam git commit: [BEAM-1347] Add a BagUserState implementation
over the BeamFnStateClient
[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(+)
----------------------------------------------------------------------