Skip to main content

Windowing

AWINAGG​

awinagg(Stream of Array s, Integer size, Integer stride) -> Stream of Array
STABLE

Stream of count windows over stream s represented as Arrays where: 

 `size` is the number of elements in each window
 `stride` is the number of elements in the window stride

PREDWIN​

predwin(Stream s, Integer c, Object p, Function e, Function l) -> Stream of Vector
STABLE

Form predicate windows over stream s by applying the window delimination 

 functions `e` and `l` on sliding change windows over `s` of size `cw`
 with stride 1. A new window is started when `e(cw,p)` is true
 and ended when `l(cw, p)` is true

predwin(Stream s, Integer c, Object p, Function e, Function l, Boolean start_entered) -> Stream of Vector
STABLE

No description.

REMOVE_NULL​

remove_null(Stream s) -> Stream
STABLE

Remove tuples in s containing some null

SHED​

shed(Stream s, Real period, Function fn, Integer min_shed, Integer max_shed)->Stream of (Object, Integer, Real)
STABLE

No description.

SHED0​

shed0(Stream s, Real period, Function fn, Integer min_shed, Integer max_shed)->(Integer, Object, Integer, Real)
STABLE

No description.

SHED:REAL_TIME​

shed:real_time(Timeval x) -> Real y
STABLE

No description.

SHED:REAL_TIME_PARAMS​

shed:real_time_params()->(Real last_val, Real tolerance)
STABLE

No description.

SHED_BASIC​

shed_basic(Stream s, Real period, Function fn, Integer min_shed, Integer max_shed) -> Stream
STABLE

No description.

SIMWINSTREAM​

simwinstream(Real pace, Integer sz) -> Stream of Vector of Real
STABLE

No description.

TWINAGG​

twinagg(Stream of Timeval s, Number size, Number stride, Boolean keep_ts) -> Stream of Timeval of Vector
STABLE

No description.

twinagg(Stream of Timeval s, Number size, Number stride, Timeval start) -> Stream of Timeval of Vector
STABLE

No description.

twinagg(Stream of Timeval s, Number size, Number stride) -> Stream of Timeval of Vector
STABLE

No description.

twinagg(Stream of Timeval s, Number size, Function pred, Vector args) -> Stream of Timeval of Vector
STABLE

No description.

twinagg(Stream of Timeval s, Number size, Boolean keep_ts, Function pred, Vector args) -> Stream of Timeval of Vector
STABLE

No description.

twinagg(Stream of Timeval s, Number size, Function pred) -> Stream of Timeval of Vector
STABLE

No description.

TWINAGG0​

twinagg0(Stream of Timeval s, Number size, Number stride, Timeval start, Boolean keep_ts) -> Stream of Timeval of Vector
STABLE

No description.

WINAGG​

winagg(Stream s, Number size, Number stride) -> Stream of Vector
STABLE

Stream of count windows over stream s represented as vectors where: 

 `size` is the number of elements in each window
 `stride` is the number of elements in the window stride