topk
Stream processor
An implementation of probabilistic data structures for approximate data stream processing
Sliding-window and regular top-K sketches, based on HeavyKeeper
4 stars
0 watching
1 forks
Language: Go
last commit: about 2 months ago gogolangheavy-hittersheavy-keeperheavykeeperprobabilistic-data-structuressketchsliding-windowtop-k
Related projects:
Repository | Description | Stars |
---|---|---|
gojek/ziggurat | A framework for building stateless applications on top of Kafka stream processing | 398 |
tylertreat/boomfilters | Probabilistic data structures for processing continuous, unbounded streams | 1,595 |
reugn/go-streams | Provides a lightweight and flexible way to process data streams in Go | 1,910 |
jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
wintoncode/winton-kafka-streams | A Python implementation of Apache Kafka's Streams API for stream processing applications | 313 |
confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 125 |
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 |
maki-nage/makinage | Stream Processing Library and Framework | 39 |
edwardcapriolo/teknek-core | A software platform that enables stream processing and data integration across multiple data sources. | 8 |
gazette/core | Enables teams to build platforms mixing SQL, batch, and real-time streaming processing paradigms | 718 |
nmaquet/kasper | A lightweight library for processing Kafka topics with idempotent at-least-once semantics | 439 |
knowledgeonwebscale/streamingmassif | A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. | 9 |
beatrichartz/parallel_stream | An Elixir module that parallelizes stream operations while preserving order | 100 |
pietern/goestools | A toolset for working with signals and files from GOES satellites | 372 |