milena.analyze.streams.grouped — dvlopt/milena 0.4.0-alpha3

IGrouped clj protocol

aggregate clj

(aggregate grouped seed f)

(aggregate grouped seed f opts)

count clj

(count grouped)

(count grouped opts)

reduce clj

(reduce grouped f)

(reduce grouped f opts)

window-by-interval clj

(window-by-interval grouped-stream opts)

window-by-session clj

(window-by-session grouped-stream opts)