pyspark.streaming.DStream.slice

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

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

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