List of Listings

Chapter 2. Getting data from clients: data ingestion

Listing 2.1. Example JSON stream event

Chapter 8. Consumer device capabilities and limitations accessing the data

Listing 8.1. Server-Sent Events

Listing 8.2. HTTP Long Polling

Listing 8.3. WebSockets

Chapter 9. Analyzing Meetup RSVPs in real time

Listing 9.1. Initializing HybridMessageLogger

Listing 9.2. Creating WebSocket handler and connecting to Meetup API

Listing 9.3. Construction of MeetupWebSocketClientHandler and RSVPProducer

Listing 9.4. Construction of RSVPProducer

Listing 9.5. Adding the handler to the Netty pipeline

Listing 9.6. Connecting to Meetup API

Listing 9.7. Message handling in MeetupWebSocketClientHandler

Listing 9.8. HybridMessageLogger addEvent call

Listing 9.9. RSVPProducer send method

Listing 9.10. TopicCallbackHandler

Listing 9.11. Downloading and installing Apache Kafka

Listing 9.12. Starting Kafka, Apache ZooKeeper, and creating a topic

Listing 9.13. Kafka list topics command

Listing 9.14. Running the Kafka console consumer

Listing 9.15. Building and running the collection service

Figure 9.3. Example Meetup RSVP JSON message

Listing 9.16. RSVP Message JSON

Listing 9.17. Installing Apache Storm

Listing 9.18. Setting up Kafka for Analysis topic

Listing 9.19. Setup of topology

Listing 9.20. getKafkaSpoutConfig

Listing 9.21. getKafkaConsumerProps

Listing 9.22. getKafkaSpoutStreams

Listing 9.23. getTuplesBuilder

Listing 9.24. TopicTupleBuilder

Listing 9.25. getRetryService

Listing 9.26. MeetupRSVPSummaryBolt