storm-starter 例子学习

时间:2023-03-10 07:07:03
storm-starter 例子学习

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

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

1,$ mvn clean install -DskipTests=true

命令的执行结果如下:

storm-starter 例子学习

它会在每个相应的目录下生成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

storm-starter 例子学习

storm-starter 例子学习

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

$ mvn package

storm-starter 例子学习

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

storm-starter 例子学习

对应的java源文件如下:

storm-starter 例子学习

4,对Topology提交

storm-starter 例子学习

提交结果如下:

storm-starter 例子学习

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

这里启动了一个supervisor

storm-starter 例子学习

storm-starter 例子学习

有一个提交了的Topology storm-starter 例子学习

Topology没有执行??

storm-starter 例子学习