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
feature adds for expiration on groupevents and keyadd, added noop and timestamp kids, depricated print2json #37
bugfix for keyadd - output uint64 instead of truncated uint32
added optional gradual flush for groupevents
added gradual expiration to keyadd - triggered by EXPIRE port
added new kids:
noop - as a passthrough placeholder used in complex graphs
timestamp - to add a current timestamp to a tuple
bugfix for keyadd - output uint64 instead of truncated uint32 added optional gradual flush for groupevents added gradual expiration to keyadd - triggered by EXPIRE port added new kids: noop - as a passthrough placeholder used in complex graphs timestamp - to add a current timestamp to a tuple