CODE EXAMPLE FOR PYTHON

pyspark rdd filter

kv_RDD.filter(lambda x: x[1] > 0)  # keep only positive temperatures