waterslideLTS / waterslide

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

BUGFIX: groupevents: expiration, collusion detection #45

Closed Karl-MS closed 4 years ago

Karl-MS commented 4 years ago

groupevents bug fixes:

  1. Expiration- added forced table-walk expiration when gradual expiraiton does not complete between the next expiration trigger
    1. added key collision detection to increase fidelity of results on massive datasets