From b39af491d2b89dbb3f49ab2321fa0775a8769ba5 Mon Sep 17 00:00:00 2001 From: Sriharsha Yayi Date: Tue, 3 Oct 2023 15:14:23 -0700 Subject: [PATCH 1/4] Add Numaflow Adding Numaflow, a K8s native stream processing platform. --- README.md | 1 + 1 file changed, 1 insertion(+) diff --git a/README.md b/README.md index 3eefc2df..338734ab 100644 --- a/README.md +++ b/README.md @@ -39,6 +39,7 @@ A curated list of awesome [streaming (stream processing)](http://radar.oreilly.c - [Maki Nage](https://github.com/maki-nage/makinage) [Python] - A stream processing framework for data scientists, based on Kafka and ReactiveX. - [mantis](https://github.com/Netflix/mantis) [Java] - Netflix's platform to build an ecosystem of realtime stream processing applications - [mupd8(muppet)](https://github.com/walmartlabs/mupd8) [Scala/Java] - mapReduce-style framework for processing fast/streaming data. +- [Numaflow](https://github.com/numaproj/numaflow)- Kubernetes native stream processing platform with language agnostic framework. Scalable and cost-efficient - [Onyx](https://github.com/onyx-platform/onyx) [Clojure] - Distributed, masterless, high performance, fault tolerant data processing. - [s4](https://github.com/apache/incubator-s4) [Java] - general-purpose, distributed, scalable, fault-tolerant, pluggable platform that allows programmers to easily develop applications for processing continuous unbounded streams of data. - [SABER](https://github.com/lsds/Saber) [Java/C] - Window-Based Hybrid CPU/GPU Stream Processing Engine. From f80dbd6644cb96929f2e160cfe3611dacc1464b6 Mon Sep 17 00:00:00 2001 From: Sriharsha Yayi Date: Tue, 3 Oct 2023 15:15:58 -0700 Subject: [PATCH 2/4] Update Numaflow --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index 338734ab..0ba188ab 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,7 @@ A curated list of awesome [streaming (stream processing)](http://radar.oreilly.c - [Maki Nage](https://github.com/maki-nage/makinage) [Python] - A stream processing framework for data scientists, based on Kafka and ReactiveX. - [mantis](https://github.com/Netflix/mantis) [Java] - Netflix's platform to build an ecosystem of realtime stream processing applications - [mupd8(muppet)](https://github.com/walmartlabs/mupd8) [Scala/Java] - mapReduce-style framework for processing fast/streaming data. -- [Numaflow](https://github.com/numaproj/numaflow)- Kubernetes native stream processing platform with language agnostic framework. Scalable and cost-efficient +- [Numaflow](https://github.com/numaproj/numaflow) - Kubernetes native stream processing platform with language agnostic framework. Scalable and cost-efficient - [Onyx](https://github.com/onyx-platform/onyx) [Clojure] - Distributed, masterless, high performance, fault tolerant data processing. - [s4](https://github.com/apache/incubator-s4) [Java] - general-purpose, distributed, scalable, fault-tolerant, pluggable platform that allows programmers to easily develop applications for processing continuous unbounded streams of data. - [SABER](https://github.com/lsds/Saber) [Java/C] - Window-Based Hybrid CPU/GPU Stream Processing Engine. From 67454ba13a0b49e234436d2bfe9530407ef77357 Mon Sep 17 00:00:00 2001 From: Sriharsha Yayi Date: Tue, 3 Oct 2023 20:47:55 -0700 Subject: [PATCH 3/4] Add Numalogic Add Numalogic to Online ML --- README.md | 1 + 1 file changed, 1 insertion(+) diff --git a/README.md b/README.md index 0ba188ab..e6716fa4 100644 --- a/README.md +++ b/README.md @@ -124,6 +124,7 @@ Mesos, designed for high performance data processing jobs that require flexibili - [Apache Samoa](https://github.com/apache/incubator-samoa) [Java] - distributed streaming machine learning (ML) framework that contains a programing abstraction for distributed streaming ML algorithms. - [DataSketches](https://github.com/DataSketches/sketches-core) [Java] - sketches library from Yahoo!. +- [Numalogic] (https://github.com/numaproj/numalogic) [Python] - Collection of ML models and libraries for real-time anomaly detection and forecasting on time series data. Built on Numaflow, a K8s native stream processing platform - [River](https://github.com/online-ml/river) [Python] - online machine learning library. - [streamDM](https://github.com/huawei-noah/streamDM) [Scala] - mining Big Data streams using Spark Streaming from Huawei. - [StreamingBandit](https://github.com/Nth-iteration-labs/streamingbandit) [Python] - Provides a webserver to quickly setup and evaluate possible solutions to contextual multi-armed bandit (cMAB) problems. From 0b22ead308b5a4c53b864dff5413026d6af68e43 Mon Sep 17 00:00:00 2001 From: Sriharsha Yayi Date: Thu, 8 Feb 2024 08:31:48 -0800 Subject: [PATCH 4/4] Update README.md Added languages for Numaflow --- README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/README.md b/README.md index e6716fa4..2e9b696d 100644 --- a/README.md +++ b/README.md @@ -39,7 +39,7 @@ A curated list of awesome [streaming (stream processing)](http://radar.oreilly.c - [Maki Nage](https://github.com/maki-nage/makinage) [Python] - A stream processing framework for data scientists, based on Kafka and ReactiveX. - [mantis](https://github.com/Netflix/mantis) [Java] - Netflix's platform to build an ecosystem of realtime stream processing applications - [mupd8(muppet)](https://github.com/walmartlabs/mupd8) [Scala/Java] - mapReduce-style framework for processing fast/streaming data. -- [Numaflow](https://github.com/numaproj/numaflow) - Kubernetes native stream processing platform with language agnostic framework. Scalable and cost-efficient +- [Numaflow](https://github.com/numaproj/numaflow) [Java/Python/Go/Rust] - Kubernetes native stream processing platform with language agnostic framework. Scalable and cost-efficient - [Onyx](https://github.com/onyx-platform/onyx) [Clojure] - Distributed, masterless, high performance, fault tolerant data processing. - [s4](https://github.com/apache/incubator-s4) [Java] - general-purpose, distributed, scalable, fault-tolerant, pluggable platform that allows programmers to easily develop applications for processing continuous unbounded streams of data. - [SABER](https://github.com/lsds/Saber) [Java/C] - Window-Based Hybrid CPU/GPU Stream Processing Engine.