Sparkstreaming after processing the data warehousing, how to obtain the data which is based on time window (starting time and ending time) information,