Richard Deurwaarder

icon indicating a website link https://www.linkedin.com/in/richard-deurwaarder

icon location Netherlands icon location Interested in Data: Machine learning, Data engineering, Data visualisation. But also playing around with Raspberry PI

Results 1 issues of Richard Deurwaarder

Run pipeline without flushing all the windows

2 comment

I have a test similar like this one: ``` @Test public void should_not_fire_window_yet() { DataStream testStream = createTimedTestStreamWith("message1") .emit("message2") .close() .timeWindowAll(Time.days(1)) .reduce((a, b) -> a + b); assertStream(testStream, emptyIterableOf(String.class)); }```...