apache-storm-flux

    3熱度

    2回答

    我使用的是磁通風暴(0.10.0)DSL部署以下拓撲結構(簡化爲只保留了它的相關部分): --- name: "my-topology" components: - id: "esConfig" className: "java.util.HashMap" configMethods: - name: "put" args:

    0熱度

    1回答

    我使用Flux 1.0.0,並將我的拓撲重寫爲YAML文件。但我有一些屬性曾經是我使用Storm驅動程序運行的配置的一部分。 storm.Driver --config myConfig/config.conf 現在用暴風助焊劑,我怎麼能注入是在config.conf到我的拓撲性質? 我目前在做java -cp myStormJar org.apache.sotrm.flux.Flux --loc

    1熱度

    1回答

    我們在LocalCluster中執行Storm拓撲。 風暴拓撲運行良好,能夠連接Storm UI(8090)。 但Storm UI未顯示正在運行的拓撲信息。 LocalCluster cluster = new LocalCluster(); ,並利用這樣的: bin/storm jar bin/StormTest-0.0.1-SNAPSHOT.jar com.abzooba.storm.tw

    2熱度

    1回答

    最近我開始使用Apache Storm。我使用Storm Clojure Storm DSL和Leiningen。 風暴拓撲管理有一個很酷的工具:Storm Flux。 我的問題是:當我用clojure編碼時如何使用flux?

    1熱度

    1回答

    我正在使用Flux YAML拓撲定義文件設計Apache Storm拓撲。麻煩是我看不到如何: - 創建一個流發送到多個螺栓(該語法似乎只包括一個':'行)。 從單個螺栓中釋放多個命名流。這在Apache Storm中是完全合法的。我擔心Stream'name:'行被聲明爲'optional - not used',因此Flux似乎不支持Storm的這個特性?