pyspark.streaming.DStream.glom

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

返回一個新的DStream抽樣生成通過應用搶DStream()來抽樣。

以前的

pyspark.streaming.DStream.fullOuterJoin

下一個

pyspark.streaming.DStream.groupByKey