pyspark.streaming.DStream.updateStateByKey¶
-
DStream。updateStateByKey( updateFunc:可調用的((Iterable(V],可選(年代]],年代],numPartitions:可選(int]=沒有一個,initialRDD:(pyspark.rdd聯盟。抽樣(元組(K S]], Iterable(元組[K S]],沒有)=沒有一個 )→pyspark.streaming.dstream.DStream(元組(K,年代] ] ¶ -
返回一個新的“狀態”DStream政府為每個關鍵更新通過給定的函數前的狀態和新價值觀的關鍵的關鍵。
- 參數
-
- updateFunc 函數
-
狀態更新功能。如果這個函數返回沒有,那麼相應的鍵-值對將被消除。