Hello, I have a question regarding windowing and triggering. I am trying to connect the dots between the simple windowing api e.g.
stream.countWindow(1000, 100) to the underlying representation using triggers and evictors api: stream.window(GlobalWindows.create()) .evictor(CountEvictor.of(1000)) .trigger(CountTrigger.of(100)) how is the above equivalent to the semantics of a window of window length to be 1000 tuples and the sliding interval to be 100 tuples? And for time duration windows: stream.timeWindow(Time.seconds(5), Time.seconds(1)) which maps to: stream.window(SlidingProcessingTimeWindows.of(Time.seconds(5), Time.seconds(1))) .trigger(ProcessingTimeTrigger.create()) why isn't it mapped to something like: stream.window(SlidingProcessingTimeWindows.create()) .trigger(ProccessingTimeTrigger.of(1)) .evictor(TimeEvictor.of(5)) ? Thanks for any help in advance! Best, Jerry
