pyspark.streaming.StreamingContext.queueStream¶
-
StreamingContext。queueStream( 抽樣:列表(pyspark.rdd.RDD(T]],oneAtATime:bool=真正的,默認的:可選(pyspark.rdd.RDD(T]]=沒有一個 )→pyspark.streaming.dstream.DStream(T] ¶ -
從一個隊列創建一個輸入流抽樣或列表。在每一批,它將處理一個或所有的抽樣返回的隊列。
- 參數
-
- 抽樣 列表
-
隊列的抽樣
- oneAtATime bool,可選
-
每次選擇一個抽樣或選擇他們所有人。
-
默認的
pyspark.RDD、可選 -
默認的抽樣如果沒有抽樣
筆記
更改後的隊列創建流將不會認可。