This closes #3749
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a481d561 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a481d561 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a481d561 Branch: refs/heads/master Commit: a481d5611925f29224724bf0e79365db8f905853 Parents: 80aebd9 ffd08da Author: Stas Levin <stasle...@apache.org> Authored: Sun Sep 3 09:04:29 2017 +0300 Committer: Stas Levin <stasle...@apache.org> Committed: Sun Sep 3 09:04:29 2017 +0300 ---------------------------------------------------------------------- .../SparkGroupAlsoByWindowViaWindowSet.java | 15 ++-- .../spark/translation/BoundedDataset.java | 17 ++++- .../beam/runners/spark/translation/Dataset.java | 3 +- .../spark/translation/EvaluationContext.java | 23 ++++-- .../spark/translation/SparkContextFactory.java | 2 - .../translation/StorageLevelPTransform.java | 37 ---------- .../spark/translation/TransformTranslator.java | 53 +++++-------- .../spark/translation/TranslationUtils.java | 78 ++++++++++++++++++++ .../streaming/StreamingTransformTranslator.java | 15 +++- .../translation/streaming/UnboundedDataset.java | 27 +++++-- .../spark/translation/StorageLevelTest.java | 75 ------------------- 11 files changed, 166 insertions(+), 179 deletions(-) ----------------------------------------------------------------------
