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.


이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

도움이 필요하시나요? 지원 페이지를 방문하세요.