Stream Ops is a fully embeddable data streaming engine and stream processing API for Java.
Repository Index
47,133 repositories indexed
457–480 of 536 · Most stars
A micro workers class that easily manages a pool of threads to optimise simultaneous jobs and jobs endings, for MicroPython (used on Pycom modules & ESP32)
- pycom
- micropython
- lopy
- wipy
Apache AVRO for go
- avro
- go
- golang
- apache
A library to build and execute typed scientific workflows
☝️ go-graphql subscription over Kafka/Redis/NSQ example
Ordered-concurrently a library for concurrent processing with ordered output in Go. Process work concurrently and returns output in a channel in the order of input. It is useful in concurrently processing items in a queue, and get output in the order provided by the queue.
- concurrent
- golang
- golang-library
- data-science
A simple embeddable scripting language which supports concurrent event processing.
- interpreter
- language
- embeddable-scripting-language
- object-oriented-programming
Window-Based Hybrid CPU/GPU Stream Processing Engine
- stream-processing
- hybrid
- multicore
- gpu
Algorand's data pipeline framework.
Functional Programming for EcmaScript(Javascript)
- functional-programming
- fp
- js
- es
Stream Processing Made Easy
- machine-learning
- reactive-programming
- kafka
- reactive-systems
Use AWS CDK with CodePipeline to deploy a TypeScript Create-React-App.
- aws-cdk
- aws-codepipeline
- cra-pipeline
- react
hypermatch is a high-performance ⚡ Go library designed for rapid matching of a large number of rules to events. It processes thousands of events per second 🚀 against extensive rule sets in-memory with minimal latency ⏱️.
- go
- golang
- matching
- matching-engine
A queue-interop compatible Queueing library
- cakephp
- queue
- queueing
- cakephp-plugin
Reverse ETL for the code-first data stack
- bigquery
- cli
- data-engineering
- dbt
EtlKit is a lightweight ETL (extract · transform · load) library and data integration toolbox for .NET. Build your own data pipelines programmatically in C# — readable, testable, and tracked in source control like the rest of your code.
- dotnet
- dotnet-core
- etl
- etl-framework
Queue data structure for Elixir-lang
- hex
- elixir
- queue
- data-structure
A JMeter plug-in that enables you to send test results to a Kafka server
Develop streaming applications for IBM Streams in Python, Java & Scala.
- ibm-streams
- java
- scala
- python
BeanQueue, a lightweight Python task queue framework based on SQLAlchemy, PostgreSQL SKIP LOCKED queries and NOTIFY / LISTEN statements.
.NET framework for DDD, CQRS and Event Sourcing.
- cqrs
- event-sourcing
- ddd
- mediator
Various examples of notebooks for working with web archives with the Archives Unleashed Toolkit, and derivatives generated by the Archives Unleashed Toolkit.
- notebooks
- pyspark-notebook
- juypter-notebook
- spark
A library for scheduling when to dispatch a message to a channel
Powerful pipes for TypeScript, that chain Promise and ADT for you 🚌 -> ⛰️ -> 🚠 -> 🏂 -> 🚀
- pipe
- pipeline
- kleisli
- ramda