pyspark.streaming.DStream.fullOuterJoin

DStream.fullOuterJoin(other, numPartitions=None)

Return a new DStream by applying ‘full outer join’ between RDDs of this DStream and other DStream.

Hash partitioning is used to generate the RDDs with numPartitions partitions.

pyspark.streaming.DStream.foreachRDD pyspark.streaming.DStream.glom