1
例如变换RDD我有型((i,j), k)
的下一个RDD:在PySpark
((0,0), 0)
((0,1), 0)
((1,0), 0)
((1,1), 0)
我想将它转化为一个又一个,其中有1
如果i==j
。我的第一次尝试出错了:
rddnew = rdd.flatMap(lambda ((i,j), k): [if i==j: ((i,j), 1)]))
有人可以帮助我改进Python代码?