Clojure Storm Flux

Question

最近我開始使用Apache Storm。我使用Storm Clojure Storm DSL和Leiningen。

風暴拓撲管理有一個很酷的工具：Storm Flux。

我的問題是：當我用clojure編碼時如何使用flux？

Answer 1

我找到了一個解決方案：

(ns your.namespace.boltname 
    (:use 
    [org.apache.storm clojure config]) 
    (:gen-class :implements [org.apache.storm.topology.IRichBolt])) 

(defbolt my-bolt 
     ["data"] 
     [tuple collector] 
     (emit-bolt! collector [(f (.getString tuple 0))] :anchor tuple) 
     (ack! collector tuple)) 

(defn -execute [this tuple] 
(.execute my-bolt tuple)) 

(defn -prepare [this conf context collector] 
(.prepare my-bolt conf context collector)) 

(defn -cleanup [this] 
(.cleanup my-bolt)) 

(defn -declareOutputFields [this output] 
(.declareOutputFields my-bolt output)) 

(defn -getComponentConfiguration [this] 
(.getComponentConfiguration my-bolt)) 

不要忘記添加:aot :all到your project.clj。

而在你的流量topology.yaml是這樣的：

... 
bolts: 
    - id: "myBolt" 
    className: "your.namespace.boltname" 
    parallelism: 1 
... 

這是所有:)