from pyspark import SparkContext

sc $=$ SparkContext$($appName$=$"RDDComparison"$)$

rdd $=$ sc$.$parallelize$([(1,2),(2,4),(3,6),(4,1)])$

rdd$1\_$a $=$ rdd$.$map$($lambda x: $($x$,$ abs$($x$[0]-$ x$[1]))).$filter$($lambda x: x$[1]>2).$map$($lambda x: x$[0])$

rdd$1\_$b $=$ rdd$.$map$($lambda x: $($x$[0]-$ x$[1],$ x$)).$filter$($lambda x: abs$($x$[0])>2).$map$($lambda x: x$[1])$

rdd$1\_$c $=$ rdd$.$flatMap$($lambda x: $[($x$[0],$ i$)$ for i in x$[1]]).$filter$($lambda x: abs$($x$[0]-$ x$[1])>2).$map$($lambda x: $($x$[0],[$x$[1]])).$reduceByKey$($lambda x$,$ y: x $+$ y$).$flatMap$($lambda x: $[($x$[0],$ i$)$ for i in x$[1]])$

rdd$1\_$d $=$ rdd$.$map$($lambda x: $($x$,$ x$[0]-$ x$[1])).$filter$($lambda x: x$[1]>2).$map$($lambda x: x$[0])$

print$("$Option A Result:", rdd$1\_$a$.$collect$())$

print$("$Option B Result:", rdd$1\_$b$.$collect$())$

print$("$Option C Result:", rdd$1\_$c$.$collect$())$

print$("$Option D Result:", rdd$1\_$d$.$collect$())$

sc$.$stop$()$