@check_input_stream_count(1)
    def _execute(self, sources, alignment_stream, interval):
        for (time,_) in sources[0].window(interval, force_calculation=True):
            yield StreamInstance(time,TimeInterval(time+self.lower,time+self.upper))