This closes #1815
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/847e4e9f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/847e4e9f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/847e4e9f Branch: refs/heads/master Commit: 847e4e9f0b84efa4726692cc8b7c9a0610703888 Parents: 343176c 62f9e7b Author: Sela <ans...@paypal.com> Authored: Mon Jan 30 22:53:56 2017 +0200 Committer: Sela <ans...@paypal.com> Committed: Mon Jan 30 22:53:56 2017 +0200 ---------------------------------------------------------------------- .../apache/beam/runners/spark/SparkRunner.java | 21 ++++- .../spark/aggregators/AccumulatorSingleton.java | 96 ++++++++++++++++++-- .../spark/aggregators/SparkAggregators.java | 20 +++- .../translation/streaming/CheckpointDir.java | 69 ++++++++++++++ .../SparkRunnerStreamingContextFactory.java | 44 ++++++--- .../ResumeFromCheckpointStreamingTest.java | 5 +- 6 files changed, 230 insertions(+), 25 deletions(-) ----------------------------------------------------------------------
