beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [23/50] beam git commit: This closes #3343
Date Fri, 23 Jun 2017 03:04:49 GMT
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 <aviemzur@gmail.com>
Authored: Thu Jun 22 15:33:26 2017 +0300
Committer: Aviem Zur <aviemzur@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(-)
----------------------------------------------------------------------



Mime
View raw message