nathanmarz/storm — Issue #73: Generalize LinearDRPCTopologyBuilder for making DRPC sub-topologies
Author: nathanmarz
Created: 2011-12-14 09:05:02+00:00
State: open
Labels: Improvement

Besides being able to add a sub-topology, it would need to be able to start midway through and coordinate only on certain streams. It would look like this:

DRPCSpout -> PrepareRequest -> your current bolt -> rest of sub topology constructed by LinearDRPCTopologyBuilder ...

It can use input groupings of downstream bolts to know which streams to coordinate on. CoordinatedBolt will need to be generalized to ignore streams other than the ones it's coordinating on.