This closes #2180
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c79bd95b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c79bd95b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c79bd95b Branch: refs/heads/master Commit: c79bd95bddab2329ef6117409621a3e00de84815 Parents: 1fd52f5 a889597 Author: Amit Sela <amitsel...@gmail.com> Authored: Tue Mar 7 15:13:54 2017 +0200 Committer: Amit Sela <amitsel...@gmail.com> Committed: Tue Mar 7 15:13:54 2017 +0200 ---------------------------------------------------------------------- .../beam/runners/spark/translation/BoundedDataset.java | 7 +------ .../beam/runners/spark/translation/TranslationUtils.java | 8 ++++++++ .../spark/translation/streaming/UnboundedDataset.java | 11 ++++++++++- 3 files changed, 19 insertions(+), 7 deletions(-) ----------------------------------------------------------------------
