stream-processing
There are 989 repositories under stream-processing topic.
hazelcast/hazelcast-jet
Distributed Stream and Batch Processing
clj-commons/manifold
A compatibility layer for event-driven abstractions
uhop/stream-json
The micro-library of Node.js stream components for creating custom JSON processing pipelines with a minimal memory footprint. It can parse JSON files far exceeding available memory streaming individual primitives using a SAX-inspired API.
spring-cloud/spring-cloud-stream
Framework for building Event-Driven Microservices
edp963/wormhole
Wormhole is a SPaaS (Stream Processing as a Service) Platform
ververica/flink-sql-cookbook
The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.
nodefluent/kafka-streams
equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:
vladimirvivien/automi
A stream processing API for Go (alpha)
gearpump/gearpump
Lightweight real-time big data streaming engine over Akka
pipeless-ai/pipeless
An open-source computer vision framework to build and deploy apps in minutes
gazette/core
Build platforms that flexibly mix SQL, batch, and stream processing paradigms
lw-lin/streaming-readings
Streaming System 相关的论文读物
hstreamdb/hstream
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
TouK/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
apache/streampipes
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
infoslack/awesome-kafka
A list about Apache Kafka
microsoft/psi
Platform for Situated Intelligence
leesf/hudi-resources
汇总Apache Hudi相关资料
deep5050/radio-active
Play any radios around the globe right from the terminal :zap:
constellation-rs/amadeus
Harmonious distributed data analysis in Rust.
nmaquet/kasper
Kasper is a lightweight library for processing Kafka topics.
smooks/smooks
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
RedisGears/RedisGears
Dynamic execution framework for your Redis data
FutureSDR/FutureSDR
An Async SDR Runtime for Heterogeneous Architectures
Kurento/kurento
Kurento WebRTC Media Server
swimos/swim-rust
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
AICoE/log-anomaly-detector
Log Anomaly Detection - Machine learning to detect abnormal events logs
AxisCommunications/media-stream-library-js
JavaScript library to handle media streams on the command line (Node.js) and in the browser.
Chulong-Li/Real-time-Sentiment-Tracking-on-Twitter-for-Brand-Improvement-and-Trend-Recognition
A real-time interactive web app based on data pipelines using streaming Twitter data, automated sentiment analysis, and MySQL&PostgreSQL database (Deployed on Heroku)
vectorengine/vectorsql
VectorSQL is a free analytics DBMS for IoT & Big Data, compatible with ClickHouse.
streamnative/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
memgraph/mage
MAGE - Memgraph Advanced Graph Extensions :crystal_ball:
raystack/dagger
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
bbejeck/kafka-streams-in-action
Source code for the Kafka Streams in Action Book
Point72/csp
csp is a high performance reactive stream processing library, written in C++ and Python
cross-platform/dspatch
The Refreshingly Simple Cross-Platform C++ Dataflow / Patching / Pipelining / Graph Processing / Stream Processing / Reactive Programming Framework