pyspark.streaming.DStream.glom¶

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

pyspark.streaming.DStream.fullOuterJoin pyspark.streaming.DStream.groupByKey