A data stream management system that aims to realize the concept of "data stream processing with concurrency control"