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

branch clj

(branch stream preds?)

filter clj

(filter stream pred?)

fmap clj

(fmap kstream f)

fmap-vals clj

(fmap-vals kstream f)

group-by clj

(group-by kstream f opts)

group-by-key clj

(group-by-key kstream)

(group-by-key kstream opts)

join-left-with-global-table clj

(join-left-with-global-table stream-left gtable-right f-map f-join)

join-left-with-stream clj

(join-left-with-stream stream-left stream-right window-ms f)

(join-left-with-stream stream-left stream-right window-ms f opts)

join-left-with-table clj

(join-left-with-table stream-left table-right f)

(join-left-with-table stream-left table-right f opts)

join-outer-with-stream clj

(join-outer-with-stream stream-left stream-right window-ms f)

(join-outer-with-stream stream-left stream-right window-ms f opts)

join-with-global-table clj

(join-with-global-table stream-left gtable-right f-map f-join)

join-with-stream clj

(join-with-stream stream-left stream-right window-ms f)

(join-with-stream stream-left stream-right window-ms f opts)

join-with-table clj

(join-with-table stream-left table-right f)

(join-with-table stream-left table-right f opts)

map clj

(map stream f)

map-keys clj

(map-keys stream f)

map-vals clj

(map-vals kstream f)

process clj

(process stream store-names processor)

side-effect clj

(side-effect stream f)

sink clj

(sink kstream f)

sink-topic clj

(sink-topic kstream topic)

(sink-topic kstream topic opts)

through clj

(through stream topic)

(through stream topic opts)

transform clj

(transform stream store-names transformer)

transform-vals clj

(transform-vals stream store-names transformer-vals)