Demonstrates realtime stream processing with the Storm framework.
This tutorial shows a simple financial application:
- The data source ("spout" in Storm parlance) is a price feed with live price data for a set of financial instruments.
- The data is consumed by candlestick chart generators sampling it and collecting min/max and open/close data.
The tutorial demonstrates:
- Spouts, the data sources.
- Bolts, the functions to consume and transform data.
- Topology, setting up the data stream flow.
- How to add custom serialization formats for new data types.
Copyright (C) 2011 Martin Jul (www.mjul.com)
Distributed under the MIT License. See the LICENSE file for details.
Martin Jul is a software architect and partner in Ative, a Copenhagen-based consultancy specialized in doing and teaching lean software development.
His work is currently focused on building distributed, high-performance low-latency financial trading applications.
He is also organizing of the Copenhagen Clojure meet-ups:
- Twitter: @mjul
- Work: Ative
- Blog: Ative at Work
- Copenhagen Clojure Meet-Up dates here