blob: bd780a9c5a4dfeb1f46399a6dcf170bbf5fdbc5c [file] [log] [blame]
data = [1, 2, 3, 4, 5, 6, 7, 8, 9, 10]
rdd = ama_context.sc.parallelize(data)
odd = rdd.filter(lambda num: num % 2 != 0)