Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Asynchronous I/O
    • Connectors
    • Formats
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink DataStream
  • Timer
  • pyflink.datastream.timerservice.TimerService.delete_processing_time_timer

pyflink.datastream.timerservice.TimerService.delete_processing_time_timer#

TimerService.delete_processing_time_timer(timestamp: int)[source]#

Deletes the processing-time timer with the given trigger time. This method has only an effect if such a timer was previously registered and did not already expire.

Timers can internally be scoped to keys and/or windows. When you delete a timer, it is removed from the current keyed context.

Parameters:

timestamp – The given trigger time of timer to be deleted.

previous

pyflink.datastream.timerservice.TimerService.register_event_time_timer

next

pyflink.datastream.timerservice.TimerService.delete_event_time_timer

On this page
  • TimerService.delete_processing_time_timer()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.