106 Storm编程模型

简介: 106 Storm编程模型

Topology:Storm中运行的一个实时应用程序的名称。(拓扑)

Spout:在一个topology中获取源数据流的组件。

通常情况下spout会从外部数据源中读取数据,然后转换为topology内部的源数据。

Bolt:接受数据然后执行处理的组件,用户可以在其中执行自己想要的操作。

Tuple:一次消息传递的基本单元,理解为一组消息就是一个Tuple。

Stream:表示数据的流向。

目录
相关文章
|
7月前
|
分布式计算 并行计算 Java
【分布式计算框架】 MapReduce编程初级实践
【分布式计算框架】 MapReduce编程初级实践
232 2
|
消息中间件 存储 缓存
Storm核心组件、编程模型
Storm核心组件、编程模型
219 0
|
SQL 分布式计算 算法
Flink 的编程模型与其他框架比较
我们在讲解 Flink 程序的编程模型之前,先来了解一下 Flink 中的 Streams、State、Time 等核心概念和基础语义,以及 Flink 提供的不同层级的 API。
267 0
Flink 的编程模型与其他框架比较
|
消息中间件 IDE Java
Flink实战(三) - 编程范式及核心概念(一)
Flink实战(三) - 编程范式及核心概念(一)
161 0
Flink实战(三) - 编程范式及核心概念(一)
|
分布式计算 Java API
Flink实战(三) - 编程范式及核心概念(三)
Flink实战(三) - 编程范式及核心概念(三)
127 0
Flink实战(三) - 编程范式及核心概念(三)
|
分布式计算 Java Hadoop
Flink实战(三) - 编程范式及核心概念(四)
Flink实战(三) - 编程范式及核心概念(四)
163 0
Flink实战(三) - 编程范式及核心概念(四)
|
存储 分布式计算 Java
Flink实战(三) - 编程范式及核心概念(二)
Flink实战(三) - 编程范式及核心概念(二)
168 0
Flink实战(三) - 编程范式及核心概念(二)
|
分布式计算 Java API
Flink实战(三) - 编程范式及核心概念
1 基本的 API 概念 Flink程序是实现分布式集合转换的常规程序(例如,过滤,映射,更新状态,加入,分组,定义窗口,聚合)。最初从源创建集合(例如,通过从文件,kafka主题或从本地的内存集合中读取)。
1723 0
|
存储 分布式计算 Java
|
分布式计算 资源调度 并行计算
并行计算框架MapReduce编程模型
思想:分而治之 map:对每一部分进行处理 reduce :汇总map结果 map是MapReduce最核心的。 mapreduce编程模型 一种分布式计算模型,解决海量数据计算问题 MapReduce把整个并行计算的过程抽象到两个函数,map和reduce函数。
1522 0