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

Dependencies

• Core API definitions and interfaces

  cargo add fluxus-api
  

• Core implementations and data structures

  cargo add fluxus-core
  

• Runtime engine and execution environment

  cargo add fluxus-runtime
  

github: https://github.com/lispking/fluxus