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
10
11
12
13
14
15
16
17
18
19
20

use std::fmt::Debug;

use super::StatelessSinkImpl;

/// Sink which prints all records to StdOut. This is only meant for testing and debugging.
pub struct StdOutSink;

impl<K, V, T> StatelessSinkImpl<K, V, T> for StdOutSink
where
    K: Debug,
    V: Debug,
    T: Debug,
{
    fn sink(&mut self, msg: crate::types::DataMessage<K, V, T>) {
        println!(
            "{{ key: {:?}, value: {:?}, timestamp: {:?} }}",
            msg.key, msg.value, msg.timestamp
        )
    }
}