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