A simple distributed stream-processing system implementation for learning purpose.