onyx.windowing.window-extensions
->FixedWindow
(->FixedWindow id task type init window-key min-value range w-range units slide timeout-gap doc window)
Positional factory function for class onyx.windowing.window_extensions.FixedWindow.
->GlobalWindow
(->GlobalWindow id task type init window-key min-value range slide timeout-gap doc window)
Positional factory function for class onyx.windowing.window_extensions.GlobalWindow.
->SessionWindow
(->SessionWindow id task type init window-key min-value range slide gap timeout-gap units doc window)
Positional factory function for class onyx.windowing.window_extensions.SessionWindow.
->SlidingWindow
(->SlidingWindow id task type init window-key min-value range slide units w-range w-slide timeout-gap doc window)
Positional factory function for class onyx.windowing.window_extensions.SlidingWindow.
bounding-extents
(bounding-extents extents session-time)
Find the extents with the closest lower bounds.
extent-serializer
multimethod
Given a window, return the type of extent serializer
IWindow
protocol
members
bounds
(bounds this window-id)
Returns a vector of two elements. The first is the lower bound that this window
id accepts, and the second is the upper.
event-time
(event-time this segment)
extent-operations
(extent-operations this all-extents segment time-index)
Given a segment time and all extents, return the vector of operations that should be performed on the windows.
Operations take the form [action arg1 arg2].
Support actions are:
[:merge-extents extent1 extent2 merged-extent]
[:alter-extents old-extent new-extent]
[:update extent]
extents
(extents this time-index)
time-index
(time-index this time)
Given a segment, return the coerced window time for the window key.
time-index->extent
(time-index->extent this time)
Given a time in milliseconds, compute the corresponding extent.
map->FixedWindow
(map->FixedWindow m__6522__auto__)
Factory function for class onyx.windowing.window_extensions.FixedWindow, taking a map of keywords to field values.
map->GlobalWindow
(map->GlobalWindow m__6522__auto__)
Factory function for class onyx.windowing.window_extensions.GlobalWindow, taking a map of keywords to field values.
map->SessionWindow
(map->SessionWindow m__6522__auto__)
Factory function for class onyx.windowing.window_extensions.SessionWindow, taking a map of keywords to field values.
map->SlidingWindow
(map->SlidingWindow m__6522__auto__)
Factory function for class onyx.windowing.window_extensions.SlidingWindow, taking a map of keywords to field values.
ordered-log?
(ordered-log? window)
window-id-impl-extents
(window-id-impl-extents units min-value w-range w-slide window-time)
windowing-builder
multimethod
Given a window, return the concrete type to perform
operations against.