风暴样本
在 Hortonworks HDP 中构建风暴拓扑的示例代码。
这不是一个完整或有效的解决方案,但提供了启动风暴项目所需的所有示例位。
入门:
在 src/main/java/com/hortonworks/streaming/impl 下查看
在topologies目录下我们可以看到Storm拓扑(基类和实现类)
在螺栓下,您可以看到 HDFS(带旋转)、hive 和 solr 的螺栓
StormKafka方案在kafka目录下
此拓扑中的所有项目都是可选的,您可以禁用除 Kafka spout 之外的所有内容来启动,并根据需要添加螺栓。
在 src/main/resources 下查看
修改 config.properties 和 hbase-site.xml 中的所有内容以匹配您的环境
编译:
编译
建造:
mvn 包
部署示例脚本:
scp target/
2021-07-06 17:07:06
38KB
Java
1