Can trigger fire early brefore specific element get into ProcessingTimeSessionWindow

[Utopia]

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

[vino yang]

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 <[hidden email]> 于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