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
Join operator should perform all possible joins #35
Currently, the Join operator only performs an inner join and passes all joined Events down the same output stream. All of the possible inner/outer join combinations should be implemented.
Further, the join operator does not use a supplied predicate to determine the nature of the join. This needs to be added as well.
Currently, the Join operator only performs an inner join and passes all joined Events down the same output stream. All of the possible inner/outer join combinations should be implemented.
Further, the join operator does not use a supplied predicate to determine the nature of the join. This needs to be added as well.