Repository: incubator-beam Updated Branches: refs/heads/master 772959447 -> 92ff63d3b
This closes #1543 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/92ff63d3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/92ff63d3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/92ff63d3 Branch: refs/heads/master Commit: 92ff63d3ba730ca592aa3f68e9786a528c87d2e3 Parents: 7729594 09e2f30 Author: Kenneth Knowles <[email protected]> Authored: Wed Dec 7 20:21:27 2016 -0800 Committer: Kenneth Knowles <[email protected]> Committed: Wed Dec 7 20:21:27 2016 -0800 ---------------------------------------------------------------------- .../CopyOnAccessInMemoryStateInternals.java | 467 +++++++++++++++ .../runners/direct/DirectExecutionContext.java | 1 - .../beam/runners/direct/EvaluationContext.java | 1 - .../GroupAlsoByWindowEvaluatorFactory.java | 1 - .../beam/runners/direct/ParDoEvaluator.java | 1 - .../runners/direct/StepTransformResult.java | 1 - .../beam/runners/direct/TransformResult.java | 1 - .../CopyOnAccessInMemoryStateInternalsTest.java | 562 +++++++++++++++++++ .../runners/direct/EvaluationContextTest.java | 1 - .../StatefulParDoEvaluatorFactoryTest.java | 1 - .../CopyOnAccessInMemoryStateInternals.java | 453 --------------- .../sdk/util/state/InMemoryStateInternals.java | 33 +- .../CopyOnAccessInMemoryStateInternalsTest.java | 552 ------------------ 13 files changed, 1054 insertions(+), 1021 deletions(-) ----------------------------------------------------------------------
