pyspark.streaming.DStream.glom

DStream.glom() → pyspark.streaming.dstream.DStream[List[T]]

Return a new DStream in which RDD is generated by applying glom() to RDD of this DStream.

previous

pyspark.streaming.DStream.fullOuterJoin

next

pyspark.streaming.DStream.groupByKey