00 Spark Overview

转载请注明出处,谢谢合作~

Spark 概述

Apache Spark 是一个用于大规模数据处理的计算分析引擎,提供了不同语言(Java, Scala, Python, R)的 high-level API 和优化层来支撑通用性的执行流程图,同时提供了丰富的 higher-level 模块来应对不用的场景,包括采用 SQL 结构化数据处理的 Spark SQL 模块,适用于机器学习的 MLlib 模块,适用于图计算的 GraphX 模块,以及适用于增量计算和流式计算的 Structured Streaming 模块。

安全

Spark 中的安全机制默认是关闭的,这意味着在默认情况下你的 Spark 系统很容易收到攻击。请在下载和使用之前参考 Spark Security

下载

你可以从网站的下载页(downloads page)获取 Spark,该文档适用于 Spark 3.0.0 版本。Spark 采用 Hadoop 的客户端依赖库操作 HDFS 和 YARN,下载包提供了集成主流 Hadoop 版本的下载版本。用户也可以下载没有集成 Hadoop 的版本,通过配置 classpath 的方式(by augmenting Spark’s classpath)集成任意的 Hadoop 版本。Scala 和 Java 用户通过 Maven 将 Spark 融合到自己的项目当中,Python 用户可以通过 PyPI 安装 Spark。

如果你想通过源码编译 Spark,参见 Building Spark

Spark 可以运行在 Windows 或者 UNIX-like (e.g. Linux, Mac OS) 系统,前提是提供相应版本的 Java,即可以运行在 x86_64 和 ARM64 平台的 JVM。只要你的环境变量 PATH 中配置有 java 命令所在的路径或者包含指向 Java 安装目录的JAVA_HOME环境变量,就可以让 Spark 运行在任何一台机器上。

Spark 依赖 Java 8/11,Scala 2.12,Python 2.7+/3.4+ 和 R 3.1+。在 Spark 3.0.0 版本中,Java 8u92 之前的版本被标记为弃用,Python 2 和 低于 3.6 的 Python 被标记为弃用,低于 3.4 版本的 R 被标记为弃用。Spark 3.0 采用的 Scala 版本是 2.12,你需要使用相应版本的 Scala (2.12.x)。

对于 Java 11,当 Apache Arrow 的运行涉及到 Netty 时需要添加启动参数-Dio.netty.tryReflectionSetAccessible=true,来避免错误:java.lang.UnsupportedOperationException: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

运行示例和 Shell

Spark 提供了一些示例程序,不同语言版本(Scala, Java, Python and R )的示例程序存储在目录examples/src/main 当中。你可以在 Spark 的根目录使用命令 bin/run-example <class> [params]运行 Java 或者 Scala 版本的示例程序(该命令会调用 spark-submit script 脚本启动应用程序)。例如:

./bin/run-example SparkPi 10

你也可以通过相应版本的 Scala shell 来交互式的运行 Spark,这是学习 Spark 框架的一个很好的途径。

./bin/spark-shell --master local[2]

参数 --master 可以指定集群地址(master URL for a distributed cluster), 或者设置为 local 在本地单线程的运行,或者设置为 local[N] 在本地多线程的运行,N 表示线程数量。你应该在 local 模式下进行测试。可以通过 --help 参数获取完整的帮助信息。

Spark 同时提供了 Python API,可以通过启动 Python 解释器bin/pyspark 交互式的运行 Spark:

./bin/pyspark --master local[2]

示例应用程序也提供了 Python 版本,例如:

./bin/spark-submit examples/src/main/python/pi.py 10

在 1.4 版本之后 Spark 还提供了 R API (只包括 DataFrames API),可以通过启动 R 解释器`bin/sparkR 交互式的运行 Spark:

./bin/sparkR --master local[2]

示例应用程序也提供了 R 版本,例如:

./bin/spark-submit examples/src/main/r/dataframe.R

启动集群

Spark 集群模式概述(cluster mode overview)解释了在集群上运行 Spark 的一些关键概念,Spark 可以自己启动集群或者依赖现有的一些集群资源管理模块。目前提供的部署模式有以下几种:

接下来干点啥呢

编程指南:

API 文档:

部署指南:

其他文档:

外部资源:

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 218,122评论 6 505
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 93,070评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,491评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,636评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,676评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,541评论 1 305
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,292评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,211评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,655评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,846评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,965评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,684评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,295评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,894评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,012评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,126评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,914评论 2 355