dataflow 0.4.0

Dataflow is a data processing library, primarily for machine learning.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use rand::{rngs::StdRng, seq::SliceRandom, SeedableRng};

use crate::pipeline::Node;
use std::marker::PhantomData;

pub struct Shuffle<T> {
    rng: StdRng,
    _phantom: PhantomData<T>,
}

impl<T> Default for Shuffle<T> {
    fn default() -> Self {
        Self {
            rng: StdRng::from_entropy(),
            _phantom: Default::default(),
        }
    }
}

impl<T> Node<Vec<T>> for Shuffle<T> {
    type Output = Vec<T>;

    fn process(&mut self, mut input: Vec<T>) -> Self::Output {
        input.shuffle(&mut self.rng);
        input
    }
}