pyspark.streaming.DStream.slice

DStream。 片 ( 開始:聯盟(datetime.datetime,int],結束:聯盟(datetime.datetime,int] )→列表(pyspark.rdd.RDD(T] ]

返回所有的抽樣之間的“開始”“結束”(包括兩個)

開始,結束可能是datetime.datetime()或unix_timestamp嗎

以前的

pyspark.streaming.DStream.rightOuterJoin

下一個

pyspark.streaming.DStream.transform