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 2016/04/12 18:32:15 UTC
[3/3] incubator-beam git commit: This closes #168
This closes #168
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c558a64c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c558a64c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c558a64c
Branch: refs/heads/master
Commit: c558a64c3892a1d00af9f99927e8fbe277523e3a
Parents: af1e575 de9f10c
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Apr 12 09:31:33 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Apr 12 09:31:33 2016 -0700
----------------------------------------------------------------------
.../sdk/transforms/windowing/AfterAll.java | 30 +++---
.../windowing/AfterDelayFromFirstElement.java | 28 ++---
.../sdk/transforms/windowing/AfterEach.java | 29 +++---
.../sdk/transforms/windowing/AfterFirst.java | 33 +++---
.../sdk/transforms/windowing/AfterPane.java | 23 ++---
.../windowing/AfterProcessingTime.java | 22 ++--
.../AfterSynchronizedProcessingTime.java | 11 +-
.../transforms/windowing/AfterWatermark.java | 102 +++++++++----------
.../transforms/windowing/DefaultTrigger.java | 20 ++--
.../transforms/windowing/OrFinallyTrigger.java | 24 ++---
.../sdk/transforms/windowing/Repeatedly.java | 21 ++--
.../sdk/transforms/windowing/Trigger.java | 85 +++++++---------
.../transforms/windowing/TriggerBuilder.java | 6 +-
.../sdk/transforms/windowing/Window.java | 20 ++--
.../dataflow/sdk/util/ExecutableTrigger.java | 58 +++++------
.../dataflow/sdk/util/FinishedTriggers.java | 6 +-
.../sdk/util/FinishedTriggersBitSet.java | 6 +-
.../dataflow/sdk/util/FinishedTriggersSet.java | 16 +--
.../dataflow/sdk/util/ReshuffleTrigger.java | 14 +--
.../sdk/util/TriggerContextFactory.java | 80 +++++++--------
.../cloud/dataflow/sdk/util/TriggerRunner.java | 12 +--
.../dataflow/sdk/util/WindowingStrategy.java | 12 +--
.../sdk/transforms/windowing/AfterAllTest.java | 6 +-
.../sdk/transforms/windowing/AfterEachTest.java | 6 +-
.../transforms/windowing/AfterFirstTest.java | 14 +--
.../windowing/AfterProcessingTimeTest.java | 8 +-
.../AfterSynchronizedProcessingTimeTest.java | 3 +-
.../windowing/AfterWatermarkTest.java | 14 +--
.../windowing/OrFinallyTriggerTest.java | 14 +--
.../transforms/windowing/RepeatedlyTest.java | 14 +--
.../sdk/transforms/windowing/TriggerTest.java | 44 ++++----
.../sdk/transforms/windowing/WindowTest.java | 8 +-
.../sdk/util/ExecutableTriggerTest.java | 18 ++--
.../sdk/util/FinishedTriggersProperties.java | 18 ++--
.../sdk/util/FinishedTriggersSetTest.java | 6 +-
.../dataflow/sdk/util/ReduceFnRunnerTest.java | 21 ++--
.../cloud/dataflow/sdk/util/ReduceFnTester.java | 8 +-
.../cloud/dataflow/sdk/util/TriggerTester.java | 16 +--
38 files changed, 419 insertions(+), 457 deletions(-)
----------------------------------------------------------------------