pyspark.streaming.DStream.slice

DStream.slice(begin: Union[datetime.datetime, int], end: Union[datetime.datetime, int]) → List[pyspark.rdd.RDD[T]]

Return all the RDDs between ‘begin’ to ‘end’ (both included)

begin, end could be datetime.datetime() or unix_timestamp

previous

pyspark.streaming.DStream.rightOuterJoin

next

pyspark.streaming.DStream.transform