You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2016/12/01 13:34:22 UTC
[2/2] incubator-beam git commit: [BEAM-918] This closes #1370
[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� <jb...@apache.org>
Authored: Thu Dec 1 11:43:36 2016 +0100
Committer: Jean-Baptiste Onofr� <jb...@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(-)
----------------------------------------------------------------------