python - PySpark RDD MapPartition 转换
问题描述
为什么可以yield进行mapPartition转换，但return不能？
例如这有效：
def foo(x): yield max(x)
但这不会：
def foo(x): return max(x)
为什么可以yield进行mapPartition转换，但return不能？
例如这有效：
def foo(x): yield max(x)
但这不会：
def foo(x): return max(x)
标签： pythonpysparkrdd