Spark Take 函数

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

在 Spark 中,take 函数的行为类似于数组。它接收一个整数值(例如,n)作为参数,并返回数据集的前 n 个元素的数组。

Take 函数的例子

在此示例中,我们返回现有数据集的前 n 个元素。

  • 要以 Scala 模式打开 Spark,请使用以下命令。
Spark Take Function
  • 使用并行集合创建 RDD。
  • 现在,我们可以使用以下命令读取生成的結果。
Spark Take Function
  • 应用 take() 函数以返回一个元素数组。
Spark Take Function

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