pyspark.streaming.DStream.transform

DStream。 变换 ( 函数:联盟(可调用的((pyspark.rdd.RDD(T]],pyspark.rdd.RDD(U]],可调用的((datetime.datetime,pyspark.rdd.RDD(T]],pyspark.rdd.RDD(U]]] )→pyspark.streaming.dstream.TransformedDStream(U]

返回一个新的DStream每个抽样生成通过应用一个函数在每个抽样DStream。

函数可以有一个论点的抽样,或者有两个参数(时间,抽样)

以前的

pyspark.streaming.DStream.slice

下一个

pyspark.streaming.DStream.transformWith