API¶
Tuples¶
You should never have to instantiate an instance of a
streamparse.Tuple
yourself as streamparse handles this for you
prior to, for example, a streamparse.Bolt
’s process()
method
being called.
None of the emit methods for bolts or spouts require that you pass a
streamparse.Tuple
instance.
Components¶
Both streamparse.Bolt
and streamparse.Spout
inherit from a
common base-class, streamparse.storm.component.Component
. It extends
pystorm’s code for handling Multi-Lang IPC between Storm and Python
and adds support for our Python Topology DSL.
Spouts¶
Spouts are data sources for topologies, they can read from any data source and emit tuples into streams.