Trigger.OnElementContext (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

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

Class Trigger.OnElementContext

    • Constructor Detail

      • OnElementContext

        public OnElementContext()
    • Method Detail

      • eventTimestamp

        public abstract Instant eventTimestamp()
        The event timestamp of the element currently being processed.
      • setTimer

        public abstract void setTimer(Instant timestamp,
                                      com.google.cloud.dataflow.sdk.util.TimeDomain domain)
        Sets a timer to fire when the watermark or processing time is beyond the given timestamp. Timers are not guaranteed to fire immediately, but will be delivered at some time afterwards.

        As with Trigger.TriggerContext.state(), timers are implicitly scoped to the current window. All timer firings for a window will be received, but the implementation should choose to ignore those that are not applicable.

        Parameters:
        timestamp - the time at which the trigger should be re-evaluated
        domain - the domain that the timestamp applies to


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow