<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                # 針對 Storm 定義一個不是 JVM 的 DSL 針對 Storm 開始學習如何使用非 JVM 的 DSL 的正確的地址是 [storm-core/src/storm.thrift](http://github.com/apache/storm/blob/master%0A/storm-core/src/storm.thrift). 由于 Storm topologies 只是 Thrift 的結構,Nimbus 是 Thrift 守護進程,您可以使用任何語言創建和提交 topologies. 當你針對 spouts 和 bolts 創建 Thrift 結構時, spout 和 bolt 的代碼指定在 ComponentObject 結構中: ``` union ComponentObject { 1: binary serialized_java; 2: ShellComponent shell; 3: JavaObject java_object; } ``` 針對 Python DSL,您需要使用 "2" 和 "3". ShellComponent 可以讓你指定一個腳本來運行組件(例如,你的 python 代碼). 并且針對組件(Storm 將使用反射來創建 spout 和 bolt)JavaObject 可以讓你指定本地的 java spouts 和 bolts. 以下是一個 "storm shell" 命令,它可以提交 topology. 用法如下: ``` storm shell resources/ python topology.py arg1 arg2 ``` Storm Shell resources/ 下的東西包裝到一個 jar 中,將 jar 上傳到 Nimbus,并像下面這樣調用你的 topology.py 腳本: ``` python topology.py arg1 arg2 {nimbus-host} {nimbus-port} {uploaded-jar-location} ``` 然后您可以使用 Thrift API 連接到 Nimbus,并提交 topology,將 {uploaded-jar-location} 傳遞到 submitTopology 方法. 作為參考,這里是 submitTopology 定義: ``` void submitTopology(1: string name, 2: string uploadedJarLocation, 3: string jsonConf, 4: StormTopology topology) throws (1: AlreadyAliveException e, 2: InvalidTopologyException ite); ``` 最后,在非 JVM DSL 中要做的一件重要的事情是,可以輕松地在一個文件(bolts,spouts 和 topology 的定義)中定義整個 topology.
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看