Hi Utopia, Flink provides a high scalability window mechanism.[1]
For your scene, you can customize your window assigner and trigger. [1]: https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/windows.html Best, Vino Utopia <gejunwei...@gmail.com> 于2019年12月19日周四 下午5:56写道： > Hi, > > I want to fire and evaluate the ProcessingTimeSessionWindow when a > specific element come into current window. But I want to exclude the > specific element when processing window function and remaining it for the > next evaluation. > > Thanks > > Best regards > Utopia >
