Databases Reference
In-Depth Information
cases, using the
backtype.storm.drpc.DRPCSpout
will be enough, but it's possible to
create your own implementation using the DRPC classes included with the Storm
package.
Conclusion
You've seen the common spout implementation patterns, their advantages, and how
to make the messages reliable. It's important to define spout communication based on
the problem that you are working on. There is no one architecture that fits all topolo-
gies. If you know the sources or you can control these sources, then you can use a direct
connection, while if you need the capacity to add unknown sources or receive messages
from variety sources, it's better to use a queued connection. If you need an online
process, you will need to use DRPCSpouts or implement something similar.
Although you have learned the three main types of connections, there are infinite ways
to do it depending on your needs.
