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>
