pyspark.streaming.DStream.glom# DStream.glom()[source]# Return a new DStream in which RDD is generated by applying glom() to RDD of this DStream.