[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(-)
----------------------------------------------------------------------


Reply via email to