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