Trigger.TriggerContext (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.TriggerContext

  • java.lang.Object
    • com.google.cloud.dataflow.sdk.transforms.windowing.Trigger.TriggerContext
    • Constructor Detail

      • TriggerContext

        public TriggerContext()
    • Method Detail

      • trigger

        public abstract Trigger.TriggerInfo<W> trigger()
        Returns the interface for accessing trigger info.
      • state

        public abstract com.google.cloud.dataflow.sdk.util.state.StateAccessor<?> state()
        Returns the interface for accessing persistent state.
      • window

        public abstract W window()
        The window that the current context is executing in.
      • forTrigger

        public abstract Trigger.TriggerContext forTrigger(com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> trigger)
        Create a sub-context for the given sub-trigger.
      • deleteTimer

        public abstract void deleteTimer(Instant timestamp,
                                         com.google.cloud.dataflow.sdk.util.TimeDomain domain)
        Removes the timer set in this trigger context for the given Instant and TimeDomain.
      • currentProcessingTime

        public abstract Instant currentProcessingTime()
        The current processing time.
      • currentSynchronizedProcessingTime

        @Nullable
        public abstract Instant currentSynchronizedProcessingTime()
        The current synchronized upstream processing time or null if unknown.
      • currentEventTime

        @Nullable
        public abstract Instant currentEventTime()
        The current event time for the input or null if unknown.


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Dataflow