I was able to use the AbstractStreamOperatorTestHarness to write more of a unit test for windowing operators. However, I'm still trying to figure out a way to have a "delayed iterator". I tried implementing an iterator that Thread.sleeps for the interval and passed it to the stream as an input, but that didn't seem to work, plus I was having issues with serialization if I enabled checkpointing which seemed like a hassle.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
