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 suport for our Python Topology DSL.

Spouts

Spouts are data sources for topologies, they can read from any data source and emit tuples into streams.

Bolts

Logging

Topology DSL