Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. It allows parallel streams to be processed that can be grouped together in different ways.
Apache License 2.0
55
stars
20
forks
source link
FlomwmixFactory should have a method to take a bolt for loading events #24
Flowmix has always assumed that the spout itself can serve up collections of events directly. So in order to make something like a JMS spout return Collection, it needs to be extended and the nextTuple() method overridden. This doesn't allow as much reusability as, say, a bolt after the spout that converts the contents of the tuples from the spout into a Collection
Flowmix has always assumed that the spout itself can serve up collections of events directly. So in order to make something like a JMS spout return Collection, it needs to be extended and the nextTuple() method overridden. This doesn't allow as much reusability as, say, a bolt after the spout that converts the contents of the tuples from the spout into a Collection