AMQP - Spark Streaming
real time "temperature" analysis
What does it do?
- An AMQP producer sends "temperature" data to a queue
- A Spark driver gets this data through AMQP
- Max temperature value in the last 5 seconds is shown
Temperature demo scenario