A Java concurrent API to asynchronously execute related tasks sequentially, and unrelated tasks concurrently.

core fluxtion static event processor generator tool and runtime components

Esper Complex Event Processing, Streaming SQL and Event Series Analysis

opensource distributed database with base JPA implementation and event processing support

API for Complex Event Processing using Spring Boot, Esper & a Mosquitto MQTT Broker

Real time data processing system based on flink and CEP

Stream Processing and Complex Event Processing Engine

Simple demo of some features of the Esper Complex Event Processing (CEP) engine.

Complex Event Processing on top of Kafka Streams

A universal Java communication framework supporting event, state and component handling, incl. pattern-matching

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Transpiler to compile from SQL to SiddhiQL

An adaptive and self-boosting stream processor

Event processing of client's location on a retail place using Esper

Sistema para monitoramento de animais domésticos. As aplicações foram desenvolvidas utilizando a linguagem de programação Java. Para processar o fluxo de dados de localização, utilizou-se Processamento de Eventos Complexos (CEP) por meio do motor de inferência Esper. Para o compartilhamento dos dados de contexto foi utilizadoo protocolo MQTT com…

Files/projects/scripts used for paper presented in SBES 2019

Mobile node code to run with Deklear

Deklaer is an Ontology-Driven framework to facilitate the development and deployment of IoT applications.