You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2017/04/05 23:38:14 UTC
[1/2] beam git commit: Fixed a comment in AfterWatermark
Repository: beam
Updated Branches:
refs/heads/master 3500d694a -> 74f799509
Fixed a comment in AfterWatermark
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/174b631a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/174b631a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/174b631a
Branch: refs/heads/master
Commit: 174b631ac1b180505c4881795309ea6d2bc592f2
Parents: 3500d69
Author: Anil Muppalla <an...@spotify.com>
Authored: Wed Apr 5 19:01:10 2017 -0400
Committer: Dan Halperin <dh...@google.com>
Committed: Wed Apr 5 16:37:57 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/windowing/AfterWatermark.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/beam/blob/174b631a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
index 37b73a6..7cd2601 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java
@@ -55,7 +55,7 @@ import org.joda.time.Instant;
*
* <p>Additionaly firings before or after the watermark can be requested by calling
* {@code AfterWatermark.pastEndOfWindow.withEarlyFirings(OnceTrigger)} or
- * {@code AfterWatermark.pastEndOfWindow.withEarlyFirings(OnceTrigger)}.
+ * {@code AfterWatermark.pastEndOfWindow.withLateFirings(OnceTrigger)}.
*/
@Experimental(Experimental.Kind.TRIGGER)
public class AfterWatermark {
[2/2] beam git commit: This closes #2444
Posted by dh...@apache.org.
This closes #2444
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/74f79950
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/74f79950
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/74f79950
Branch: refs/heads/master
Commit: 74f7995097bee22a0701e27f31c7f0449a01e37c
Parents: 3500d69 174b631
Author: Dan Halperin <dh...@google.com>
Authored: Wed Apr 5 16:38:05 2017 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Wed Apr 5 16:38:05 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/transforms/windowing/AfterWatermark.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------