您的位置:首页 > 其它

storm-starter 例子学习

2015-06-27 11:29 204 查看
storm-starter 是 apache storm 针对初学者的一个用maven管理的项目示例。这篇文章记录storm-starter例子代码分析及执行。

参考:https://github.com/apache/storm/tree/master/examples/storm-starter

1,$ mvn clean install -DskipTests=true


命令的执行结果如下:



它会在每个相应的目录下生成target文件夹。

看到如上编译提示的信息,storm-core 在storm/storm-core/target目录下

storm-hdfs、storm-hive等等,这些生成的jar包在 storm/external/target目录下

2,在本地模式下编译并运行
ExclamationTopology


$ mvn compile exec:java -Dstorm.topology=storm.starter.ExclamationTopology






3, package a jar suitable for submitting to a Storm cluster

$ mvn package




此时,在storm-start/target/目录下生成了一个storm-starter-0.11.0-SNAPSHOT.jar文件,里面的部分内容如下:



对应的java源文件如下:



4,对Topology提交



提交结果如下:



5,在storm UI 中查看提交Topology后的执行情况:

这里启动了一个supervisor





有一个提交了的Topology


Topology没有执行??

内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: