beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [18/50] [abbrv] beam git commit: This closes #1868
Date Fri, 17 Mar 2017 21:46:49 GMT
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/gearpump-runner
Commit: c12d432d84437175e9ad54f9c31e8c0669f6ecdc
Parents: 2c2424c 94bef14
Author: Amit Sela <amitsela33@gmail.com>
Authored: Fri Mar 10 15:14:57 2017 +0200
Committer: Amit Sela <amitsela33@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(-)
----------------------------------------------------------------------



Mime
View raw message