[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

How to clear keyed states periodically?


I’m using MapState to deduplicate some ids and the MapState needs to be truncated periodically. I tried to use ProcessingTimeCallback to call state.clear(), but in this way I can only clear the state for one key, and actually I need a key group level cleanup. So I’m wondering is there any best practice for my case? Thanks a lot!

Paul Lam