Hot swap clojure code into streaming data processing