A data stream management system that aims to realize the concept of "data stream processing with concurrency control" - View it on GitHub