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.


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow
Need help? Visit our support page.