Reduce Method In Pyspark