WaterSlide is a streaming event-at-a-time architecture for processing metadata. It is designed to take in a set of streaming events from multiple sources, process them through a set of modules ("kids"), and return meaningful outputs.
Other
113
stars
40
forks
source link
Added processor: persist - detect repeated occurrences across time windows #50
created persist processor to detect repeated occurrences across time windows. Emits output when N of M time windows have been observed for a given key.
created persist processor to detect repeated occurrences across time windows. Emits output when N of M time windows have been observed for a given key.