Crate fluxus_runtime 

Fluxus Runtime - Execution engine for stream processing

This module implements the runtime execution environment for Fluxus pipelines.

Modules

state

State management for stateful operators

watermark

Watermark tracking and propagation

Structs

RuntimeContext

Runtime context for managing stream processing execution