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" <[email protected]> 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 > [email protected] > http://www.linkedin.com/in/davidnovogrodsky > > > > >
