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
kafka fixes, tuple2json new module, removed .wsalias from git #28
made several kafka fixes to improve error reporting, flushing and record annotation.
added a tuple2json module for use in serializing tuples to a json string buffer for kafka, redis or other output.
Removed .wsalias from repository tracking - as it gets automatically built from the make process.
made several kafka fixes to improve error reporting, flushing and record annotation. added a tuple2json module for use in serializing tuples to a json string buffer for kafka, redis or other output. Removed .wsalias from repository tracking - as it gets automatically built from the make process.