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/master Commit: e2ee59557befd729e24e62a4991a76bab64f5755 Parents: b3099bb 22dbb50 Author: Aviem Zur <aviem...@gmail.com> Authored: Thu Jun 22 15:33:26 2017 +0300 Committer: Aviem Zur <aviem...@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(-) ----------------------------------------------------------------------
