streamprocessing
There are 16 repositories under streamprocessing topic.
risingwavelabs/awesome-stream-processing
A collection of demonstrations showcasing how stream processing can be used to solve real-world problems.
Axual/ksml
Kafka Streams for Low Code Environments
anovv/svoe
A scalable, declarative, low-code framework for real-time and batch feature calculation/management (quant finance, anomaly/fraud detection, etc.), predictive ML training/inference and simulation. Built on top of Ray
usedatabrew/pg_stream_benthos
Postgres Logical Replication plugin for benthos
datakaveri/iudx-adaptor-framework
A data ingestion adaptor to plug data from source to sink with a configuration based pipeline
streamreasoning/rsplab
Repository containing configurations for the benchmarks included in RSP Lab Suite
hmrguez/Hermes
This is the graduate thesis work for my Computer Science Major
AhmadAfsharinejad/Orleans.StreamProcessing
A .NET stream processing
phip123/glimmer
Simple stream processing library for synchronous or parallel and non-distributed execution.
dininduviduneth/github-analytics-uu
GitHub Analytics Using Apache Pulsar - Streaming Analytics Solution
sulthonuladib/recets-engine
simple stream processing with event driven services. using nodejs, rabbitmq, apache kafka, mongodb and redis
tahhnik/Designing-Large-Scale-Data-Warehouse-with-Azure-Synapse-Analytics
The repo simulates query load, optimizes performance, and offers practical guidance for building data warehouses with Azure Synapse Analytics. 🚀
vigneshc/TweetAggregates
Stream & aggregate tweets containing a set of track terms in memory and write aggregates to rocks db. Aggregates include top hashtags, top mentions and top retweets. Contains a local executable that can run forever, computing aggregates and storing results in a local rocks DB. Also has repl mode for querying results from the db.
imminh123/streaming-analytics-platforms-kafka-spark
A sample real-time streaming analytics application with Spark Structured Streaming and Kafka.
khandakerrahin/BDT2022-Group12
The aim of this big data project is to design and implement a big data system that can provide real-time context-aware recommendations to drivers on the level of possible danger.