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
More abstract AbstractAggregator, *Aggregator are now using Abstract, tests and some ideas #46
I changed the Abstract Aggregator to a more abstract one, maybe is something to discuss so please check it, every Aggregator is adapted to the Abstract one, test where done, and some extra optional things:
AbstractGrouplessAggregator: without the group burden, I'm going to JMeter this to compare
FunctionAggregator: maybe useless, but you could have a set of functions and use at will with this
JavascriptFunctionAggregator: I saw some CEP implementations where they use javascript for functions, maybe this is not the best approach nor the place to do it but it was fun anyways
Deprecated LongSumAggregator, why the Long prefix? because of the Type?
Hi!
I changed the Abstract Aggregator to a more abstract one, maybe is something to discuss so please check it, every Aggregator is adapted to the Abstract one, test where done, and some extra optional things:
Deprecated LongSumAggregator, why the Long prefix? because of the Type?
Best regards!