Skip to content

Commit 31f2956

Browse files
committed
Fix left outer join documentation comments.
1 parent 0d1cc4a commit 31f2956

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

python/pyspark/rdd.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1402,7 +1402,7 @@ def leftOuterJoin(self, other, numPartitions=None):
14021402
14031403
For each element (k, v) in C{self}, the resulting RDD will either
14041404
contain all pairs (k, (v, w)) for w in C{other}, or the pair
1405-
(k, (v, None)) if no elements in other have key k.
1405+
(k, (v, None)) if no elements in C{other} have key k.
14061406
14071407
Hash-partitions the resulting RDD into the given number of partitions.
14081408

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -606,8 +606,9 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])(
606606
}
607607

608608
/**
609-
* Return a new DStream by applying 'join' between RDDs of `this` DStream and `other` DStream.
610-
* The supplied org.apache.spark.Partitioner is used to control the partitioning of each RDD.
609+
* Return a new DStream by applying 'left outer join' between RDDs of `this` DStream and
610+
* `other` DStream. The supplied org.apache.spark.Partitioner is used to control
611+
* the partitioning of each RDD.
611612
*/
612613
def leftOuterJoin[W](
613614
other: JavaPairDStream[K, W],

0 commit comments

Comments
 (0)