v12technology/fluxtion

core fluxtion static event processor generator tool and runtime components

Language: Java - Size: 38.9 MB - Last synced: about 16 hours ago - Pushed: 1 day ago - Stars: 77 - Forks: 8

slgobinath/wisdom

An adaptive and self-boosting stream processor

Language: Java - Size: 1.67 MB - Last synced: 14 days ago - Pushed: over 1 year ago - Stars: 4 - Forks: 2

Purii/hdm-wim-fallstudie-cep

Bei diesem Projekt handelt es sich um ein Forschungsprojekt der Hochschule der Medien, Stuttgart.

Language: Java - Size: 2.44 MB - Last synced: 14 days ago - Pushed: over 7 years ago - Stars: 3 - Forks: 0

GridProtectionAlliance/openPDC

Open Source Phasor Data Concentrator

Language: C# - Size: 2.21 GB - Last synced: 9 days ago - Pushed: 22 days ago - Stars: 125 - Forks: 59

siddhi-io/siddhi

Stream Processing and Complex Event Processing Engine

Language: Java - Size: 33.5 MB - Last synced: 14 days ago - Pushed: 2 months ago - Stars: 1,500 - Forks: 522

GridProtectionAlliance/gsf

Grid Solutions Framework

Language: C# - Size: 247 MB - Last synced: about 9 hours ago - Pushed: 11 days ago - Stars: 160 - Forks: 68

espertechinc/esper

Esper Complex Event Processing, Streaming SQL and Event Series Analysis

Language: Java - Size: 45.6 MB - Last synced: 24 days ago - Pushed: 24 days ago - Stars: 820 - Forks: 256

aartikis/RTEC

RTEC is an Event Calculus implementation optimised for stream reasoning

Language: Prolog - Size: 13 MB - Last synced: 2 months ago - Pushed: 2 months ago - Stars: 78 - Forks: 15

GiilDe/OpenCEP

Initial implementation of an open source complex event processing library

Language: Python - Size: 5.2 MB - Last synced: 28 days ago - Pushed: over 3 years ago - Stars: 1 - Forks: 0

GiilDe/CEPDeepOptimization

Language: Python - Size: 1.15 MB - Last synced: 28 days ago - Pushed: almost 4 years ago - Stars: 0 - Forks: 0

elastest/elastest-monitoring-service

This is the repository of the ElasTest Monitoring Service, which provides a monitoring infrastructure suitable for inspecting executions of a SuT (System under Test) and the ElasTest platform itself online.

Language: Go - Size: 8.83 MB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 4 - Forks: 10

fhussonnois/kafkastreams-cep

Complex Event Processing on top of Kafka Streams

Language: Java - Size: 434 KB - Last synced: 8 days ago - Pushed: 5 months ago - Stars: 304 - Forks: 64

Hurence/logisland

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.

Language: Java - Size: 120 MB - Last synced: 15 days ago - Pushed: 7 months ago - Stars: 108 - Forks: 29

mbrazalez/EsperAPI

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

Language: Java - Size: 108 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0

kaskada-ai/kaskada

Modern, open-source event-processing

Language: Rust - Size: 111 MB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 338 - Forks: 15

r3w0p/bobocep

A fault-tolerant Complex Event Processing engine designed for edge computing in Internet of Things systems.

Language: Python - Size: 1.94 MB - Last synced: 13 days ago - Pushed: 4 months ago - Stars: 13 - Forks: 4

aksakalli/EsperIoT

Small and simple stream-based CEP tool for IoT devices connected to an MQTT broker

Language: Java - Size: 108 KB - Last synced: 30 days ago - Pushed: over 4 years ago - Stars: 18 - Forks: 5

luxiaoxun/eagle

Real time data processing system based on flink and CEP

Language: Java - Size: 400 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 241 - Forks: 126

TIBCOSoftware/be-tools

Collection of tools to work with TIBCO BusinessEvents

Language: Shell - Size: 1.81 MB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 8 - Forks: 4

wso2/product-sp

An open source, cloud-native streaming data integration and analytics product optimized for agile digital businesses

Language: Python - Size: 121 MB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 118 - Forks: 132

Clover-Group/tsp

Complex event processing engine for time series data

Language: Scala - Size: 17.7 MB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 18 - Forks: 5

interference-project/interference

opensource distributed database with base JPA implementation and event processing support

Language: Java - Size: 3.93 MB - Last synced: 2 months ago - Pushed: 5 months ago - Stars: 74 - Forks: 6

ElAlev/Wayeb

Wayeb is a Complex Event Processing and Forecasting (CEP/F) engine written in Scala.

Language: Scala - Size: 8.17 MB - Last synced: 4 months ago - Pushed: 6 months ago - Stars: 147 - Forks: 6

q3769/conseq4j

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

Language: Java - Size: 955 KB - Last synced: 9 days ago - Pushed: 6 months ago - Stars: 3 - Forks: 0

Periklismant/oPIEC

oPIEC: Online Event Recognition over Noisy Data Streams using the Event Calculus

Language: Prolog - Size: 1.9 MB - Last synced: 4 months ago - Pushed: 7 months ago - Stars: 15 - Forks: 1

vascokk/rivus_cep

Complex event processing in Erlang

Language: Erlang - Size: 1.59 MB - Last synced: 30 days ago - Pushed: over 7 years ago - Stars: 138 - Forks: 26

manospits/Phenesthe

'Phenesthe' (orig. φαίνεσθαι) is a system for the representation and processing of instantaneous and durative temporal phenomena.

Language: Prolog - Size: 39.4 MB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 18 - Forks: 0

czimml/rcepexample

An example application that aims to demonstrate some operations implemented by the Reactive CEP project

Size: 1000 Bytes - Last synced: 7 months ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

IshaanAdarsh/MedStream-Analytics

The project leverages Apache Flink, Apache Kafka and Python digital Twin to provide real-time insights into healthcare data, enabling timely interventions and proactive patient care.

Language: Jupyter Notebook - Size: 76.8 MB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 8 - Forks: 3

itsubaki/gostream

Stream Processing library for Go

Language: Go - Size: 234 KB - Last synced: 3 months ago - Pushed: 8 months ago - Stars: 54 - Forks: 8

itsubaki/gostream-server 📦

Stream Processing Server written in Go

Language: Go - Size: 77.1 KB - Last synced: 10 months ago - Pushed: about 1 year ago - Stars: 7 - Forks: 0

MaheshMadushan/SQLtoSiddhiQL

Transpiler to compile from SQL to SiddhiQL

Language: Java - Size: 432 KB - Last synced: 11 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 1

Macrometacorp/demo-akamai-fashionstore

Fashion Store using Edge Workers

Language: TypeScript - Size: 18.7 MB - Last synced: 11 months ago - Pushed: 11 months ago - Stars: 1 - Forks: 0

michaeldorner/CEP-Systems

An overview of Complex Event Processing Systems

Language: HTML - Size: 95.6 MB - Last synced: 10 months ago - Pushed: about 2 years ago - Stars: 23 - Forks: 10

adrianmilne/esper-demo-nuclear

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

Language: Java - Size: 310 KB - Last synced: 7 months ago - Pushed: over 4 years ago - Stars: 84 - Forks: 63

made2591/spotispy-framework

A framework to take the songs heard using Spotify and shared on social to extract information about tracks, genres, users. SpotiSpy performs more than just visualization: it analyzes the kinds of songs, geolocalizes users, extracts the list of most listened songs, and so much more. Created with BIG help of @valentinarho.

Size: 8.17 MB - Last synced: 9 months ago - Pushed: almost 7 years ago - Stars: 1 - Forks: 0

carloszimm/sbes2019 📦

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

Language: Java - Size: 26.6 MB - Last synced: 4 months ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

carloszimm/rcepexample 📦

Files/projects/scripts used for paper presented in WebMedia 2018

Language: JavaScript - Size: 93.8 KB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

mauzr/resty 📦

A lightweight toolset for IoT project :cat:

Language: Go - Size: 389 KB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 4 - Forks: 1

RxCEP/cepjs

:boom: Complex Event Processing boosted by JS Reactive Programming :boom:

Language: JavaScript - Size: 1.86 MB - Last synced: 20 days ago - Pushed: about 1 year ago - Stars: 6 - Forks: 0

qminer/qtopology 📦

Distributed stream processing layer

Language: TypeScript - Size: 2.93 MB - Last synced: 4 days ago - Pushed: over 1 year ago - Stars: 19 - Forks: 5

Kampadais/EsperProducts

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

Language: Java - Size: 273 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0

VitorPinheiro/ICarePatient

Mobile node code to run with Deklear

Language: Java - Size: 18.4 MB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 1 - Forks: 0

csymvoul/CEPEngine

A Complex Event Processing engine for the identification of events related to the resource usage of deployed services.

Language: Java - Size: 86.9 KB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 1 - Forks: 0

aartikis/oPIEC Fork of Periklismant/oPIEC

Online Probabilistic Interval-based Event Calculus

Size: 1.52 MB - Last synced: about 1 year ago - Pushed: over 3 years ago - Stars: 3 - Forks: 0

prabal77/ApachePulsarConnecitivityPlugin

Apama Connectivity Plugin for Apache Pulsar Messaging Framework.

Language: Java - Size: 30.1 MB - Last synced: about 1 year ago - Pushed: over 5 years ago - Stars: 1 - Forks: 0

laurindo-luis/safepet

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 o Broker Mosquitto.

Language: Java - Size: 3.9 MB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 0 - Forks: 0

VitorPinheiro/Deklear

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

Language: Java - Size: 17.1 MB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

pascals-ager/OpenvSwitch-Event-Processing

Implementation of an event processing framework within a DPDK accelerated Open vSwitch. The implemented framework embeds the vSwitch with capabilities to detect and process L7 events based on configured event rules. Additionally, an SDN controller based northbound API is implemented to offload application rules onto the vSwitch remotely.

Language: C - Size: 273 MB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 1 - Forks: 3

suhothayan/siddhi Fork of siddhi-io/siddhi

Stream Processing and Complex Event Processing Engine

Language: Java - Size: 27 MB - Last synced: 9 months ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

mauriziocarioli/Open-Ticket-App

Language: Java - Size: 376 KB - Last synced: about 1 year ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

mauriziocarioli/Open-Ticket

Language: Java - Size: 109 KB - Last synced: about 1 year ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

cs224/dev-meetup-control-structures

Control Structures and Paradigms in Java on the JVM

Language: Java - Size: 683 KB - Last synced: about 1 year ago - Pushed: almost 7 years ago - Stars: 2 - Forks: 0

menuka94/siddhi Fork of siddhi-io/siddhi

Language: Java - Size: 14.7 MB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0