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
proc_flush is not called with waterslide-parallel #21
I noticed that flushes are not being forwarded to downstream kids when using waterslide-parallel. I don't notice the same problem with the serial waterslide executable. How do you suggest I resolve this issue?
Hi,
I noticed that flushes are not being forwarded to downstream kids when using waterslide-parallel. I don't notice the same problem with the serial waterslide executable. How do you suggest I resolve this issue?
Thanks!