fluxus_runtime/
lib.rs

1//! Fluxus Runtime - Execution engine for stream processing
2//!
3//! This module implements the runtime execution environment for Fluxus pipelines.
4mod runtime;
5pub use runtime::RuntimeContext;
6
7/// State management for stateful operators
8pub mod state;
9
10/// Watermark tracking and propagation
11pub mod watermark;