📜  Apache Spark接受功能

📅  最后修改于: 2020-12-27 02:51:29             🧑  作者: Mango

火花点火功能

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

取函数示例

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

  • 要在Scala模式下打开Spark,请遵循以下命令。
$ spark-shell

  • 使用并行化的集合创建一个RDD。
scala> val data = sc.parallelize(List(10,20,30,40,50))
  • 现在,我们可以使用以下命令读取生成的结果。
scala> data.collect

  • 应用take()函数返回元素数组。
scala> val takefunc = data.take(3)

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