Nice write up, one question though my understanding of keyed stream is that it will fork n number of streams from one stream based on n keys, if that is true it can be pictorially depicted as well and the apply function will can be shown to operate over the time period by clearly marking a time line.