Topic: "streaming-analytics"
infinyon/fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Language: Rust - Size: 34 MB - Last synced at: 5 days ago - Pushed at: 12 days ago - Stars: 4,930 - Forks: 517
silverton-io/buz
Serverless multi-protocol + multi-destination event collection system.
Language: Go - Size: 30.1 MB - Last synced at: 1 day ago - Pushed at: 6 months ago - Stars: 205 - Forks: 26
getindata/dbt-flink-adapter
Adapter for dbt that executes dbt pipelines on Apache Flink
Language: Python - Size: 14 MB - Last synced at: 18 days ago - Pushed at: about 1 year ago - Stars: 95 - Forks: 12
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: about 1 month ago - Pushed at: 4 months ago - Stars: 43 - Forks: 4
Rishav273/kafkaPysparkAnalytics
Real-time ETL pipeline for financial data (kafka, pyspark) .
Language: Python - Size: 395 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 1
Cumulocity-IoT/cumulocity-analytics-management
Extends the standard cumulocity administration with dialog to add analytics builder extensions
Language: TypeScript - Size: 50.7 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 7 - Forks: 3
MarekWadinger/adaptive-interpretable-ad
Self-Supervised Adaptive and Interpretable Anomaly Detection with Dynamic Operating Limits
Language: Python - Size: 158 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 5 - Forks: 0
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: about 1 month ago - Pushed at: almost 3 years ago - Stars: 3 - Forks: 0
Cumulocity-IoT/streaming-analytics-sample-repo-template
This repo provides a template for developing Cumulocity Streaming Analytics assets such as Blocks and EPL Apps, with a dev container for opening in Visual Studio Code
Language: Python - Size: 42 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 2 - Forks: 3
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
xenogenics/openstreams Fork of IBMStreams/OSStreams
Open-source, Cloud-native Streams
Language: C++ - Size: 11.4 MB - Last synced at: about 22 hours ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 1
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
IBMStreams/streamsx.cloudant
Allow Streams applications to read / write to Cloudant database
Language: Java - Size: 866 KB - Last synced at: 2 months ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 2
rohitshubham/Cloud-pipeline
A real-life end-to-end cloud sub-system scenario
Language: Python - Size: 294 KB - Last synced at: almost 2 years ago - Pushed at: almost 5 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
MrHAM17/Spotify_Streaming_Analytics
This is my Sem 7 BDA Lab Project. For complete details, kindly check the below README File.
Language: Jupyter Notebook - Size: 14.9 MB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 0 - Forks: 0
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: about 2 months 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: 9 months ago - Pushed at: 9 months ago - Stars: 0 - Forks: 0
denisecase/streaming-01-getting-started
An opinionated way to get started with Python for streaming analytics
Language: Python - Size: 376 KB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 109
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: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - 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
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: almost 3 years ago - Stars: 0 - 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: almost 4 years ago - Stars: 0 - Forks: 0
IBMStreams/streamsx.microservice
Provide documentation, utilities, examples for Streams microservices
Language: Java - Size: 61.5 KB - Last synced at: 2 months ago - Pushed at: almost 5 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: over 5 years ago - Stars: 0 - Forks: 0
