bucket-example.clj

;; bigrams bucket: keys are words,  
;; values are map of word counts
(def bigrams  
  (bucket/new
   {:type :mem
    ;; merge value maps with + 
    :merge (partial merge-with +)}))

;; For each word, count following words
(doseq [[word next-word] 
          (partition-all 2 words)]
  (bucket/merge bigrams 
     word {next-word 1}))