2019, Schaaf, Marc

This paper presents the central concepts for a microservices-based distribution of event stream processing pipelines as they are part of our situation-aware event stream processing system. For this, we outline changes to our specification language for a clear separation of the stream processing specification from the actual stream processing engine. Based on this separation, we then discuss our mapping approach for the assignment of the pipelines to stream processing nodes.

2018, Schaaf, Marc

This paper presents the central aspects of a service based architecture for a distributed event stream processing system with an emphasis on its components, as well as related scalability and flexibility considerations. The processing system architecture is designed based on a well-defined situation-aware adaptive event stream processing model and a matching scenario definition language, which allow the definition of such processing scenarios in a processing system independent way.