GitHub topics: datastreaming
conduktor/conduktor-platform
Streamline Apache Kafka with Conduktor Platform. 🚀
Size: 1.39 MB - Last synced at: about 20 hours ago - Pushed at: about 20 hours ago - Stars: 134 - Forks: 13
factorhouse/examples
Kpow and Flex product feature and integration examples
Language: Python - Size: 18.9 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 2 - Forks: 0
bousettayounes/Real-Time-Processing-of-Users-Data
Developing a data pipeline to stream user data from a user generator API, apply necessary transformations, and seamlessly insert the processed data into a storage system
Language: Python - Size: 4.08 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0
mikeroyal/AMX-Guide
Advanced Matrix Extensions (AMX) Guide
Language: C++ - Size: 44.9 KB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 88 - Forks: 7
glassflow/glassflow-python-sdk
GlassFlow Python SDK to publish and consume data to your pipelines at Glassflow.dev
Language: Python - Size: 4.69 MB - Last synced at: 1 day ago - Pushed at: 4 months ago - Stars: 9 - Forks: 1
glassflow/pipelines-push-action
This Github Action lets you automate GlassFlow pipelines deployments as code
Language: Python - Size: 104 KB - Last synced at: 3 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0
Mattdl/ContinualPrototypeEvolution
Codebase for Continual Prototype Evolution (CoPE) to attain perpetually representative prototypes for online and non-stationary datastreams. Includes implementation of the Pseudo-Prototypical Proxy (PPP) loss.
Language: Python - Size: 161 KB - Last synced at: about 1 month ago - Pushed at: about 3 years ago - Stars: 44 - Forks: 8
tarungka/wire
Wire is a distributed open source stream processing framework with powerful stream and batch-processing capabilities.[UNDER DEVELOPEMENT]
Language: Go - Size: 410 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 2 - Forks: 1
mriusero/real-time-fare-calculator 📦
This repository contains code snippets for a backend platform that calculates real-time taxi fares based on comfort levels. It leverages Kafka for data streaming, ElasticSearch for indexing, and BigQuery for revenue analysis, computing fares by analyzing driver-customer distances, categorized by comfort level and location.
Language: Java - Size: 14.6 KB - Last synced at: 7 months ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0
IndianaBug/moonStreamProcess
crypto aggregator of order books, trades, liquidations, open interest by levels
Language: Python - Size: 7.43 MB - Last synced at: 5 months ago - Pushed at: about 1 year ago - Stars: 7 - Forks: 1
AliEsmaeil/zagel
This is a real-time chat application designed for seamless communication between users.
Language: Dart - Size: 2.4 MB - Last synced at: 8 days ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0
jaehyeon-kim/beam-demos
Apache Beam demo projects
Language: Jupyter Notebook - Size: 2.22 MB - Last synced at: 7 months ago - Pushed at: 8 months ago - Stars: 5 - Forks: 2
mensahTribeWeb/war-card-game
a I declare WAR card game exploring API, Promises, and Callbacks
Language: JavaScript - Size: 3.91 KB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0
officialarijit/RPWE
Reward Penalty Weighted Ensemble approach for multimodal data stream classification
Language: Jupyter Notebook - Size: 1.74 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 0
gillsantos/streamflake
StreamFlake: Real-Time CDC Pipeline with Kafka and Snowflake
Size: 118 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0
achalise/cloudnative-serverless-streaming
- Data streaming application using spring cloud function, kafka streams and reactjs - Spring Cloud Function to write once and deploy to serverless and kubernetes
Language: Kotlin - Size: 289 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
samkenxstream/SAMkenXEcosystem_gcp-community Fork of GoogleCloudPlatform/community
🛡️📃PhoenixDOMString 🚀🔏📃SAMkenXEcosystem This repository holds the content submitted to https://cloud.google.com/community. Files added to the tutorials/ directory will appear at https://cloud.google.com/community/tutorials.
Language: Java - Size: 133 MB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 1
shujaattariq/rfid-reader-serial
Basic RFID Reader over Serial Port
Language: JavaScript - Size: 2.93 KB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 8 - Forks: 1
martandsingh/S3KinesisAWS
S3 bucket to Kinesis data stream using lambda functions
Language: JavaScript - Size: 13.7 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0
tknishh/Twitter-Spark-Streaming
Streaming data from data related to a certain topic.
Language: Jupyter Notebook - Size: 183 KB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0
Moh-Ayman/UDP-TCP-Sockets-Forwarding-using-Python
Building a client server model to forward data using UDP Port from server to another using a connecting server in the middle.
Language: Python - Size: 32.2 KB - Last synced at: 3 months ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0
jchambyd/TestMOA
Test of the drift classifiers implemented in MOA
Language: Java - Size: 99.4 MB - Last synced at: almost 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0
