I've been looking at the trident code. If the following code is run on the same bolt:
TridentStream input = ... TridentStream firstSection = input.each(new Fields(...), new FirstFilter()); TridentStream secondSection = input.each(new Fields(...), new SecondFilter()); >From looking at FreshCollector and AppendCollector, it looks like the two >filters will be run sequentially. Are there plans/thoughts on involving >threading when a stream splits like this? Running each split on a new thread >in parallel? There may be some complications when joining streams together, >but that's a simple solution that a couple of locks on the >MultiReducerProcessor would solve. Has this been considered before? SimonC
