Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.window.ContinuousProcessingTimeTrigger#

class ContinuousProcessingTimeTrigger(interval: int)[source]#

A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.

Methods

can_merge()

Note

If this returns true you must properly implement on_merge()

clear(window, ctx)

Clears any state that the trigger might still hold for the given window.

of(interval)

on_element(element, timestamp, window, ctx)

Called for every element that gets added to a pane.

on_event_time(time, window, ctx)

Called when an event-time timer that was set using the trigger context fires.

on_merge(window, ctx)

Called when several windows have been merged into one window by the WindowAssigner.

on_processing_time(time, window, ctx)

Called when a processing-time timer that was set using the trigger context fires.

register_next_fire_timestamp(time, window, ...)

previous

pyflink.datastream.window.ProcessingTimeTrigger

next

pyflink.datastream.window.PurgingTrigger

Show Source

Created using Sphinx 4.5.0.