Topic: "streaming-data-processing"
infinyon/fluvio
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
Language: Rust - Size: 34.4 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 4,937 - Forks: 517
siddhi-io/siddhi
Stream Processing and Complex Event Processing Engine
Language: Java - Size: 33.6 MB - Last synced at: 17 days ago - Pushed at: about 2 months ago - Stars: 1,546 - Forks: 530
quixio/quix-streams
Python Streaming DataFrames for Kafka
Language: Python - Size: 8.58 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 1,384 - Forks: 78
jMetal/jMetalSP
A framework for Big Data Optimization with multi-objective metaheuristics
Language: Java - Size: 4.25 MB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 46 - Forks: 27
sdpython/pandas-streaming
Streaming API for pandas applied to big datasets
Language: Python - Size: 883 KB - Last synced at: 28 days ago - Pushed at: 9 months ago - Stars: 31 - Forks: 9
benwilcock/spring-cloud-dataflow-demo
Demonstration of streaming applications using Spring Cloud Data Flow with microservices written in Spring Cloud Stream.
Language: Java - Size: 201 KB - Last synced at: over 2 years ago - Pushed at: almost 5 years ago - Stars: 11 - Forks: 7
thanhtbt/tensor_tracking_survey
[IEEE TKDE 2023] A list of up-to-date papers on streaming tensor decomposition, tensor tracking, dynamic tensor analysis
Size: 528 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 6 - Forks: 2
thanhtbt/ROLCP
[IEEE ICASSP 2021] "A fast randomized adaptive CP decomposition for streaming tensors". In 46th IEEE International Conference on Acoustics, Speech, & Signal Processing, 2021.
Language: MATLAB - Size: 379 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 1
fjoniyz/ganges
A project for the module (Advanced) Distributed Systems Prototyping at the Technical University of Berlin.
Language: Jupyter Notebook - Size: 8.97 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 1
titianaMannu/SABD-TM-Project2
Stream processing of AIS data with Flink
Language: Java - Size: 15.9 MB - Last synced at: almost 2 years ago - Pushed at: almost 4 years ago - Stars: 1 - Forks: 0
L-MDLC/mdlc-nodejs-demos
This repository contains a collection of NodeJS/Typescript demos presented in technical events and on the french YouTube channel 'Les Mains Dans Le Code'.
Language: TypeScript - Size: 893 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0
aDudko/streaming-data-loader
Tool for efficient loading and processing of streaming data from Kafka to Elasticsearch
Language: Python - Size: 16.6 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0
L-MDLC/mdlc-java-spring-demos
This repository contains a collection of Java demos presented in technical events and on the french YouTube channel 'Les Mains Dans Le Code'.
Language: Java - Size: 9.77 KB - Last synced at: 2 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0
thecodemancer/Apache-Beam
🔥👨💻 Build Big data pipelines with Apache Beam in any language and run it via Spark, Flink, GCP (Google Cloud Dataflow).
Language: Jupyter Notebook - Size: 321 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0
edwinthomas444/machine-learning
e2e machine learning pipeline using a config based approach for classification problems. Supports grouping and grading classifiers in addition to online learning algorithms
Language: Python - Size: 55.1 MB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
bhavitavayashrivastava/Python-SparkStreaming
Spark Streaming using Flume (pushed based Approach)
Language: Python - Size: 3.91 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0
