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、可选 -
默认的抽样如果没有抽样
笔记
更改后的队列创建流将不会认可。