Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink Common

pyflink.table.window.SlideWithSize.every#

SlideWithSize.every(slide: Expression) → SlideWithSizeAndSlide[source]#

Specifies the window’s slide as time or row-count interval.

The slide determines the interval in which windows are started. Hence, sliding windows can overlap if the slide is smaller than the size of the window.

For example, you could have windows of size 15 minutes that slide by 3 minutes. With this 15 minutes worth of elements are grouped every 3 minutes and each row contributes to 5 windows.

Parameters

slide – The slide of the window either as time or row-count interval.

Returns

A sliding window.

previous

pyflink.table.window.Slide.over

next

pyflink.table.window.SlideWithSizeAndSlide.on

On this page
  • SlideWithSize.every()
Show Source

Created using Sphinx 5.3.0.