pyspark.streaming.DStream.map

DStream。 地圖 ( f:可調用的((T],U],preservesPartitioning:bool=假 )→pyspark.streaming.dstream.DStream(U]

通過應用一個函數返回一個新的DStream DStream的每個元素。

以前的

pyspark.streaming.DStream.leftOuterJoin

下一個

pyspark.streaming.DStream.mapPartitions