PySpark RDD MapPartition Tansformation - PullRequest
0 голосов
/ 21 марта 2020

Почему yield работает с mapPartition преобразованием, а return - нет?

, например, это работает:

def foo(x): yield max(x) 

, но это не так:

def foo(x): return max(x)
...