riko

maki-nage/makinage38

Stream processor

Stream Processing Library and Framework

bytewax/bytewax1.6K

Stream processor

A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities.

bkirwi/coast60

Stream processor

A streaming data processing framework with strong ordering and exactly-once semantics

wallaroolabs/wally1.5K

Stream processor

A distributed stream processing framework for real-time data reactions

basho/riak_pipe162

Pipeline processor

Enables parallel processing of data by dividing tasks into independent queues managed by Riak Core's vnode architecture.

reugn/go-streams1.9K

Stream processor library

Provides a lightweight and flexible way to process data streams in Go

python-streamz/streamz1.2K

Stream processor

A library for building and managing real-time stream processing pipelines in Python

quixio/quix-streams1.2K

Data processor

A Python framework for real-time data processing on Apache Kafka streams

edwardcapriolo/teknek-core8

Stream processor

A software platform that enables stream processing and data integration across multiple data sources.

beatrichartz/parallel_stream100

Stream processor

An Elixir module that parallelizes stream operations while preserving order

streamio/streamio-ffmpeg1.6K

Movie processor

Provides a Ruby interface to FFmpeg for reading movie metadata and transcoding video files.

olacabs/fabric55

Stream processor

A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability.

wintoncode/winton-kafka-streams311

Stream processor

A Python implementation of Apache Kafka's Streams API for building stream processing applications

dm6718/ritsar208

SAR processor

A Python-based software toolkit for processing Synthetic Aperture Radar image data

raine/ramda-cli573

Pipeline processor

A tool for composing functions into data-processing pipelines to produce desired output.