riak_pipe
Pipeline processor
Enables parallel processing of data by dividing tasks into independent queues managed by Riak Core's vnode architecture.
Riak Pipelines
162 stars
84 watching
61 forks
Language: Erlang
last commit: over 3 years agoRelated projects:
| Repository | Description | Stars |
|---|---|---|
| basho/riak | A distributed, decentralized data storage system for storing and retrieving large amounts of data | 3,962 |
 renkun-ken/piper | Provides functions and methods to chain operations in R, enhancing readability and maintainability of data pipelines. | 169 |
 nerevu/riko | A Python library for analyzing and processing streams of structured data | 1,605 |
 raine/ramda-cli | A tool for composing functions into data-processing pipelines to produce desired output. | 573 |
 nazar256/parapipe | A library that provides a concurrent, non-blocking buffered pipeline for structuring and scaling applications. | 33 |
 thephpleague/pipeline | Provides a flexible pipeline pattern implementation to compose sequential stages and process payloads in a composable manner. | 965 |
 skner/iasi-pipe | A data pipeline framework for processing Ion Torrent sequencing data | 2 |
 destel/rill | A toolkit that simplifies concurrency in Go by providing a composable and clean way to handle channels and errors. | 1,440 |
 substantic/rain | A framework for processing large-scale task-based pipelines in a distributed manner | 749 |
 sizovs/pipelinr | A command processing pipeline framework for handling requests and responses in Java applications | 429 |
 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 |
 calebwin/pipelines | A language and runtime for crafting massively parallel data pipelines | 375 |
 p12ngh/pipelinedsl | A Haskell-based DSL for describing hardware pipelines | 1 |
 bakins/lua-resty-riak | A Lua client driver for the Riak distributed database | 25 |
 priestjim/gen_rpc | A scalable RPC library for Erlang-based languages | 224 |