492 Open source projects that are alternatives of or similar to open-stream-processing-benchmark

A full stack, reactive architecture for general purpose programming. Algebraic and monadically composable primitives for concurrency, parallelism, event handling, transactions, multithreading, Web, and distributed computing with complete de-inversion of control (No callbacks, no blocking, pure state)

Grid Solutions Framework

⚡A supercharged, interactive Kafka shell built on top of the existing Kafka CLI tools.

The free EAP version of the Cosmian Collaborative Confidential Computing platform. Try it!

Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.

MPI Parallel framework for training deep learning models built in Theano

Framework of vectorized and distributed data analytics

Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes

Realtime calculation distributed system. AKA distributed lodash

The purpose of this project is to apply mediapipe to more AI chips.

ARCHIVE of monorepo implementing Boba, an L2 Compute solution built on Optimistic Ethereum - active repo is at https://github.com/bobanetwork/boba

a payment application intended for deployment by the united states treasury

Dinky is an out of the box one-stop real-time computing platform dedicated to the construction and practice of Unified Streaming & Batch and Unified Data Lake & Data Warehouse. Based on Apache Flink, Dinky provides the ability to connect many big data frameworks including OLAP and Data Lake.

The origin of the Non-IID phenomenon is the personalization of users, who generate the Non-IID data. With Non-IID (Not Independent and Identically Distributed) issues existing in the federated learning setting, a myriad of approaches has been proposed to crack this hard nut. In contrast, the personalized federated learning may take the advantage…

papers on scalable and efficient machine learning systems

Self-contained examples of Apache Spark streaming integrated with Apache Kafka.

A reading list on blockchain and related technologies, targeted at technical people who want a deep understanding of those topics.

Simple yet powerful live data computation framework

Java library for managing Apache Flink via the Monitoring REST API

A light-weight library for building distributed applications such as microservices

汇总Apache Hudi相关资料

DevOps code to deploy eScience services

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

A message-passing distributed computing framework for node.js

Apache Spark and Apache Kafka integration example

Experiments for "Distributed Convolutional Dictionary Learning (DiCoDiLe): Pattern Discovery in Large Images and Signals"

基于spark-ml,spark-mllib,spark-streaming的推荐算法实现

Custom state store providers for Apache Spark

Distributed least squares approximation (dlsa) implemented with Apache Spark

scala、spark使用过程中，各种测试用例以及相关资料整理

🚀 R package: future.apply - Apply Function to Elements in Parallel using Futures

零基础学习spark，大数据学习

[GSoC] Distributed Data Structures - Collections Framework for Chapel language

Plot live-stats as graph from ApacheSpark application using Lightning-viz

Dockerized Folding@home client with NVIDIA GPU support to help battle COVID-19

Monitoring tool to measure flow throughput of data sources and processing components that are part of Data Ingestion and ETL pipelines.

Distributed process pool for Python

Real Time Analytics and Data Pipelines based on Spark Streaming

A Clojure dataframe library that runs on Spark

Prime95 source code from GIMPS to find Mersenne Prime.

bigdatatutorial

Fast Raft framework using the Redis protocol for Go

Machine is a workflow/pipeline library for processing data

A library to compute histograms on distributed environments, on streaming data

Live Twitter sentiment analysis using Python, Apache Spark Streaming, Kafka, NLTK, SocketIO

Scheduler for sub-node tasks for HPC systems with batch scheduling

Fundamentals of Spark with Python (using PySpark), code examples

四川大学拓思艾诺广告流量实时分析项目

Python framework for asynchronous, concurrent, distributed, network programming with coroutines

Kafka client for functional streams for scala (fs2)

Thrill - An EXPERIMENTAL Algorithmic Distributed Big Data Batch Processing Framework in C++

Stream Processing and Complex Event Processing Engine

Easy local cluster creation for Elixir to aid in unit testing

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

Real Time Twitter Sentiment Analysis Product

Simple examle for Spark Streaming over Kafka topic

大数据学习笔记，学习路线，技术案例整理。

Orleans providers for Azure Cosmos DB

Plumber, for your dirtiest Kafka streaming jobs

A Research-oriented Federated Learning Library. Supporting distributed computing, mobile/IoT on-device training, and standalone simulation. Best Paper Award at NeurIPS 2020 Federated Learning workshop. Join our Slack Community:(https://join.slack.com/t/fedml/shared_invite/zt-havwx1ee-a1xfOUrATNfc9DFqU~r34w)