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
The TickSpout is only emitting ticks in nextTuple() which means it's very likely the ticks could get out of sync. #37
A better option would be to have a TimerTask running that is emitting tuples directly instead of using nextTuple(). This would guarantee tick tuples are always prioritized. It's possible it could cause issues in cases where there is significant back-pressure... but we'll need to verify this through some stress tests.
A better option would be to have a TimerTask running that is emitting tuples directly instead of using nextTuple(). This would guarantee tick tuples are always prioritized. It's possible it could cause issues in cases where there is significant back-pressure... but we'll need to verify this through some stress tests.