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

    • Constructor Detail

      • OnMergeContext

        public OnMergeContext()
    • Method Detail

      • 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 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
      • state

        public abstract com.google.cloud.dataflow.sdk.util.state.MergingStateAccessor<?,W> state()
        Description copied from class: Trigger.TriggerContext
        Returns the interface for accessing persistent state.
        Specified by:
        state in class Trigger.TriggerContext


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

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

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