I will look into separating the streams by severity then within the processing bolt filter out the ones I do not want. However I think a direct grouping/OutputCollector.emit or a CustomStreamGrouping would be more flexible.
On Apr 20, 2014, at 7:10 PM, Cody A. Ray <cody.a....@gmail.com> wrote: > I don't know anything about these custom/direct groupings but I do have an > alternative suggestion. What about doing a group-by severity, splitting the > stream into 5 parts (one for each level) and applying a filter to weed out > other levels in each stream? Then you can direct each stream/level wherever > you want. > > Just an idea. :) > > -Cody > > On Apr 19, 2014 9:56 PM, "David Novogrodsky" <david.novogrod...@gmail.com> > wrote: > All, > > Thank you for your help in the past. I appreciate it. > > I am writing a Storm application to process alerts from applications in > real-time. I need to not only sort the stream by severity, the field is > called “severity” and it can contain one of the following strings: Critical, > High, Medium, Low or Debug. > > I need to send streams with critical severity to a specific Bolt. I call > this bolt CriticalSeverityBolt. It looks like I will use with a > DirectGrouping in the topology or create a custom stream grouping using the > CustomStreamGrouping. I am not sure which is the best way. Does anyone have > examples of either solution? > > David Novogrodsky > david.novogrod...@gmail.com > http://www.linkedin.com/in/davidnovogrodsky > > > > David Novogrodsky david.novogrod...@gmail.com http://www.linkedin.com/in/davidnovogrodsky
