malstrom 0.1.0

Malstrom is a distributed, stateful stream processing framework written in Rust.
Documentation 
1
2
3
4
5
6
7
8
9

//! Streams are logical orders of operations. A Stream can be seen as a series of nodes and edges
//! in the computation graph
mod builder;
mod operator;

pub use builder::StreamBuilder;
pub use operator::{BuildContext, Logic, LogicWrapper, OperatorBuilder, OperatorContext};

pub(super) use operator::{AppendableOperator, BuildableOperator, RunnableOperator};