gistfile1.txt

(ns storm-test.core
  (:import [backtype.storm StormSubmitter LocalCluster])
  (:use [backtype.storm clojure config])
  (:gen-class))

(defspout dummy-spout ["data"]
  [conf context collector]
  (let [data [2 4 8 16 32 64 128 256 512 1024 4096]]
    (dorun (map #(do
                   (println (str "Spout: " %))
                   (emit-spout! collector [%]))
                data))))

(defbolt dummy-bolt [""]
  [tuple collector]
  (println (str "Bolt: " (- (first tuple))))
  (emit-bolt! collector [(- (first tuple))] :anchor tuple))

(defn make-topology []
  (topology
   {1 (spout-spec dummy-spout)}
   {2 (bolt-spec {1 :shuffle} dummy-bolt :p 4)}))

(defn run-local! []
  (let [cluster (LocalCluster.)]
    (.submitTopology cluster "dummy-topology" {TOPOLOGY-DEBUG true} (make-topology))
    (Thread/sleep 10000)
    (.shutdown cluster)
    ))