Re: What's the best way to clean up the expired rocksdb state

2018-03-13 Thread Chesnay Schepler
Hello, yes, i think you'll need to use a ProcessFunction and clean up the state manually. On 11.03.2018 15:13, sundy wrote: hi: my streaming application always do Key by the some keys with event timestamp, such as keyBy( “qps_1520777430”), so the expired keys(1 hours ago) are useless.

What's the best way to clean up the expired rocksdb state

2018-03-11 Thread sundy
hi: my streaming application always do Key by the some keys with event timestamp, such as keyBy( “qps_1520777430”), so the expired keys(1 hours ago) are useless. And I use rocksdb to store the state, I want to know What's the best way to clean up the expired rocksdb state, should I must