Summingbird – Streaming MapReduce with Scalding and Storm
github.com
github.com
You can see a presentation about a Clojure solution in Cascalog to a similar set of problems by Sam Ritchie here: "Cascalog 2 - Streaming MapReduce in Clojure" https://speakerdeck.com/sritchie/cascalog-2-dot-0-datalog-in...