{"repo":"fluxus-labs/fluxus","free":true,"listed":false,"github":"https://github.com/fluxus-labs/fluxus","clone":"git clone https://github.com/fluxus-labs/fluxus.git","description":"Fluxus Stream Processing Engine","language":"Rust","stars":169,"topics":["fluxus","fluxus-sink","fluxus-source","analytics","async","data-processing","real-time","stream-processing"],"license":"Apache-2.0","category":"data-pipelines","readme_excerpt":"Fluxus Stream Processing Engine Fluxus is a lightweight stream processing engine written in Rust, designed for efficient real-time data processing and analysis. Features - High-performance stream processing - Flexible windowing operations (Tumbling, Sliding, Session windows) - Parallel processing support - Rich set of stream operations (map, filter, aggregate) - Type-safe API - Easy to use and extend Project Structure - crates/fluxus - Main crate containing the Fluxus engine and its dependencies - crates/fluxus-api - Core API definitions and interfaces - crates/fluxus-core - Core implementations and data structures - crates/fluxus-runtime - Runtime engine and execution environment - crates/fluxus-sinks - Sink implementations for different data sinks (e.g., Kafka, Console) - crates/fluxus-sources - Source implementations for different data sources (e.g., Kafka, Console) - crates/fluxus-transforms - Transformations for stream processing (e.g., map, filter, aggregate) - crates/fluxus-utils - Utility functions and helpers - examples - Example applications demonstrating usage Examples The project includes several example applications that demonstrate different use cases: Word Count Simple word frequency analysis in text streams using tumbling windows. Temperature Sensor Analysis Processing and analyzing temperature sensor data with sliding windows. Click Stream Analysis Analyzing user click streams with session windows. Network Log Analysis Processing network logs with sliding win","default_branch":null,"files":null,"tree":[],"storefront":"/r/fluxus-labs","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/fluxus-labs/fluxus/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}