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.