Hi All, I read through the doc below and I am wondering if I can clean up the state based on custom logic rather min and max retention time?
For example, I want to say clean up all the state where the key = foo or say the value = bar. so until the keys reach a particular value just keep accumulating(retain) and when it does reach a particular value then write to some sink and clean up! I am looking for something along those lines. please let me know. Thanks https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html
