如何将字典中的值分别加到RDD*****中？
我有以下内容：
my_model = sc.parallelize([("Smith", np.array([1, 0, 3])), ("Johnson",np.array([2, 4, 1])), ("Brown",np.array([1, 1, 2]))])我希望最终输出为numpy array中的以下内容：
[4, 5, 6]我怎样才能得到numpy数组中的这个附加输出？
如何将字典中的值分别加到RDD*****中？
我有以下内容：
my_model = sc.parallelize([("Smith", np.array([1, 0, 3])), ("Johnson",np.array([2, 4, 1])), ("Brown",np.array([1, 1, 2]))])我希望最终输出为numpy array中的以下内容：
[4, 5, 6]我怎样才能得到numpy数组中的这个附加输出？
1条答案
按热度按时间jv4diomz1#
可以使用
reduce函数将RDD中的值相加：