The Clojure DSL is defined in the source in the org.apache.storm.clojure namespace. ... just use the StormSubmitter class just like you would from Java.
確定! 回上一頁