Apache Storm 官方文档 —— 本地模式

原文链接    译者:魏勇

本地模式是一种在本地进程中模拟 Storm 集群的工作模式,对于开发和测试拓扑很有帮助。在本地模式下运行拓扑与在集群模式下运行拓扑的方式很相似。

创建一个进程内的“集群”只需要使用 LocalCluster 类即可,例如:

import backtype.storm.LocalCluster;

LocalCluster cluster = new LocalCluster();

随后,你就可以使用 LocalCluster 中的 submitTopology 方法来提交拓扑了。与 StormSubmitter 中相应的方法相似,submitTopology 接收一个拓扑名称、拓扑配置以及拓扑对象作为输入参数。你也可以以拓扑名称为参数,使用killTopology 方法来 kill 掉对应的拓扑。

使用以下语句关闭本地模式集群运行:

cluster.shutdown();

本地模式的常用配置

你可以在这里找到完整的配置项列表。以下是几个比较有用的配置项说明:

原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/118162.html

(0)
上一篇 2021年8月28日
下一篇 2021年8月28日

相关推荐

发表回复

登录后才能评论