pyspark.streaming.DStream.slice

DStream.slice(begin, end)

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

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

pyspark.streaming.DStream.rightOuterJoin pyspark.streaming.DStream.transform