Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
- java
- hazelcast
- in-memory
- big-data
47,133 repositories indexed
1–22 of 22 · Most stars
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
StreamAlert is a serverless, realtime data analysis framework which empowers you to ingest, analyze, and alert on data from any environment, using datasources and alerting logic you define.
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Compositional, streaming I/O library for Scala
The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.
Lightweight data stream processing engine for IoT edge
Stream Processing and Complex Event Processing Engine
Trill is a single-node query processor for temporal or streaming data.
A compatibility layer for event-driven abstractions
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
Lightweight real-time big data streaming engine over Apache Pekko
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
🏎️ Streams & Reactive Programming paradigm for Go: declarative and composable API for event-driven applications
Compositional pipelines
Amazon Kinesis Aggregators provides a simple way to create real time aggregations of data on Amazon Kinesis.
Data management for the sensor-edge-cloud continuum
Multi-core Window-Based Stream Processing Engine
Lightweight SQL-based stream processing engine for IoT edge.
Parallelize _anything_ //
Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency
Simple yet powerful live data computation framework.
Simple yet powerful live data computation framework. C++ port of Scramjet framework.