Filter RDD Pyspark
kv_RDD.filter(lambda x: x[1] > 0) # keep only positive temperatures
Worried Wallaby
kv_RDD.filter(lambda x: x[1] > 0) # keep only positive temperatures