java - Trident の Apache Storm プラガブル スケジューラ

Question

Core Storm では、プラガブル スケジューラを使用して特定のボルトを実行するノードを指定できます。Storm トポロジを Trident に再設計することを検討していますが、Trident トポロジを使用して特定のボルトをどのノードで実行する必要があるかを構成するのと同じ動作を得る方法がわかりません。Trident でスケジューリングは引き続き利用できますか? ありがとうございました。

Answer 1

低レベルの Java API または Trindent を使用して、同じ方法でカスタム スケジューラを指定できます。スケジューリングの観点からは、違いはありません。カスタム スケジューラを実装する方法の例については、こちらを参照してください: https://xumingming.sinaapp.com/885/twitter-storm-how-to-develop-a-pluggable-scheduler/

次のようにして、送信する前に Trident トポロジに関する情報を取得できます。

TridentTopology t = new TridentTopology();
// plug topology together

StormTopology st = t.build();
Map<String, SpoutSpec> spouts = st.get_spouts();
Map<String, Bolt> bolts = st.get_bolts();