Hi Nishi,
I will point to you some resources that solve similar problems:
1. Book: Storm Real-time processing Cookbook <http://amzn.to/OEaK5N> has
chapter "Rule-based analysis of the log stream". This recipe integrates the
JBoss Library and Drools into a bolt and allow to capture event based on
rule. Next you need sliding window analysis to see if your events frequency
exceed some threshold. The same book has chapter how to implement "rolling
window topology" or better yet,
2. brand new book "Storm Blueprints <http://goo.gl/tuyY65>" explain how to
do sliding windows and alerting using Trident ( which I prefer over plain
storm semantics). Using those 2 resources it should be easy to craft
solution for your use case.
good luck



On Thu, Apr 24, 2014 at 3:36 AM, Nishu <nishuta...@gmail.com> wrote:

> Hi,
>
> I am using Storm with Drools Fusion for adding CEP rules to raise system
> alerts . I need to raise alerts for system if condition is matched for last
> 10 records or 10 minutes.
>  Bolt is receiving one event in tuple from Spout. How can I make it work
> where bolt can read multiple events(lets say 10 events or last 10 minute
> events) and how to call CEP rules on those event to raise an alert?
>
> I checked following thread also :
> https://groups.google.com/forum/#!topic/storm-user/VqBPnheDtQ8
>
> --
> Thanks,
> Nishu Tayal
>
>


-- 
Eugene Dvorkin
Software Engineer
New York City Storm User Group - organizer
WebMD
email: edvor...@gmail.com
phone: 646-250-9649
eugenedvorkin.com
Connect with me on:
LinkedIn <http://www.linkedin.com/in/eugenedvorkin>
Twitter<http://twitter.com/edvorkin>

Reply via email to