Crate fluxus_api

Crate fluxus_api 

Source
Expand description

Fluxus API - High-level interface for stream processing

This module provides a user-friendly API for building stream processing applications.

Re-exports§

pub use io::CollectionSink;
pub use io::CollectionSource;
pub use stream::DataStream;
pub use stream::WindowedStream;

Modules§

io
operators
stream