Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. It allows parallel streams to be processed that can be grouped together in different ways.
Apache License 2.0
55
stars
20
forks
source link
Custom expire for the guava cache backing the windows #9
Currently, the expiration for windows that haven't been written to in a significant amount of time is 60 minutes. It would be useful if the user could set their own expiration on a per-stream basis for both the read expiration and the write expiration.
Currently, the expiration for windows that haven't been written to in a significant amount of time is 60 minutes. It would be useful if the user could set their own expiration on a per-stream basis for both the read expiration and the write expiration.