pyspark.RDD.foreach

RDD. foreach ( f : Callable[[T], None] ) → None

将一个函数应用于这个RDD的所有元素。

新增于版本 0.7.0。

Parameters

f function

应用于每个元素的函数

另请参阅

RDD.foreachPartition()

pyspark.sql.DataFrame.foreach()

pyspark.sql.DataFrame.foreachPartition()

示例

>>> def f(x): print(x)
...
>>> sc.parallelize([1, 2, 3, 4, 5]).foreach(f)

上一篇

pyspark.RDD.foldByKey

下一页

pyspark.RDD.foreachPartition