notebook.community

Edit and run



In [1]:

    
accum = sc.accumulator(0)
data = sc.parallelize(range(1,1000))



In [2]:

    
print data.takeSample(True, 10)









    



[156, 480, 111, 849, 205, 653, 407, 279, 328, 903]



In [3]:

    
data.foreach(lambda value: accum.add(value))
print accum.value



In [ ]: