GitHub topics: streaming-analytics
infinyon/fluvio
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Language: Rust - Size: 34.2 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 4,613 - Forks: 511
SonicEXEDVP/real-time-data-pipeline
📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.
Size: 1000 Bytes - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 1 - Forks: 0
abeltavares/real-time-data-pipeline
📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.
Language: Python - Size: 1010 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 43 - Forks: 4
getindata/dbt-flink-adapter
Adapter for dbt that executes dbt pipelines on Apache Flink
Language: Python - Size: 14 MB - Last synced at: 26 days ago - Pushed at: about 1 year ago - Stars: 92 - Forks: 12
MarekWadinger/adaptive-interpretable-ad
Self-Supervised Adaptive and Interpretable Anomaly Detection with Dynamic Operating Limits
Language: Python - Size: 158 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 5 - Forks: 0
silverton-io/buz
Serverless multi-protocol + multi-destination event collection system.
Language: Go - Size: 30.1 MB - Last synced at: 14 days ago - Pushed at: 5 months ago - Stars: 202 - Forks: 26
Cumulocity-IoT/cumulocity-analytics-management
Extends the standard cumulocity administration with dialog to add analytics builder extensions
Language: TypeScript - Size: 50.3 MB - Last synced at: 22 days ago - Pushed at: about 1 month ago - Stars: 7 - Forks: 3
Undisputed-jay/Streaming-Data-from-Reddit-Using-Kafka-Spark-and-MongoDB
A data pipeline that streams Reddit comments from the 'Politics' subreddit using Kafka and Apache Spark. Processed data is stored in MongoDB for real-time analysis and management.
Language: Python - Size: 399 MB - Last synced at: 26 days ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0
MrHAM17/Spotify_Streaming_Analytics
Project is stable & documentation will be completed soon. Thank you for your understanding and patience.
Language: Jupyter Notebook - Size: 14.4 MB - Last synced at: about 1 month ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0
InspiredcL/data-science-on-gcp Fork of GoogleCloudPlatform/data-science-on-gcp
Código fuente: Análisis de Vuelos basado en trabajo de Valliappa Lakshmanan.
Language: Jupyter Notebook - Size: 12.5 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0
Rishav273/kafkaPysparkAnalytics
Real-time ETL pipeline for financial data (kafka, pyspark) .
Language: Python - Size: 395 MB - Last synced at: 14 days ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 1
denisecase/streaming-01-getting-started
An opinionated way to get started with Python for streaming analytics
Language: Python - Size: 376 KB - Last synced at: 15 days ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 109
karmatothex/awt-pj-ss22-streaming-analytics-using-cmcd-and-cmsd-1
Advanced Web Technologies Project @ TUB
Language: JavaScript - Size: 1.06 GB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
nabikhalid/spark-streaming-app
Real-time data streaming and processing application using Apache Spark, with Dockerized deployment.
Language: Python - Size: 349 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
rohitshubham/Cloud-pipeline
A real-life end-to-end cloud sub-system scenario
Language: Python - Size: 294 KB - Last synced at: over 1 year ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 0
maxng07/ksqlDB
Learnings on ksqlDB
Size: 92.8 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0
xenogenics/openstreams Fork of IBMStreams/OSStreams
Open-source, Cloud-native Streams
Language: C++ - Size: 11.4 MB - Last synced at: about 2 hours ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 1
alefais/packet-streaming-bench-sigcomm22poster
Source code of a heavy hitter packet streaming application implemented with four stream processing systems: Flink, Spark Streaming, Storm and WindFlow.
Language: C++ - Size: 3.95 MB - Last synced at: 15 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
rndazurescript/StreamingInAzure
Streaming data processing in Azure
Language: C# - Size: 1.02 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0
prabal77/ApachePulsarConnecitivityPlugin
Apama Connectivity Plugin for Apache Pulsar Messaging Framework.
Language: Java - Size: 30.1 MB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0
sophannaek/COVID19_Tweet_Sentiment_Analysis
Sentiment Analysis of Long-term of Social Data during the COVID-19 Pandemic
Language: Python - Size: 1.08 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0
IBMStreams/streamsx.cloudant
Allow Streams applications to read / write to Cloudant database
Language: Java - Size: 866 KB - Last synced at: about 1 month ago - Pushed at: over 4 years ago - Stars: 1 - Forks: 2
IBMStreams/streamsx.microservice
Provide documentation, utilities, examples for Streams microservices
Language: Java - Size: 61.5 KB - Last synced at: about 1 month ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 3
robertobatts/ml-streaming
Real time machine learning analysis on Azure. Pipeline: Nodejs app (to simulate cameras) -> Blob Storage -> IoT Hub -> Streaming Analytics -> Azure Function -> Custom Vision Service
Language: JavaScript - Size: 12.7 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0
