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 <a...@spotify.com> Authored: Wed Apr 5 19:01:10 2017 -0400 Committer: Dan Halperin <dhalp...@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 {
