PigPe是Clojure的Map-Reduce，可以编译到ApachePig或者Cascadig。
代码：
(require '[pigpe.core :as pig])(def word-cout [lies] (->> lies (pig/mapcat #(-> % first (clojure.strig/lower-case) (clojure.strig/replace #"[^\w\s]" "") (clojure.strig/split #"\s+"))) (pig/group-by idetity) (pig/map (f [[word occurreces]] [word (cout occurreces)]))))
评论