Sparkstreaming 介绍-流计算和批计算的区别 | 学习笔记

简介: 快速学习 Sparkstreaming 介绍-流计算和批计算的区别

开发者学堂课程【大数据Spark2020版(知识精讲与实战演练)第五阶段:Sparkstreaming 介绍-流计算和批计算的区别 】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/692/detail/12126


Sparkstreaming 介绍-流计算和批计算的区别

内容介绍

一、课堂目标

二、批量计算

三、流计算

四、流计算和批计算的区别

 

一、课堂目标

通过上节课的学习,流计算的应用场景带来两大要求,一、数据要快速处理,二、同时计算量巨大,接下来通过讲解流计算与批量计算的区别,说明流计算特殊的应用场景,明白何时用批量计算或者流计算

 

二、批量计算

批量计算整体流程如图:

image.png

使用 SPARK SQL 去吧 HDFS 等上的文件或者数据取出来

通过 SPARK 进行处理,然后落地在 hdfs 上

可以提供 hive 对 HDFS 的数据进行处理

往往读出来的数据较大,存在调度的时间,可能无法及时返回结果,

传统的计算方式,是无法快速计算数据结果的,Hdfs 的数据此时存在边界,数据量是固定的。

往往批量计算是为了形成一个数据仓库,对数据仓库进行查询,获取一些运行指标与特殊数据处理。

 

三、流计算

流计算和批量计算区别显著,如工业大数据

以工业应用场景为例

如图:

image.png

三台设备,数据以时间的形式源源不断地产生,一直产生,一直处理

此时数据没有边界,所以 SPARK 无法进行数据处理

此时数据往往放到过滤用的队列当中,如 kafka

kafka 是非常快速地数列工具,有许多磁盘上的优化,保证了数据的快速对接。

处理完成后以后,将数据落地到 Hbase 当中,Sparkstreaming

获取规律,结果,指标等信息,进行存储

再通过外部的 webui,对 HBease 进行处理

 

四、流计算和批计算的区别

1. 批量计算也叫做离线计算,数据有边界,有大小

2.流计算的数据是不断产生的

3.批量计算往往计算全量数据

4.流计算要求快速处理,所以处理的是增量数据

相关文章
|
移动开发 编解码 Java
Netty编码器和解码器
Netty从底层Java通道读到ByteBuf二进制数据,传入Netty通道的流水线,随后开始入站处理。在入站处理过程中,需要将ByteBuf二进制类型解码成Java POJO对象。这个解码过程可以通过Netty的Decoder解码器去完成。在出站处理过程中,业务处理后的结果需要从某个Java POJO对象编码为最终的ByteBuf二进制数据,然后通过底层 Java通道发送到对端。在编码过程中,需要用到Netty的Encoder编码器去完成数据的编码工作。
|
消息中间件 Java Apache
RocketMQ5.0 搭建 Name Server And Broker+Proxy 同进程部署、搭建RocketMQ控制台图形化界面
RocketMQ5.0 搭建 Name Server And Broker+Proxy 同进程部署、搭建RocketMQ控制台图形化界面
3032 0
|
消息中间件 监控 Java
Apache Kafka 分布式流处理平台技术详解与实践指南
本文档全面介绍 Apache Kafka 分布式流处理平台的核心概念、架构设计和实践应用。作为高吞吐量、低延迟的分布式消息系统,Kafka 已成为现代数据管道和流处理应用的事实标准。本文将深入探讨其生产者-消费者模型、主题分区机制、副本复制、流处理API等核心机制,帮助开发者构建可靠、可扩展的实时数据流处理系统。
1025 4
|
存储 前端开发 数据可视化
Postman vs. Apifox 用于 API 测试全面对比
寻找一款可靠的 API 测试工具?这份对比分析将深入探讨 Postman 和 Apifox 的功能和特性。了解哪款工具最适合您的 API 测试需求。
|
消息中间件 存储 监控
Apache Kafka 3.0与KRaft模式的革新解读
在该架构中,Kafka集群依旧包含多个broker节点,但已不再依赖ZooKeeper集群。被选中的Kafka集群Controller将从KRaft Quorum中加载其状态,并在必要时通知其他Broker节点关于元数据的变更。这种设计支持更多分区与快速Controller切换,并有效避免了因数据不一致导致的问题。
|
消息中间件 分布式计算 搜索推荐
【KafkaStream】微服务学习笔记十一:流式计算概述&KafkaStream入门
【KafkaStream】微服务学习笔记十一:流式计算概述&KafkaStream入门
1196 0
【KafkaStream】微服务学习笔记十一:流式计算概述&KafkaStream入门
|
消息中间件 安全 Kafka
Kafka如何进行内外网分流(超详细建议收藏)
Kafka如何进行内外网分流 网络通信中常见的配置文件解析
4275 1
Kafka如何进行内外网分流(超详细建议收藏)
|
消息中间件 RocketMQ
2024最全RocketMQ集群方案汇总
在研究RocketMQ集群方案时,发现网上存在诸多不一致之处,如组件包含NameServer、Broker、Proxy等。通过查阅官方文档,了解到v4.x和v5.x版本的差异。v4.x部署模式包括单主、多主、多主多从(异步复制、同步双写),而v5.x新增Local与Cluster模式,主要区别在于Broker和Proxy是否同进程部署。Local模式适合平滑升级,Cluster模式适合高可用需求。不同模式下,集群部署方案大致相同,涵盖单主、多主、多主多从等模式,以满足不同的高可用性和性能需求。
2248 0
|
资源调度 分布式计算 监控
YARN的基本架构
【6月更文挑战第19天】YARN的基本架构
706 10
|
消息中间件 SQL 监控
RocketMQ 5.3.0 版本中 Broker IP 配置为 IPv6 的情况
【8月更文第28天】RocketMQ 是一款分布式消息中间件,支持多种消息发布和订阅模式。在 RocketMQ 5.3.0 版本中,Broker 的配置文件 `broker.conf` 允许配置 IPv6 地址。当 Broker 的 `brokerIP1` 配置为 IPv6 地址时,会对 Broker 的启动、消息推送和状态监控等方面产生影响。本文将探讨如何在 RocketMQ 中配置 IPv6 地址,并检查 Broker 的状态。
1475 0