Sliding
- class windows.Sliding
-
Overlapping windows producing the latest value at each predicate.
“Sliding” windows are a series of overlapping windows that produce values each
time the predicate evaluates to true. Each window is exclusive of the time
it starts at and inclusive of the end time.
- Parameters:
-
duration (int)
the number of active windows at any given time.
predicate (Timestream | Callable[, Timestream] | bool)
the condition used to determine when the oldest window ends and a new
window starts.
- static windows.Sliding.daily(duration)
-
Return a sliding window containing
duration
calendar days.- Parameters:
-
duration (int)
The number of days to use in the window.
- Returns:
-
Overlapping windows for aggregating values.
- static windows.Sliding.hourly(duration)
-
Return a sliding window containing
duration
calendar hours.- Parameters:
-
duration (int)
The number of hours to use in the window.
- Returns:
-
Overlapping windows for aggregating values.
- static windows.Sliding.minutely(duration)
-
Return a sliding window containing
duration
calendar minutes.- Parameters:
-
duration (int)
The number of minutes to use in the window.
- Returns:
-
Overlapping windows for aggregating values.
- static windows.Sliding.monthly(duration)
-
Return a sliding window containing
duration
calendar months.- Parameters:
-
duration (int)
The number of months to use in the window.
- Returns:
-
Overlapping windows for aggregating values.
- static windows.Sliding.yearly(duration)
-
Return a sliding window containing
duration
calendar years.- Parameters:
-
duration (int)
The number of years to use in the window.
- Returns:
-
Overlapping windows for aggregating values.