Apache Flink - Evictor interface clarification

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Apache Flink - Evictor interface clarification

M Singh
Hi:

I am looking at the documentation and it states:

'The evictor has the ability to remove elements from a window after the trigger fires and before and/or after the window function is applied. '

I understand that if we use evictor's before method (evictBefore) it can remove items before invocation of the window computation.  But I am not sure what is the use of the evictor's after method (evictAfter) ?  

Please let me know where I can find information about what are the use cases for evictor's after method (evictorAfter).

Thanks

Mans
Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink - Evictor interface clarification

vishnuviswanath
Hi Mans,


Thanks,

On Sat, Nov 18, 2017 at 11:28 AM, M Singh <[hidden email]> wrote:
Hi:

I am looking at the documentation and it states:

'The evictor has the ability to remove elements from a window after the trigger fires and before and/or after the window function is applied. '

I understand that if we use evictor's before method (evictBefore) it can remove items before invocation of the window computation.  But I am not sure what is the use of the evictor's after method (evictAfter) ?  

Please let me know where I can find information about what are the use cases for evictor's after method (evictorAfter).

Thanks

Mans

Reply | Threaded
Open this post in threaded view
|

Re: Apache Flink - Evictor interface clarification

M Singh
Thanks Vishu for the pointer.


On Saturday, November 18, 2017 6:27 PM, Vishnu Viswanath <[hidden email]> wrote:


Hi Mans,


Thanks,

On Sat, Nov 18, 2017 at 11:28 AM, M Singh <[hidden email]> wrote:
Hi:

I am looking at the documentation and it states:

'The evictor has the ability to remove elements from a window after the trigger fires and before and/or after the window function is applied. '

I understand that if we use evictor's before method (evictBefore) it can remove items before invocation of the window computation.  But I am not sure what is the use of the evictor's after method (evictAfter) ?  

Please let me know where I can find information about what are the use cases for evictor's after method (evictorAfter).

Thanks

Mans