streamflow
Stream processor
A tool designed to simplify stream processing workflow development and management
StreamFlow™ is a stream processing tool designed to help build and monitor processing workflows.
253 stars
44 watching
69 forks
Language: Java
last commit: 11 months ago
Linked from 1 awesome list
Related projects:
Repository | Description | Stars |
---|---|---|
olacabs/fabric | A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability. | 55 |
lsds/saber | A hybrid stream processing engine designed to optimize data processing on heterogeneous architectures. | 38 |
jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
apache/rocketmq-streams | Provides a lightweight stream processing framework | 172 |
lsds/lightsaber | A high-throughput stream processing engine designed for multi-core CPUs with support for incremental computation and fault-tolerance semantics. | 70 |
knowledgeonwebscale/streamingmassif | A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. | 9 |
wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,480 |
bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,558 |
hortonworks/streamline | A toolset for building and deploying real-time data processing applications using various streaming engines and frameworks. | 164 |
nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,604 |
vert-x3/vertx-reactive-streams | A Java library providing a standard for asynchronous stream processing with non-blocking back pressure. | 49 |
nanosai/stream-ops-java | A Java-based data streaming engine and stream processing API designed to be embeddable in various applications. | 48 |
scramjetorg/framework-js | A reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams. | 38 |
alpha-unito/streamflow | A container-native workflow management system for managing multi-container environments and hybrid workflows. | 52 |