RDD = sc.parallelize([0,1,2,3])
print RDD.flatMap(lambda n: [n*2, n*2+1]).collect()