This closes #2513
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/dc672f42 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/dc672f42 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/dc672f42 Branch: refs/heads/master Commit: dc672f42083c375872d87030523545866cea4f55 Parents: 8479094 facdc10 Author: Dan Halperin <[email protected]> Authored: Wed Apr 12 16:08:35 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed Apr 12 16:08:35 2017 -0700 ---------------------------------------------------------------------- .../runners/core/construction/Triggers.java | 336 +++++++++++++++++++ .../core/construction/WindowingStrategies.java | 1 - .../runners/core/construction/TriggersTest.java | 111 ++++++ runners/core-java/pom.xml | 5 + .../GroupAlsoByWindowViaOutputBufferDoFn.java | 2 +- .../core/GroupAlsoByWindowViaWindowSetDoFn.java | 2 +- .../GroupAlsoByWindowViaWindowSetNewDoFn.java | 2 +- .../beam/runners/core/ReduceFnTester.java | 2 +- .../GroupAlsoByWindowEvaluatorFactory.java | 2 +- .../SparkGroupAlsoByWindowViaWindowSet.java | 3 +- ...SparkGroupAlsoByWindowViaOutputBufferFn.java | 2 +- .../beam/sdk/transforms/windowing/Triggers.java | 1 + .../sdk/transforms/windowing/TriggersTest.java | 100 ------ 13 files changed, 460 insertions(+), 109 deletions(-) ----------------------------------------------------------------------
