1. 前言
- Spark必须安装Java,使用Python还需安装Python。
2. 生态
Spark SQL:用来操作结构化数据的核心组件,通过Spark SQL可以直接查询Hive、 HBase等多种外部数据源中的数据。Spark SQL的重要特点是能够统一处理关系表和RDD在处理结构化数据时,开发人员无须编写 MapReduce程序,直接使用SQL命令就能完成更加复杂的数据查询操作。
Spark Streaming:Spark提供的流式计算框架,支持高吞吐量、可容错处理的实时流式数据处理,其核心原理是将流数据分解成一系列短小的批处理作业,每个短小的批处理作业都可以使用 Spark Core进行快速处理。Spark Streaming支持多种数据源,如 Kafka以及TCP套接字等。
MLlib:Spark提供的关于机器学习功能的算法程序库,包括分类、回归、聚类、协同过滤算法等,还提供了模型评估、数据导入等额外的功能,开发人员只需了解一定的机器学习算法知识就能进行机器学习方面的开发,降低了学习成本。
GraphX: Spark提供的分布式图处理框架,拥有图计算和图挖掘算法的API接口以及丰富的功能和运算符,极大地方便了对分布式图的处理需求,能在海量数据上运行复杂的图算法。
3. 基础架构
- Spark的集群管理器、YARN、Mesos
- Spark 支持 Standalone、Yarn、Mesos、Kubernetes 等多种部署方案
- SparkSession
- DataFrame
- Panda(Python)DataFrame转换为Spark DataFrame
Python DataFrame存在与一台机器上(有些情况例外)
- RDD(Resilient Distributed Datasets,弹性分布式数据集)
4. 两类转换操作
- 窄依赖
- 宽依赖