[BEAM-649] This closes #1739
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/82b7b861 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/82b7b861 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/82b7b861 Branch: refs/heads/master Commit: 82b7b86139167a5eae58a7eb6ace05f2776ada56 Parents: c045b0e daa10dd Author: Jean-Baptiste Onofré <[email protected]> Authored: Thu Mar 23 17:29:44 2017 +0100 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Thu Mar 23 17:29:44 2017 +0100 ---------------------------------------------------------------------- .../apache/beam/runners/spark/SparkRunner.java | 64 ++++++++++++++++++-- .../spark/translation/BoundedDataset.java | 3 +- .../spark/translation/EvaluationContext.java | 61 ++++++++++++------- .../SparkRunnerStreamingContextFactory.java | 4 ++ .../apache/beam/runners/spark/CacheTest.java | 61 +++++++++++++++++++ .../spark/translation/StorageLevelTest.java | 6 +- 6 files changed, 168 insertions(+), 31 deletions(-) ----------------------------------------------------------------------
