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 于2019年12月19日周四 下午5:56写道：
> Hi,
>
> I want to f
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
