You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Jayant Ameta <wi...@gmail.com> on 2018/07/10 11:26:00 UTC

State sharing across trigger and evictor

Hi,
I'm using the GlobalWindow with a custom CountTrigger (similar to the
CountTrigger provided by flink).
I'm also using an evictor to remove some of the elements from the window.
Is it possible to update the count when an element is evicted? For example:
can I access the ReducingState used by the countTrigger from my Evictor
class, so that the count always reflects the number of elements in the
windows?

Jayant Ameta

Re: State sharing across trigger and evictor

Posted by vino yang <ya...@gmail.com>.

Hi Jayant,

As Fabian said, Evictor can not access flink state. But if you really has
your own requirement. You can try to customize a special trigger (with
evictor function), may be that could match your requirement.

Thanks.
vino.

2018-07-16 17:17 GMT+08:00 Fabian Hueske <fh...@gmail.com>:

> Hi,
>
> I don't think that is possible.
> The Evictor interface does not provide access to a state store, so there
> is no way to access state.
>
> Best, Fabian
>
> 2018-07-10 13:26 GMT+02:00 Jayant Ameta <wi...@gmail.com>:
>
>> Hi,
>> I'm using the GlobalWindow with a custom CountTrigger (similar to the
>> CountTrigger provided by flink).
>> I'm also using an evictor to remove some of the elements from the window.
>> Is it possible to update the count when an element is evicted? For example:
>> can I access the ReducingState used by the countTrigger from my Evictor
>> class, so that the count always reflects the number of elements in the
>> windows?
>>
>> Jayant Ameta
>>
>
>

Re: State sharing across trigger and evictor

Posted by Fabian Hueske <fh...@gmail.com>.

Hi,

I don't think that is possible.
The Evictor interface does not provide access to a state store, so there is
no way to access state.

Best, Fabian

2018-07-10 13:26 GMT+02:00 Jayant Ameta <wi...@gmail.com>:

> Hi,
> I'm using the GlobalWindow with a custom CountTrigger (similar to the
> CountTrigger provided by flink).
> I'm also using an evictor to remove some of the elements from the window.
> Is it possible to update the count when an element is evicted? For example:
> can I access the ReducingState used by the countTrigger from my Evictor
> class, so that the count always reflects the number of elements in the
> windows?
>
> Jayant Ameta
>