Topic: "streamprocessing"
risingwavelabs/awesome-stream-processing
A collection of demos showcasing how stream processing can be used to solve real-world problems.
Language: Python - Size: 1010 KB - Last synced at: about 21 hours ago - Pushed at: 28 days ago - Stars: 197 - Forks: 9
Axual/ksml
Kafka Streams for Low Code Environments
Language: Java - Size: 2.15 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 25 - Forks: 11
redpanda-data/pg_stream 📦
Postgres Logical Replication plugin for benthos
Language: Go - Size: 187 KB - Last synced at: 9 days ago - Pushed at: 8 months ago - Stars: 18 - Forks: 4
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
Language: Python - Size: 78.6 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 15 - Forks: 10
datakaveri/iudx-adaptor-framework
A data ingestion adaptor to plug data from source to sink with a configuration based pipeline
Language: Java - Size: 2.04 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 7
streamreasoning/rsplab
Repository containing configurations for the benchmarks included in RSP Lab Suite
Language: Jupyter Notebook - Size: 307 MB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 5 - Forks: 6
AhmadAfsharinejad/Orleans.StreamProcessing
A .NET stream processing
Language: C# - Size: 3.96 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 1 - Forks: 0
phip123/glimmer
Simple stream processing library for synchronous or parallel and non-distributed execution.
Language: Python - Size: 65.4 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 1 - Forks: 0
dininduviduneth/github-analytics-uu
GitHub Analytics Using Apache Pulsar - Streaming Analytics Solution
Language: Jupyter Notebook - Size: 482 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
sulthonuladib/recets-engine
simple stream processing with event driven services. using nodejs, rabbitmq, apache kafka, mongodb and redis
Language: TypeScript - Size: 36.1 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
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.
Language: JavaScript - Size: 3.74 MB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0
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.
Language: C# - Size: 27.3 KB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
