List of Listings

 

Chapter 2. Core Storm concepts

Listing 2.1. Sample commit data for the GitHub commit feed

Listing 2.2. pom.xml

Listing 2.3. An excerpt from our simple data source: changelog.txt

Listing 2.4. CommitFeedListener.java

Listing 2.5. EmailExtractor.java

Listing 2.6. EmailCounter.java

Listing 2.7. LocalTopologyRunner.java

Chapter 3. Topology design

Listing 3.1. An excerpt from our simple data source, checkins.txt

Listing 3.2. Checkins.java

Listing 3.3. GeocodeLookup.java

Listing 3.4. HeatMapBuilder.java: step 1, collecting incoming tuples into an in-memory map

Listing 3.5. HeatMapBuilder.java: step 2, configuring to receive a signal at a given frequency

Listing 3.6. HeatMapBuilder.java: step 3, emitting the aggregated HeatMap for elapsed time intervals

Listing 3.7. Persistor.java

Listing 3.8. HeatmapTopologyBuilder.java

Listing 3.9. LocalTopologyRunner.java

Listing 3.10. Determining time interval for a tuple in HeatMapBuilder.java

Listing 3.11. TimeIntervalExtractor.java

Listing 3.12. Updating execute() in HeatMapBuilder.java to use the precalculated time interval

Listing 3.13. New bolt added to HeatmapTopologyBuilder.java

Listing 3.14. Adding city as a field in the output tuple of GeocodeLookup.java

Listing 3.15. Pass city field along in TimeIntervalExtractor.java

Listing 3.16. Added second-level grouping to HeatmapTopologyBuilder.java

Chapter 4. Creating robust topologies

Listing 4.1. Order JSON

Listing 4.2. Order.java

Listing 4.3. AuthorizeCreditCard.java