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

Interface Trigger.TriggerInfo<W extends BoundedWindow>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method and Description
      boolean areAllSubtriggersFinished()
      Returns true if all the sub-triggers of the current trigger are marked finished.
      com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> firstUnfinishedSubTrigger()
      Returns the first unfinished sub-trigger.
      boolean isFinished()
      Returns true if the current trigger is marked finished.
      boolean isFinished(int subtriggerIndex)
      Return true if the given subtrigger is marked finished.
      boolean isMerging()
      Returns true if the windowing strategy of the current PCollection is a merging WindowFn.
      void resetTree()
      Clears all keyed state for triggers in the current sub-tree and unsets all the associated finished bits.
      void setFinished(boolean finished)
      Sets the finished bit for the current trigger.
      void setFinished(boolean finished, int subTriggerIndex)
      Sets the finished bit for the given sub-trigger.
      com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> subTrigger(int subtriggerIndex)
      Access the executable version of the specified sub-trigger.
      Iterable<com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W>> subTriggers()
      Access the executable versions of the sub-triggers of the current trigger.
      Iterable<com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W>> unfinishedSubTriggers()
      Returns an iterable over the unfinished sub-triggers of the current trigger.
    • Method Detail

      • subTriggers

        Iterable<com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W>> subTriggers()
        Access the executable versions of the sub-triggers of the current trigger.
      • subTrigger

        com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> subTrigger(int subtriggerIndex)
        Access the executable version of the specified sub-trigger.
      • isFinished

        boolean isFinished()
        Returns true if the current trigger is marked finished.
      • isFinished

        boolean isFinished(int subtriggerIndex)
        Return true if the given subtrigger is marked finished.
      • areAllSubtriggersFinished

        boolean areAllSubtriggersFinished()
        Returns true if all the sub-triggers of the current trigger are marked finished.
      • unfinishedSubTriggers

        Iterable<com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W>> unfinishedSubTriggers()
        Returns an iterable over the unfinished sub-triggers of the current trigger.
      • firstUnfinishedSubTrigger

        com.google.cloud.dataflow.sdk.util.ExecutableTrigger<W> firstUnfinishedSubTrigger()
        Returns the first unfinished sub-trigger.
      • resetTree

        void resetTree()
                throws Exception
        Clears all keyed state for triggers in the current sub-tree and unsets all the associated finished bits.
        Throws:
        Exception
      • setFinished

        void setFinished(boolean finished)
        Sets the finished bit for the current trigger.
      • setFinished

        void setFinished(boolean finished,
                         int subTriggerIndex)
        Sets the finished bit for the given sub-trigger.


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

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

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