a  light, scalable and fault-tolerant stream processing framework