Awesome Open Source

Programming Languages

Search results for stream processing

stream-processing x

362 search results found

Beepbeep 3 ⭐ 20

An event stream processor anyone can use

Rticonnextdds Reactive ⭐ 20

Reactive Extensions Adapters for RTI Connext DDS.

Hazelcast Jet Contrib ⭐ 19

Extension modules for Hazelcast Jet

Administration ⭐ 19

Umbrella project for the IBMStreams organization. This project will be used for the management of the individual projects within the IBMStreams organization.

Catenae Kafka ⭐ 18

Catenae 2 – Microservices Framework for Kafka

Kahpp Oss ⭐ 18

Kafka Streams made easy with a YAML file

Simple shared surface streaming application

Asynchronous pipelines of contiguous data, for rust.

Proxima Platform ⭐ 17

The Proxima platform.

Jpstream ⭐ 17

JPStream: JSONPath Stream Processing in Parallel

Kafka Streams ⭐ 17

Oh you know, just a coupla, two, tree Kafka Streams in Scala

Dspbench ⭐ 17

a suite of benchmark applications for distributed data stream processing systems

Kafka Streams for Low Code Environments

Storm Ml ⭐ 17

an online learning algorithm library for Storm

Esperiot ⭐ 17

Small and simple stream-based CEP tool for IoT devices connected to an MQTT broker

MIST: High-performance IoT Stream Processing

A Domain Specific Language for Distributed, Reactive Workflows

Aws Kinesis Local ⭐ 16

Build for local AWS Kinesis

Mediapipe_plus ⭐ 16

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

A Spatial Extension of Apache Flink

Tiny Cps ⭐ 16

Tiny goodies for Continuation-Passing-Style functions (OLDER VERSION), use instead the NEWER `cpsfy`

Apachekafka ⭐ 16

A curated re-sources list for awesome Apache Kafka

A stream processing language and compiler for small-scale monitoring

Kepler Model Server ⭐ 15

Model Server for Kepler

Remote Iterator Server

Coldfilter ⭐ 15

This repository contains the open source related to Cold Filter meta-framework (accepted by SIGMOD2018).

Rcppstreams ⭐ 15

A C++ DSEL for real-time event stream processing

Machine Learning And Data Processing ⭐ 15

A collection of resources on machine learning, data processing and related areas

A scalable, declarative, low-code framework for real-time and batch feature calculation/management (quant finance, anomaly/fraud detection, etc.), predictive ML training/inference and simulation. Built on top of Ray

Pysiddhi ⭐ 15

Python wrapper for Siddhi engine

Turbine Go ⭐ 15

Turbine Library for Go

Streamer ⭐ 14

streamer 实时计算引擎

Flamestream ⭐ 14

Distributed stream processing model and its implementation

ARTML- Real time learning

A simple and eloquent workflow for streaming messages to micro-services.

An opinionated clojure framework for writing kafka machines

Awesome Apache Pulsar ⭐ 14

A curated list of resources about Apache Pulsar.

Distributed KV Streams

Python stream processing for analytics

Akka Streams Custom Stream Processing Examples ⭐ 13

Demos of how to do custom stream processing using the Akka Streams GraphStages API

Kafka Streams Examples ⭐ 13

ReactiveX for data science

💥 Fusion is a tiny stream processing library written in Go.

Siddhi Operator ⭐ 13

Operator allows you to run stream processing logic directly on a Kubernetes cluster

Streamsx.kafka ⭐ 13

Repository for integration with Apache Kafka

Cedar implements an updatable double-array trie, which offers fast update/lookup for skewed queries in real-world data.

The magic message bus

Lecture: Big Data

🐟 A streaming ETL for fish

Nature is a development support platform, it separates data definition from code, so it decouple the data from business system.

Streambenchmarks ⭐ 12

Suite of Benchmark Applications for Stream Processing Systems

Distogram ⭐ 12

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

S3 Streaming ⭐ 12

stream and (de)serialize s3 streams

Fox Wamp ⭐ 12

Web Application Message Async Server and WAMP/MQTT bridge

Wearedevs 2018 ⭐ 12

Code for my talk "Stateful & Reactive Streaming Applications Without a Database" at WeAreDevelopers 2018

Deploy Kafka pipelines to Kubernetes

Kafka Aggregator ⭐ 12

A Kafka aggregator based on the Faust Python Stream Processing library

Frizzle for Apache Kafka

Dotdotnet ⭐ 11

C#.NET based DevFast NuGet package

Hyperstream ⭐ 11

Distributed event processing for Python based on Redis Streams

Clickhouse Tickstore ⭐ 11

Go package to store real time streaming websocket data in clickhouse using queuing and bulk insert.

Cribl Palo Alto Networks ⭐ 11

Process, reduce, and transform Palo Alto Networks Firewall logs.

Kafka Streams Cassandra State Store ⭐ 11

'Drop-in' Kafka Streams State Store implementation that persists data to Apache Cassandra / ScyllaDB

Cribl Windows Events ⭐ 11

This pack is targeted for collections of Window events in the Classic or newer XML format. For events in the Classic format, sometimes the Message field contains XML.

Pipelining framework for python. Designed for data analysis but can be useful to other applications

Idealistic and yet usable framework for event-driven backend

Framework ⭐ 11

The Beamline streaming process mining framework

Reading Notebook ⭐ 10

读书笔记|stream processing with apache flink|统计学习方法

Streamsx.inet ⭐ 10

This toolkit supports common internet protocols, such as HTTP and WebSockets

Extend Muon into the world of Spring. Implement Muon apis, especially around events to provide DDD patterns natively in Spring Boot

Confluent Platform Spark Streaming ⭐ 10

Working example of consuming Avro data from Kafka with Spark Streaming

Kafka Streams DSL liked, Stream Processing Library abstracting pipelines pattern using generic.

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

Event Sourcing ⭐ 10

An implementation of Event Sourcing and CQRS based on Azure table storage (EventStore) and Document DB (Materialized Views)

Dbt Decodable ⭐ 10

A dbt adapter for Decodable

Hs Popen ⭐ 10

Padogrid ⭐ 10

A comprehensive addon tool for managing data grid environments by distributed workspaces and online use case bundles

函数流，数据流，同步异步，事件驱动，多种模式channel

Monasca Aggregator ⭐ 9

Near real-time continuous aggregation of Monasca metrics

Stream processing with a series of tubes.

Stream processing in Python of twitter searches using public APIs.

Streamsx.hdfs ⭐ 9

This toolkit provides operators and functions for interacting with Hadoop File System.

Sawatabi is an application framework to develop and run stream-data-oriented Ising applications with quantum annealing.

A Stream Processor written in Golang that support pluggable tasks

Biggis Landuse ⭐ 9

Land use update detection

Twitter_hashtag_following ⭐ 8

This job is used to collect live tweets from the specified Twitter hashtag and saves the data in a specified model.

Streamprocessor ⭐ 8

C++ lazy evaluated stream processing

Streamsx.sparkmllib ⭐ 8

Toolkit for real-time scoring using Apache Spark MLLib library

Streamsx.hbase ⭐ 8

Integration of IBM Streams and Apache HBase

Floodplain Library ⭐ 8

Kotlin based stream processing framework

Hello Flink ⭐ 8

apache flink learning

SPBench: A Framework for Benchmarking Stream Processing Applications

Event Meshinery ⭐ 8

A new Framework for asynchronous signaling of processes via Kafka/Mysql/anything.

Protobufp ⭐ 8

Adds the stream-processing to protobuf messaging that you usually need to add yourself.

An Erlang/OTP library for lazily evaluated lists.

Flink Fault Tolerant Stream Example ⭐ 8

An example of using Flink for Fault-Tolerant Stream Processing

Nyuki Legacy ⭐ 8

Allowing the creation of independent unit to deal with stream processing while exposing an XMPP and REST API.

Go client library for EventStore.

201-300 of 362 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.