This closes #1868
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c12d432d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c12d432d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c12d432d Branch: refs/heads/master Commit: c12d432d84437175e9ad54f9c31e8c0669f6ecdc Parents: 2c2424c 94bef14 Author: Amit Sela <amitsel...@gmail.com> Authored: Fri Mar 10 15:14:57 2017 +0200 Committer: Amit Sela <amitsel...@gmail.com> Committed: Fri Mar 10 15:14:57 2017 +0200 ---------------------------------------------------------------------- runners/spark/pom.xml | 5 + .../spark/SparkNativePipelineVisitor.java | 202 +++++++++++++++++++ .../apache/beam/runners/spark/SparkRunner.java | 16 +- .../beam/runners/spark/SparkRunnerDebugger.java | 121 +++++++++++ .../spark/translation/TransformEvaluator.java | 1 + .../spark/translation/TransformTranslator.java | 105 ++++++++++ .../streaming/StreamingTransformTranslator.java | 53 ++++- .../runners/spark/SparkRunnerDebuggerTest.java | 180 +++++++++++++++++ 8 files changed, 673 insertions(+), 10 deletions(-) ----------------------------------------------------------------------
