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

//! Sinks for writing data from a Malstrom job
mod stateful;
mod stateless;
mod stdout;
mod vec_sink;
pub use stateful::{StatefulSink, StatefulSinkImpl, StatefulSinkPartition};
pub use stateless::{StatelessSink, StatelessSinkImpl};
pub use stdout::StdOutSink;
pub use vec_sink::VecSink;