onyx.windowing.window-extensions — org.onyxplatform/onyx 0.14.6

bounding-extents clj/s

(bounding-extents extents session-time)

Find the extents with the closest lower bounds.

extent-serializer clj/s multimethod

Given a window, return the type of extent serializer

IWindow clj/s protocol

bounds clj/s

(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 clj/s

(event-time this segment)

extent-operations clj/s

(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 clj/s

(extents this time-index)

time-index clj/s

(time-index this time)

Given a segment, return the coerced window time for the window key.

time-index->extent clj/s

(time-index->extent this time)

Given a time in milliseconds, compute the corresponding extent.

ordered-log? clj/s

(ordered-log? window)

window-id-impl-extents clj/s

(window-id-impl-extents units min-value w-range w-slide window-time)

windowing-builder clj/s multimethod

Given a window, return the concrete type to perform operations against.