[BEAM-918] This closes #1370

Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/0c875ba7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/0c875ba7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/0c875ba7

Branch: refs/heads/master
Commit: 0c875ba704c2501c3215ffd588d02d2e4117ded2
Parents: 711c680 d99829d
Author: Jean-Baptiste Onofré <jbono...@apache.org>
Authored: Thu Dec 1 11:43:36 2016 +0100
Committer: Jean-Baptiste Onofré <jbono...@apache.org>
Committed: Thu Dec 1 11:43:36 2016 +0100

----------------------------------------------------------------------
 .../runners/spark/SparkPipelineOptions.java     |  5 ++
 .../spark/translation/BoundedDataset.java       |  5 +-
 .../beam/runners/spark/translation/Dataset.java |  2 +-
 .../spark/translation/EvaluationContext.java    | 10 +++-
 .../translation/StorageLevelPTransform.java     | 43 +++++++++++++++
 .../spark/translation/TransformTranslator.java  | 27 ++++++++++
 .../translation/streaming/UnboundedDataset.java | 13 ++++-
 .../spark/translation/StorageLevelTest.java     | 56 ++++++++++++++++++++
 8 files changed, 155 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


Reply via email to