coast
Stream processor
A streaming data processing framework with strong ordering and exactly-once semantics
Experiments in Streaming
60 stars
15 watching
3 forks
Language: Scala
last commit: about 10 years agoLinked from 1 awesome list
manuzhang/awesome-streamingRelated projects:
| Repository | Description | Stars |
|---|---|---|
 jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 scramjetorg/framework-cpp | A C++ framework for reactive stream programming with concurrent asynchronous operations | 3 |
 bytewax/bytewax | A Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities. | 1,585 |
| scramjetorg/framework-js | A reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams. | 38 |
 pathikrit/better-files | A Scala wrapper around Java NIO for simple and safe I/O operations, providing a pragmatic solution for tasks like file processing and compression. | 1,477 |
| bkirwi/decline | A composable command-line parser for Scala applications | 647 |
 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 |
 wallaroolabs/wally | A distributed stream processing framework for real-time data reactions | 1,477 |
 beatrichartz/parallel_stream | An Elixir module that parallelizes stream operations while preserving order | 100 |
 knowledgeonwebscale/streamingmassif | A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. | 10 |
 lsds/saber | A hybrid stream processing engine designed to optimize data processing on heterogeneous architectures. | 38 |
 vert-x3/vertx-reactive-streams | A Java library providing a standard for asynchronous stream processing with non-blocking back pressure. | 49 |
 keilerkonzept/topk | An implementation of probabilistic data structures for approximate data stream processing | 4 |
 gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 723 |