Re: Incremental state with purging

Posted by Thomas Huang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Incremental-state-with-purging-tp35090p35232.html

I’m wondering that why you use a beta feature for production. Why not push the latest state into down sink like redis or hbase with Apache phoenix .

---

From: Annemarie Burger <[hidden email]>
Sent: Monday, May 18, 2020 11:19:23 PM
To: [hidden email] <[hidden email]>
Subject: Re: Incremental state with purging

 

Hi,

Thanks for your suggestions!
However, as I'm reading the docs for queryable state, it says that it can
only be used for Processing time, and my windows are defined using event
time. So, I guess this means I should use the KeyedProcessFunction. Could
you maybe suggest a rough implementation for this? I can't seem to get the
implementation working right.

Best,
Annemarie



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/