小编zhe*_*gjw的帖子

如何将参数传递给传递给 mapPartitions 的函数?

我正在尝试使用mapPartitionsfunction 而不是 using map,问题是我想将 anArray作为参数传递,但mapPartitions不作为参数传递Array。如何将数组作为参数传递?

mapPartitions[U: ClassTag](
    f: Iterator[T] => Iterator[U], preservesPartitioning: Boolean = false)
Run Code Online (Sandbox Code Playgroud)

scala apache-spark

1
推荐指数
1
解决办法
1707
查看次数

标签 统计

apache-spark ×1

scala ×1