pyspark.streaming.DStream.glom

DStream。 偷 ( )→pyspark.streaming.dstream.DStream(列表(T] ]

返回一个新的DStream抽样生成通过应用抢DStream()来抽样。

以前的

pyspark.streaming.DStream.fullOuterJoin

下一个

pyspark.streaming.DStream.groupByKey