PROSAGA码农传奇-storm-Clojure Storm Flux

Clojure Storm Flux

作者: 大魔王
发布时间: 2024-04-18 01:31:19 (6天前)
转自：

<div class =“post-text”itemprop =“text”>
  <P>
    我找到了解决方案：
  </p>
   <pre>
    <code>
      (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))

</code>
  </pre>
  <P>
    别忘了添加
     <code>
      :aot :all
    </code>
     至
     <code>
      your project.clj
    </code>
    。
  </p>
  <P>
    在你的流量
     <code>
      topology.yaml
    </code>
     就像是：
  </p>
   <pre>
    <code>
      ...
bolts:
  - id: "myBolt"
    className: "your.namespace.boltname"
    parallelism: 1
...

</code>
  </pre>
  <P>
    就这样 ：）
  </p>
</DIV>