pyspark.streaming.DStream.foreachRDD

DStream。 foreachRDD ( 函數:聯盟[可調用的[[pyspark.rdd。抽樣[T]], [[datetime),沒有一個可調用的。datetime, pyspark.rdd。抽樣[T]],沒有]] )→沒有

一個函數應用於每個DStream抽樣。

以前的

pyspark.streaming.DStream.flatMapValues

下一個

pyspark.streaming.DStream.fullOuterJoin