1 Repo
Operations that modify event data through rate calculation, linear prediction, and event coalescing.
Distinct from Event Stream Filtering: Distinct from Event Stream Filtering: covers active data transformation and computation rather than just selecting events based on predicates.
Explore 1 awesome GitHub repository matching data & databases · Stream Transformations. Refine with filters or upvote what's useful.
Riemann is a Clojure-based event stream processor and real-time analytics engine. It functions as a network telemetry pipeline and extensible event router that ingests, transforms, and routes event data from distributed systems. The system uses a domain-specific language to compute metrics and statistical patterns over continuous streams, enabling network trend analysis and real-time alerting. It supports dynamic plugin loading from the classpath and allows for live configuration reloading without interrupting active event streams. Capabilities include centralized telemetry aggregation, even
Transforms event streams using complex operations including linear prediction, rate calculation, and event coalescing.