I'd like to have "sub-topologies" within my topology. That is, a Bolt that
also be a Spout. Or Spout that can also receive input via Execute(). Is this
possible?
For example, I'd like to send a tuple from Spout A, to Bolt B, to Bolt C. Bolt
C should also be a spout — it can store the tuple from Bolt B and emit a new
tuple to C[A] and C[B]. Once it's own DAG is complete (C[A], C[B], etc), it
can proceed to ack/fail the original tuple so that Spout A gets a response.
Spout A --> B --> Spout C --> D
/ \
C[A] C[B]
Thanks,
-Sam
