Interface ProcessingTimeManager

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      long currentTime()
      Get the current processing time.
      void deleteTimer​(long timestamp)
      Deletes the processing-time timer with the given trigger timestamp.
      void registerTimer​(long timestamp)
      Register a processing timer for this process function.
    • Method Detail

      • registerTimer

        void registerTimer​(long timestamp)
        Register a processing timer for this process function. `onProcessingTimer` method of this function will be invoked as callback if the timer expires.
        Parameters:
        timestamp - to trigger timer callback.
      • deleteTimer

        void deleteTimer​(long timestamp)
        Deletes the processing-time timer with the given trigger timestamp. This method has only an effect if such a timer was previously registered and did not already expire.
        Parameters:
        timestamp - indicates the timestamp of the timer to delete.
      • currentTime

        long currentTime()
        Get the current processing time.
        Returns:
        current processing time.