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.


Send feedback about...

Cloud Dataflow