pyspark.streaming.DStream.rightOuterJoin

DStream.rightOuterJoin(other, numPartitions=None)[source]

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

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

previous

pyspark.streaming.DStream.repartition

next

pyspark.streaming.DStream.slice