fluxus-api 0.2.0

High-level API for Fluxus stream processing engine
Documentation
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
mod filter;
mod flat_map;
mod map;
mod window_aggregator;
mod window_skipper;
mod window_sorter;

pub use filter::FilterOperator;
pub use flat_map::FlatMapOperator;
pub use map::MapOperator;
pub use window_aggregator::WindowAggregator;
pub use window_skipper::WindowSkipper;
pub use window_sorter::SortOrder;
pub use window_sorter::WindowSorter;
pub use window_sorter::WindowTimestampSorter;