RDD = sc.parallelize([1,2,3,4]) print RDD.map(lambda n: n+1).collect()