data-stream-processing · GitHub Topics

ArroyoSystems / arroyo

Distributed stream processing engine in Rust

data dev-tools infrastructure kafka Rust SQL stream-processing data-stream-processing stream-processing-engine

Rust 4.38 k

3 天前

superstreamlabs / memphis

Memphis.dev is a highly scalable and effortless data streaming platform

data data-stream-processing data-streaming Kubernetes messaging-queue data-engineering data-pipeline Go enrichment message-broker message-bus message-queue 微服务 schema-registry

Go 3.31 k

1 年前

Western-OC2-Lab / AutoML-Implementation-for-Static-and-Dynamic-Data-Analytics

#计算机科学#Implementation/Tutorial of using Automated Machine Learning (AutoML) methods for static/batch and online/continual learning

automated-machine-learning automl concept-drift data-preprocessing data-stream-processing data-streams 深度学习 feature-engineering hyperparameter-tuning intrusion-detection-system Internet of things 机器学习 model-selection

Jupyter Notebook 628

1 年前

Fengrui-Liu / StreamAD

#计算机科学#Online anomaly detection for data streams/ Real-time anomaly detection for time series data.

streaming Python anomaly-detection online-learning incremental-learning data-streams outlier-detection time-series data-stream-processing 机器学习 timeseries

Python 122

2 年前

aartikis / RTEC

RTEC is an Event Calculus implementation optimised for stream reasoning

logic-programming data-stream-processing 人工智能数据科学 multi-agent-systems stream-processing cep prolog

Prolog 92

5 天前

inloco / kafka-elasticsearch-injector

Golang app to read records from a set of kafka topics and write them to an elasticsearch cluster

Go elasticsearch kafka data-stream-processing Hacktoberfest

Go 75

3 年前

marcosschroh / faust-docker-compose-example

Faust dockerized application

faust kafka schema-registry zookeeper data-stream-processing Docker

Python 68

3 年前

oscimp / oscimpDigital

OscillatorIMP ecosystem for the digital characterization of ultrastable oscillators and Software Defined Radio (SDR) frontend processing

buildroot fpga linux-driver sdr software-defined-radio plutosdr data-stream-processing ecosystem radio-frequency digital-signal-processing

3 天前

zmyzheng / TweetMap

A real time Tweet Trend Map and Sentiment Analysis web application with kafka, Angular, Spring Boot, Flink, Elasticsearch, Kibana, Docker and Kubernetes deployed on the cloud

Spring Boot Angular data-stream-processing kafka flink kibana Docker Kubernetes 微服务 Amazon Web Services sentiment-analysis Bootstrap cloud

Java 51

2 年前

Western-OC2-Lab / AutoML-and-Adversarial-Attack-Defense-for-Zero-Touch-Network-Security

#计算机科学#This repository includes code for the AutoML-based IDS and adversarial attack defense case studies presented in the paper "Enabling AutoML for Zero-Touch Network Security: Use-Case Driven Analysis" pu...

6g adversarial-attacks adversarial-machine-learning automated-machine-learning automl concept-drift data-stream-processing data-streams hyperparameter-optimization hyperparameter-tuning ids intrusion-detection-system 深度学习 feature-engineering feature-selection 机器学习 Cybersecurity network-automation

Jupyter Notebook 36

3 个月前

anqorithm / RealTime-StockStream

RealTime StockStream is a streamlined, simulation system for processing live stock market data. It uses Apache Kafka for data input, Apache Spark for data handling, and Apache Cassandra for data stora...

data-stream-processing Docker Docker Compose kafka Python realtime Apache Spark spark-streaming stocks zookeeper asynchronous bigdata 数据库 stock-market

Python 26

4 个月前

officialarijit / RECS

Real-time Emotion Recognition using Physiological signals in e-Learning Here one can find the development of realtime emotion recognition using various physiological signals

e-learning data-stream-processing affective-computing real-time-processing

Jupyter Notebook 24

1 年前

AhmetFurkanDEMIR / Flink-Example

Flink Example

debezium debeziumkafkaconnector Docker flink flink-sql kafka Scala Ubuntu apache apache-flink data-engineering data-stream-processing kafka-streams

Scala 16

2 年前

ognis1205 / mutad

Realtime Data Processing and Search Engine Implementation.

Docker Amazon Web Services cloud React Next elasticsearch kibana Spring Boot kafka storm 微服务 data-stream-processing TypeScript Java material-ui

Java 15

3 年前

JayKumarr / OSDM

This code belongs to ACL conference paper entitled as "An Online Semantic-enhanced Dirichlet Model for Short Text Stream Clustering"

data-stream data-stream-processing text-clustering text-mining

Python 15

4 年前

ppatierno / kafka-hybrid-iot

Apache Kafka for the Hybrid IoT

apache-kafka Internet of things messaging amqp Eclipse Vert.x iot-application iot-cloud kafka-streams data-streaming data-stream-processing

JavaScript 10

6 年前

braineering / socstream

Real-time visual analytics for soccer matches, leveraging Apache Flink, Apache Kafka and the Elastic stack. Solution to DEBS 2013 Grand Challenge. Coursework in Systems and Architectures for Big Dat...

big-data-analytics visual-analytics real-time data-stream-processing soccer apache-flink apache-kafka elasticstack elasticsearch kibana

Java 10

8 年前

radinhamidi / Hybrid_Forest

#计算机科学#Hybrid Forest: A Concept Drift Aware Data Stream Mining Algorithm

机器学习 data-mining 数据科学人工智能 classification regression data-stream-processing

Python 9

6 年前

braineering / crimegraph

Real-time visual analytics application for link prediction and link detection in criminal networks. Research work accepted to the 5th IEEE International Conference on Future of Internet of Things and ...

big-data-analytics real-time data-stream-processing NoSQL graph-database social-network apache-flink apache-kafka Neo4j

Java 8

8 年前

Data-Wrangling-with-JavaScript / Chapter-7

Code examples for Chapter 7 of Data Wrangling with JavaScript

JavaScript data-wrangling Node.js stream streaming stream-processing data-stream data-stream-processing parallel-computing

JavaScript 7

4 年前