没有合适的资源?快使用搜索试试~ 我知道了~
storm-spring-autowire:使storm支持spring的注入功能
共47个文件
java:44个
xml:2个
md:1个
需积分: 10 0 下载量 41 浏览量
2021-05-04
23:51:17
上传
评论
收藏 36KB ZIP 举报
温馨提示
storm-spring-autowire 使storm支持spring的注入功能 由于storm的生命周期如下 1.在提交了一个topology之后(是在nimbus所在的机器么?), 创建spout/bolt实例(spout/bolt在storm中统称为component)并进行序列化. 2.将序列化的component发送给所有的任务所在的机器 3.在每一个任务上反序列化component. 4.在开始执行任务之前, 先执行component的初始化方法(bolt是prepare, spout是open). 这个项目采取了了在prepare方法中执行注入的方式使bolt在序列化完成后执行注入,绕开了storm的序列化机制 使用这个项目里 你可以通过以下代码做到最基本的注入 @Resource private SentenceCounter counter; public void
资源推荐
资源详情
资源评论
收起资源包目录
storm-spring-autowire-master.zip (47个子文件)
storm-spring-autowire-master
README.md 3KB
pom.xml 1KB
java
test
resource
applicationContext.xml 539B
src
org
im
storm
counter
SentenceCounter.java 315B
WordCounter.java 317B
bolt
AggregatorBolt.java 1KB
SentenceCounterBolt.java 1KB
WordCounterBolt.java 1KB
spout
TestSpout.java 1003B
main
TestAutoBuild.java 729B
main
src
org
im
storm
utils
PackageUtil.java 4KB
BeanUtil.java 2KB
annotation
grouping
GlobalGrouping.java 279B
FieldsGrouping.java 299B
DirectGrouping.java 279B
LocalOrShuffleGrouping.java 287B
ShuffleGrouping.java 291B
PartialKeyGrouping.java 303B
AllGrouping.java 278B
NoneGrouping.java 277B
base
Bolt.java 293B
Spout.java 330B
groups
ShuffleGroups.java 314B
PartialKeyGroups.java 389B
AllGroups.java 302B
DirectGroups.java 311B
LocalOrShuffleGroups.java 335B
FieldsGroups.java 311B
GlobalGroups.java 311B
NoneGroups.java 305B
strategy
impl
NoneGroupingStrategy.java 1KB
AllGroupingStrategy.java 1KB
DirectGroupingStrategy.java 1KB
LocalOrShuffleGroupingStrategy.java 1KB
ShuffleGroupingStrategy.java 1KB
PartialKeyGroupingStrategy.java 1KB
GlobalGroupingStrategy.java 1KB
FieldsGroupingStrategy.java 1KB
Strategies.java 740B
GroupingStrategy.java 302B
model
proxy
Proxy.java 127B
impl
ProxySpout.java 2KB
ProxyBolt.java 1KB
bolt
BaseRichBolt.java 813B
BaseBasicBolt.java 815B
spout
BaseRichSpout.java 774B
build
AutoBuild.java 3KB
共 47 条
- 1
资源评论
沐水涤尘
- 粉丝: 27
- 资源: 4626
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- (源码)基于Spring Boot和WebSocket的毕业设计选题系统.zip
- (源码)基于C++的机器人与船舶管理系统.zip
- (源码)基于WPF和Entity Framework Core的智能货架管理系统.zip
- SAP Note 532932 FAQ Valuation logic with active material ledger
- (源码)基于Spring Boot和Redis的秒杀系统.zip
- (源码)基于C#的计算器系统.zip
- (源码)基于ESP32和ThingSpeak的牛舍环境监测系统.zip
- 西南科技大学数据库实验三
- Web开发全栈入门与进阶指南:从前端到后端
- TSP问题的概述及其在多领域的应用
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功