AfterWatermark (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.transforms.windowing

Class AfterWatermark<W extends BoundedWindow>

• java.lang.Object
• • com.google.cloud.dataflow.sdk.transforms.windowing.AfterWatermark<W>

• Type Parameters:

  W - BoundedWindow subclass used to represent the windows used.

  ---

  
  

  @Experimental(value=TRIGGER)
  public class AfterWatermark<W extends BoundedWindow>
  extends Object

  AfterWatermark triggers fire based on progress of the system watermark. This time is a lower-bound, sometimes heuristically established, on event times that have been fully processed by the pipeline.

  For sources that provide non-heuristic watermarks (e.g. PubsubIO when using arrival times as event times), the watermark is a strict guarantee that no data with an event time earlier than that watermark will ever be observed in the pipeline. In this case, it's safe to assume that any pane triggered by an AfterWatermark trigger with a reference point at or beyond the end of the window will be the last pane ever for that window.

  For sources that provide heuristic watermarks (e.g. PubsubIO when using user-supplied event times), the watermark itself becomes an estimate that no data with an event time earlier than that watermark (i.e. "late data") will ever be observed in the pipeline. These heuristics can often be quite accurate, but the chance of seeing late data for any given window is non-zero. Thus, if absolute correctness over time is important to your use case, you may want to consider using a trigger that accounts for late data. The default trigger, Repeatedly.forever(AfterWatermark.pastEndOfWindow()), which fires once when the watermark passes the end of the window and then immediately therafter when any late data arrives, is one such example.

  The watermark is the clock that defines TimeDomain.EVENT_TIME.

  Additionaly firings before or after the watermark can be requested by calling AfterWatermark.pastEndOfWindow.withEarlyFirings(OnceTrigger) or AfterWatermark.pastEndOfWindow.withEarlyFirings(OnceTrigger).

• • Nested Class Summary

    Nested Classes 

    Modifier and Type	Class and Description
    static interface	AfterWatermark.AfterWatermarkEarly<W extends BoundedWindow> Interface for building an AfterWatermarkTrigger with early firings already filled in.
    static interface	AfterWatermark.AfterWatermarkLate<W extends BoundedWindow> Interface for building an AfterWatermarkTrigger with late firings already filled in.
    static class	AfterWatermark.FromEndOfWindow<W extends BoundedWindow> A watermark trigger targeted relative to the end of the window.

  • Method Summary

    All Methods Static Methods Concrete Methods 

    Modifier and Type	Method and Description
    static <W extends BoundedWindow> AfterWatermark.FromEndOfWindow<W>	pastEndOfWindow() Creates a trigger that fires when the watermark passes the end of the window.

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • Method Detail

    • pastEndOfWindow

      public static <W extends BoundedWindow> AfterWatermark.FromEndOfWindow<W> pastEndOfWindow()

      Creates a trigger that fires when the watermark passes the end of the window.