Implementing the Lambda Architecture with Spring XD
summary
Claims a runnable Lambda Architecture built with Spring XD, GemFireXD and HDFS and MapReduce that targets the ACM DABS smart‑grid challenge (40 houses, ~4 billion events). Pipeline: MQTT/RabbitMQ ingestion, Spring XD streams for the speed layer (duplicate removal, time‑slicing, three analytics: house and plug short‑term forecasts plus outlier detection), Hadoop MapReduce jobs launched by Spring XD for batch recomputation, and GemFireXD serving real‑time and batch views. Prototype runs on a laptop; cluster sizing and some integrations (in‑memory state, Redis access) remain work in progress.
AI-written summary · about
chapters (32)
- 0:00Intro
- 2:38What is Lambda Architecture?
- 3:29Approach is new, ideas not so...
- 4:42Why Lambda Architecture?
- 5:30Desired Properties of such systems
- 7:07How to support those properties?
- 8:19The Master dataset
- 10:28Master dataset requirements
- 13:02Desired properties on the Serving layer
- 13:50Serving layer database requirements
- 14:36Batch and serving layers
- 16:31Speed layer
- 19:03Incremental computation
- 19:43Eventual Accuracy
- 21:25One observation...
- 22:52Approximation & Randomisation
- 24:28Synopses structures
- 26:32Stream processing (real-time function)
- 28:18Generalised one-at-a-time approach
- 29:31Micro-batching
- 32:29Principles of Lambda Architecture
- 33:31Implementing the Lambda Architecture
- 34:53ACM DEBS 2014 Challenge Application
- 38:27Data model
- 39:51Analytical models
- 43:22How others did
- 47:46Implementation details
- 48:59Our approach - ACM DEBS 2014 system architecture
- 52:57Data ingestion
- 56:21Stream actions
- 57:07Spring XD streams
- 59:22Batch Layer
related talks
01h 20mSupercharging Operations and Analytics: Using Spring XD to Support Analytics and CEP
53mNoLambda: A new architecture combining streaming, ad hoc, machine...
48mLambda Architecture with Apache Spark
25mAccelerating Data Processing and Consumption for Building Modern Apps at the Edge
49mLambda Architecture for High Data Volume and Fast Business Response
30mSparkless Patterns: The New Data Stack and Modern Data Architecture
01h 14mHow to build Big Data Pipelines for Hadoop using OSS
45mModern Data Architecture
