An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: streaming-analytics

FastPix/iOS-data-avplayer-sdk

Enhances AVPlayer with real-time analytics tracking for video playback. Automatically collects viewer engagement, quality metrics, and errors, with data visualized on the FastPix dashboard

Language: Swift - Size: 15.6 KB - Last synced at: about 5 hours ago - Pushed at: about 6 hours ago - Stars: 0 - Forks: 0

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: about 14 hours ago - Pushed at: about 15 hours ago - Stars: 1 - 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: 4 days ago - Pushed at: 4 days ago - Stars: 2 - Forks: 3

silverton-io/buz

Serverless multi-protocol + multi-destination event collection system.

Language: Go - Size: 30.1 MB - Last synced at: 4 days ago - Pushed at: 6 months ago - Stars: 205 - Forks: 26

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: 7 days ago - Pushed at: 14 days ago - Stars: 4,930 - Forks: 517

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: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

getindata/dbt-flink-adapter

Adapter for dbt that executes dbt pipelines on Apache Flink

Language: Python - Size: 14 MB - Last synced at: 20 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

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

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: 6 days ago - Pushed at: 6 days 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: 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

Rishav273/kafkaPysparkAnalytics

Real-time ETL pipeline for financial data (kafka, pyspark) .

Language: Python - Size: 395 MB - Last synced at: about 2 months 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: about 2 months 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: almost 3 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: almost 2 years ago - Pushed at: almost 2 years 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: almost 2 years 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: 3 days 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: about 2 months ago - Pushed at: almost 3 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: almost 4 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: 2 months ago - Pushed at: almost 5 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: 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