DStream.
leftOuterJoin
(
other
:
pyspark.streaming.dstream.DStream
[
Tuple
[
K
,
U
]
]
,
numPartitions
:
Optional
[
int
]
=
None
)
→ pyspark.streaming.dstream.DStream
[
Tuple
[
K
,
Tuple
[
V
,
Optional
[
U
]
]
]
]
[source]
¶
返回一个新的DStream，通过对此DStream和 other DStream的RDD应用“左外连接”来生成。
哈希分区用于生成具有 numPartitions 分区的RDD。