流式计算

简介: 从spark 说起,谈谈“流式”计算的理解spark是一个大数据分布式的计算框架,有一些并行计算的基础会更容易理解分布式计算框架的概念。对比并行计算,谈三个概念:并行计算Map Reduce 算子RDD数据结构并行计算spark的任务分为1个driver、多个executor。

从spark 说起,谈谈“流式”计算的理解

spark是一个大数据分布式的计算框架,有一些并行计算的基础会更容易理解分布式计算框架的概念。对比并行计算,谈三个概念:

  1. 并行计算
  2. Map Reduce 算子
  3. RDD数据结构
  • 并行计算

spark的任务分为1个driver、多个executor。程序启动driver,driver发送执行的程序(jar)到executor,executor在多台机器并行执行。driver和executor可以理解为进程,像httpd一样,完成某些任务,接受并发送数据的进程。

不同的spark任务都需要分配driver、executor。此时,还需要提供资源管理的应用,包括计算资源和内存资源的。

我们采用YARN作为spark资源管理系统,Mesos是另一个资源管理框架。


YARN
  • Map Reduce 算子

大数据与并行计算的最大区别,我认为就在map reduce算子上。

并行计算更喜欢做“关门打狗”的应用,高度并行,线程之间不做交互,例如口令破译,造表等。

spark中,用transform 和 action代替map Reduce操作。transform中的reduceByKey等操作对整体数据处理。例如,下面的代码是一个transform操作,rdd是(word,1)对象,reducebykey统计相同word出现的次数,这个操作是全局完成的。

rdd.reduceByKey((v1,v2)->v1+v2)
  • RDD数据结构

在并行计算中,需要维护一个全局数据结构,类似任务种子,每个节点维护与自己种子对应的数据片。

RDD(Resilient Distributed Datasets),弹性分布式数据集。在spark中,RDD维护一个全局的数据对象。每个任务executor自动对应自己的数据集分片。在编写程序的时候,对executor上到底有哪些数据不用关心,数据集的分片、合并等操作都是透明的,仅需要定义整个数据集的操作。

RDD

spark 大数据应用,挑战

spark用于实现大数据分析功能。如果数据源比较大,有几十亿条,用MySQL做数据分析,可能要一天的时间,spark可能几十分钟就能给出结果(因为采用分布式计算,分布式数据集)。

传统的web服务,属于online业务。online业务要求毫秒级的响应速度,这样的业务产生额外的要求,例如对用户的阅读记录对用户的画像的影响、一个订单对全城车辆调度的影响、一个用户的动态对推荐feed流的影响。

虽然,这些操作实时性不像online业务要求毫秒,但是也是秒级的。对spark批处理提出更多要求。

Spark streaming 解决秒级响应,即流式计算

spark streaming 将spark 批处理应用,缩小为一个微批micro batch,把microbatch作为一个计算单元。


Stream

典型应用如图。大量实时业务产生的实时数据,首先放在一个队列中,例如kafka,Spark streaming 从kafka中取出micorbatch进行处理。

JavaStreamingContext ssc = 
new JavaStreamingContext(sparkConf, Durations.seconds(5));
JavaReceiverInputDStream inputDStream =     
                ssc.socketTextStream("localhost",9999,
                    StorageLevel.MEMORY_AND_DISK());
JavaDStream<String> words =  inputDStream
            .flatMap(s->Arrays.asList(String.valueOf(s)
                          .split(" ")).iterator());

上面的代码案例,定义一个socket输入流,任务每5秒钟执行一次(微批),统计单词个数。

总结

本文是关于spark streaming流式计算理解的介绍文章。

希望读者能通过10分钟的阅读,理解spark streaming 及流式计算的原理。

文中对spark、yarn的原理没有深入讲解,有机会在后面的文章介绍。

下一篇我会根据spark streaming 官网中案例讲解JavaDStream mapWithState的练习。

目录
相关文章
计算机中存储单位的换算
计算机中存储单位的换算
|
4月前
|
数据采集 数据管理 BI
数据中台选型避坑指南:从功能、架构到服务,企业应该关注什么
本文基于DCMM与DAMA-DMBOK2,构建“功能深度、架构兼容性、服务持续性”三维选型框架,结合真实案例,破除“功能越多越好”误区,强调匹配企业数据成熟度、IT现状与组织能力,提供可落地、兼具学术性与工程性的中台选型方法论。
数据中台选型避坑指南:从功能、架构到服务,企业应该关注什么
|
传感器 监控 安全
PowerShell域内信息收集技术—Powerview用法
PowerView是PowerShell下用于域内信息收集的强大工具,支持枚举用户、组、计算机、共享资源及进程会话等,助力渗透测试与安全评估。通过Get-NetUser、Get-NetComputer等命令可全面探测AD环境,结合狩猎类指令实现用户行为分析。需强调:仅限授权使用。
664 4
|
机器学习/深度学习 人工智能 自然语言处理
拔俗AI智能营运分析助手:用数据驱动企业高效决策
AI智能营运分析助手融合AI、大数据与机器学习,构建“数据-算法-交互”三层架构,打破数据孤岛,实现多源数据自动融合、智能建模与自然语言交互。助力企业分钟级响应经营问题,降低技术门槛,提升决策效率,推动从经验驱动向数据驱动转型。(238字)
464 0
|
Java Android开发 开发者
【Uniapp开发】APP的真机调试指南,从开发到上架全过程
【Uniapp开发】APP的真机调试指南,从开发到上架全过程
1432 3
|
存储 监控 物联网
蜂窝网络基础架构详解:从基站到核心网
蜂窝网络基础架构详解:从基站到核心网
4173 9
|
XML Java 数据库连接
Mybatis-Plus学习小项目及详细教程
Mybatis-Plus学习小项目及详细教程
|
SQL 缓存 监控
一文带你了解MySQL之Change Buffer
上一篇文章一文带你了解MySQL数据库InnoDB_Buffer_Pool(点击跳转)我们学习了InnoDB Buffer Pool的工作原理,其作用是减少MySQL读取数据时直接与磁盘打交道的次数。那么写入数据时MySQL是否做了减少IO的优化呢?答案是肯定的,就要我们深入的学习Change Buffer。
945 1
一文带你了解MySQL之Change Buffer
|
JSON Linux Shell
vscode c++ 使用问题汇总
vscode c++ 使用问题汇总
686 0
|
缓存 搜索推荐 机器人
HTTP 状态码完整指南
HTTP 状态码完整指南
3321 0

热门文章

最新文章