《Storm企业级应用:实战、运维和调优》——3.6 Task任务-阿里云开发者社区

开发者社区> 华章计算机> 正文

《Storm企业级应用:实战、运维和调优》——3.6 Task任务

简介:
+关注继续查看

本节书摘来自华章计算机《Storm企业级应用:实战、运维和调优》一书中的第3章,第3.6节,作者:马延辉 陈书美 雷葆华著, 更多章节内容可以访问云栖社区“华章计算机”公众号查看。

3.6 Task任务

Task是运行Spout或Bolt的单元,每一个Spout/Bolt的线程称为一个Task。
在Storm 0.8及之后的版本中,Task不再与物理线程对应,同一个Spout/Bolt的Task可能会共享一个物理线程,该线程称为Executor。
实际的数据处理由Task完成,在Topology的生命周期中,每个组件的Task数量不会变化,而Executor的数量却不一定。在一般情况下,线程数小于等于Task数量。默认Task的数量等于Executor线程数量,即一个Executor线程只运行一个Task。Executor线程在执行期间会调用该Task的nextTuple或execute方法。
每个Spout或Bolt都是通过集群中的许多任务来执行的。每个任务相当于一个执行线程,可以通过TopologyBuilder的setSpout方法和setBolt方法为每个Spout或Bolt设置并行数,即任务数。

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Redis Cluster集群应用与原理(下)
Redis Cluster集群应用与原理(下)
4 0
海康录像机RTSP回放流的格式
海康录像机RTSP回放流的格式
4 0
将 Flink 融合进消息系统,RocketMQ 为什么选择了与 Kafka 不一样的路
8 月 13 日,RocketMQ 迎来了 5.0 版本,这是继 2017 年发布 4.0 版本之后时隔 5 年的一次重大更新。
2 0
1sdfsaf
1sdfsaf
4 0
突破Java面试(41)-ZooKeeper的适用场景
突破Java面试(41)-ZooKeeper的适用场景
9 0
Hyperledger(超级账本)的worldstate和SAP CRM的CRMD_CUMULAT_H
Hyperledger(超级账本)的worldstate和SAP CRM的CRMD_CUMULAT_H
3 0
Hadoop 大数据系统在文件存储 HDFS 上的最佳实践
介绍Hadoop 大数据系统在文件存储 HDFS 上的最佳实践
15 0
《海量数据处理与大数据技术实战》来咯,从实战出发,解读大数据技术!
随着大数据技术和云计算技术的发展,Hadoop 大数据生态系统中的各项技术越来越流 行,已然成为大数据开发领域的事实标准。特别是 Hadoop 大数据生态系统中各项技术的开 源特性,使得其核心技术和各种解决方案得到了广泛的应用。程序员要想进入大数据开发领 域,除了需要有扎实的编程基础外,还要融会贯通各种大数据框架,最好还要熟悉大数据领 域中有典型意义和实用价值的各类开发案例。这样才能在竞争日益激烈的大数据市场环境中 具备较强的职场竞争力。
9 0
Flink实战(三) - 编程范式及核心概念(四)
Flink实战(三) - 编程范式及核心概念(四)
11 0
海康摄像头取、录像机RTSP视频流的字串格式
海康摄像头取、录像机RTSP视频流的字串格式
5 0
10059
文章
0
问答
来源圈子
更多
+ 订阅
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载