通过TopologyBuilder建立topology。 使用Storm Submitter,将topology递交给集群。以topology的名字、配置和topology的对象作为参数。 提交topology。 Listing Eight:建立和执行topology。
- public class StormMain
- {
- public static void main(String[] args) throws AlreadyAliveException,
- InvalidTopologyException,
- InterruptedException
-
44/47 首页 上一页 42 43 44 45 46 47 下一页 尾页