java - Trident 中的 Apache Storm 可插拔调度程序

Question

Core Storm 允许通过可插入的调度程序指定在哪个节点上执行特定的 Bolt。我们正在考虑将 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();