风暴样本在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/
暂无评论