DStream.
map
Return a new DStream by applying a function to each element of DStream.
previous
pyspark.streaming.DStream.leftOuterJoin
next
pyspark.streaming.DStream.mapPartitions