pyspark.streaming.DStream.flatMap

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

通過應用一個函數返回一個新的DStream DStream的所有元素,然後壓扁的結果

以前的

pyspark.streaming.DStream.filter

下一個

pyspark.streaming.DStream.flatMapValues