Distributed, fault tolerant data processing for Clojure