Medium podstawowe
double_rdd = num_rdd.map(lambda x : x * 2)
Expensive Eagle
double_rdd = num_rdd.map(lambda x : x * 2)
even_rdd = num_rdd.filter(lambda x : x % 2 == 0)
num = [1,2,3,4,5]num_rdd = sc.parallelize(num)
flat_rdd = num_rdd.flatMap(lambda x : range(1,x))