You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/23 03:04:49 UTC
[23/50] beam git commit: This closes #3343
This closes #3343
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e2ee5955
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e2ee5955
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e2ee5955
Branch: refs/heads/gearpump-runner
Commit: e2ee59557befd729e24e62a4991a76bab64f5755
Parents: b3099bb 22dbb50
Author: Aviem Zur <av...@gmail.com>
Authored: Thu Jun 22 15:33:26 2017 +0300
Committer: Aviem Zur <av...@gmail.com>
Committed: Thu Jun 22 15:33:26 2017 +0300
----------------------------------------------------------------------
runners/spark/pom.xml | 42 +++---
.../apache/beam/runners/spark/SparkRunner.java | 2 +-
.../beam/runners/spark/TestSparkRunner.java | 2 +-
.../SparkGroupAlsoByWindowViaWindowSet.java | 6 +-
.../spark/stateful/SparkTimerInternals.java | 18 ++-
.../spark/util/GlobalWatermarkHolder.java | 127 ++++++++++++++-----
.../spark/GlobalWatermarkHolderTest.java | 18 +--
7 files changed, 141 insertions(+), 74 deletions(-)
----------------------------------------------------------------------