A stream transformer for creating windowed streams based on time from a stream