Spark Map 函数

2025 年 3 月 17 日 | 阅读 1 分钟

在 Spark 中,Map 函数将源中的每个元素传递给一个函数,并形成一个新的分布式数据集。

Map 函数的示例

在本例中,我们向每个元素添加一个常量值 10。

  • 要以 Scala 模式打开 spark,请执行以下命令
Spark Map function
  • 使用并行集合创建 RDD。
  • 现在,我们可以使用以下命令读取生成的結果。
Spark Map function
  • 应用 map 函数并传递执行所需的表达式。
  • 现在,我们可以使用以下命令读取生成的結果。
Spark Map function

在这里,我们得到了期望的输出。


下一个主题Spark 过滤函数