当前位置: 首页 > news >正文

Spark计算引擎

Spark是一个基于MapReduce思想的分布式通用计算框架,相对于MapReduce,它的升华主要体现在处理结果驻留在了内存中(RDD,即分布式内存的概念,也是将数据进行切片,计算的中间结果驻留在内存中,可以设置切片数,也可以采用默认值),可以直接与客户端交互,而不是像mapReduce那样,将结果存于hdfs,然后客户端再与hdfs交互,这样可以大大减少磁盘IO的消耗,更适用与数据挖掘和机器学习任务。

Spark支持检查点,会对任务的执行链进行记录,一旦某个任务执行失败,会对其进行重新执行,而不是对整个链路进行执行,大大提升了任务的执行效率

Spark支持Java,Python等多种语言开发,并提供了很多高级操作符,方便了不同语言之间的交互

Spark主要分为四块:

Spark Sql:类似传统的sql查询,可以直接查询hive中的数据

Spark Streaming:批处理的流式计算框架,map和reduce的各种算子就集中在这里,这是一个具体处理业务逻辑的地方

Spark GraphX:分布式的图处理框架,提供了很多图计算和图挖掘的接口

Spark MLIib:可拓展的机器学习库,包括很多常用算法,例如分类回归,聚类协同,决策树,朴素贝叶斯等

Spark的工作流程:

任务控制节点向集群管理器申请资源,启动执行器,执行器将任务分解并执行,执行结果返回控制节点

在Spark中一个应用由一个任务控制器和多个作业组成,同时作业可以切分成多个阶段,阶段可以再次切分成多个任务,这个任务就是Spark的最小逻辑执行单元了,可以利用多线程进行并行执行

http://www.jsqmd.com/news/22628/

相关文章:

  • 【轨物方案】变频器物联网软硬件一站式解决方案 - 详解
  • 人工智能初了解
  • 173天隧道技术篇防火墙组策略ICMPDNSSMB协议出网判断C2上线解决方案
  • Hbase分布式数据库
  • 软考六
  • MapReduce并行计算框架
  • 应用安全 ---
  • 实用指南:3DGS 如何理解它?
  • HDFS文件系统
  • Java 类加载器
  • 面试总被追问k8s调度器工作原理, 收藏 == 学废
  • 题解:十二重计数法
  • Wyn 商业智能软件:3D 可视化大屏搭建与设备利用全指南
  • 什么是Java Lambda
  • Java 代理
  • 《算法与数据结构》第七章[算法2]:广度优先搜索(BFS) - 指南
  • 中转API为什么比官方更便宜?AI中转站成本揭秘
  • Java 混合编程
  • Java 语法糖
  • JAVA RMI编程
  • 大资料毕业设计选题推荐-基于大数据的全球产品库存数据分析与可视化系统-大材料-Spark-Hadoop-Bigdata
  • 纸笔群群友命题乱做
  • 本人对KMP如何匹配到所有结果的算法存在一些疑惑...
  • 字符与Java国际化编程
  • Ubuntu 系统 /dev/sdb2(RAID 关联磁盘)挂载操作手册
  • 2025 年 10 月厨房排烟、厨房排烟罩、厨房排烟系统厂家最新推荐,资质、案例、售后三维测评与选购指南
  • 解决 Windows 下 Claude 通过 cmd/powershell 运行出错失去响应的问题
  • # Ubuntu 根目录空间扩展操作手册(基于 RAID 关联磁盘 /dev/sdb2)
  • 013的加密世界权威指南_第二部分
  • Perplexity Comet AI浏览器「等待网络链接」解决方案