changed names

This commit is contained in:
Yann Esposito 2015-03-26 10:20:17 +01:00
parent 8ac94aabd5
commit 4f66cb8cd6

View file

@ -35,8 +35,8 @@
(where (service service-name)
(coalesce
(smap f
(with {:service (str service-name " " suffix)
:host "Aggregator"} index)))))))
(with {:service service-name
:host (str "Aggregator " suffix)} index)))))))
(defn add-sum-stream [service-name]
(add-stream-by service-name folds/sum "sum"))