Pyspark Reduce By Example Sentence