Package org.apache.beam.sdk.transforms.windowing

Class AfterProcessingTime

java.lang.Object
org.apache.beam.sdk.transforms.windowing.Trigger
org.apache.beam.sdk.transforms.windowing.Trigger.OnceTrigger
org.apache.beam.sdk.transforms.windowing.AfterProcessingTime
All Implemented Interfaces:
Serializable
public class AfterProcessingTime extends Trigger.OnceTrigger
A Trigger trigger that fires at a specified point in processing time, relative to when input first arrives.
See Also:

  • Method Details

    • pastFirstElementInPane

      public static AfterProcessingTime pastFirstElementInPane()
      Creates a trigger that fires when the current processing time passes the processing time at which this trigger saw the first element in a pane.

    • getTimestampTransforms

      public List<TimestampTransform> getTimestampTransforms()
      The transforms applied to the arrival time of an element to determine when this trigger allows output.

    • plusDelayOf

      public AfterProcessingTime plusDelayOf(Duration delay)
      Adds some delay to the original target time.
      Parameters:
      delay - the delay to add
      Returns:
      An updated time trigger that will wait the additional time before firing.

    • alignedTo

      public AfterProcessingTime alignedTo(Duration period, Instant offset)
      Aligns timestamps to the smallest multiple of period since the offset greater than the timestamp.

    • alignedTo

      public AfterProcessingTime alignedTo(Duration period)
      Aligns the time to be the smallest multiple of period greater than the epoch boundary (aka new Instant(0)).

    • isCompatible

      public boolean isCompatible(Trigger other)
      Description copied from class: Trigger
      For internal use only; no backwards-compatibility guarantees.

      Returns whether this performs the same triggering as the given Trigger.

      Overrides:
      isCompatible in class Trigger

    • getWatermarkThatGuaranteesFiring

      public Instant getWatermarkThatGuaranteesFiring(BoundedWindow window)
      Description copied from class: Trigger
      For internal use only; no backwards-compatibility guarantees.

      Returns a bound in event time by which this trigger would have fired at least once for a given window had there been input data.

      For triggers that do not fire based on the watermark advancing, returns BoundedWindow.TIMESTAMP_MAX_VALUE.

      This estimate may be used, for example, to determine that there are no elements in a side-input window, which causes the default value to be used instead.

      Specified by:
      getWatermarkThatGuaranteesFiring in class Trigger

    • getContinuationTrigger

      protected Trigger getContinuationTrigger(List<Trigger> continuationTriggers)
      Description copied from class: Trigger
      Subclasses should override this to return the Trigger.getContinuationTrigger() of this Trigger. For convenience, this is provided the continuation trigger of each of the sub-triggers in the same order as Trigger.subTriggers.
      Specified by:
      getContinuationTrigger in class Trigger
      Parameters:
      continuationTriggers - contains the result of Trigger.getContinuationTrigger() on each of the subTriggers in the same order.

    • toString

      public String toString()
      Overrides:
      toString in class Trigger

    • equals

      public boolean equals(@Nullable Object obj)
      Overrides:
      equals in class Trigger

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Trigger