kgdata 4.0.1

Library to process dumps of knowledge graphs (Wikipedia, DBpedia, Wikidata)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use rayon::prelude::*;

use super::ParallelDataset;

#[derive(Clone)]
pub struct TakeAny<D: ParallelDataset> {
    pub base: D,
    pub n: usize,
}

impl<D> IntoParallelIterator for TakeAny<D>
where
    D: ParallelDataset,
{
    type Iter = rayon::iter::TakeAny<D::Iter>;
    type Item = D::Item;

    fn into_par_iter(self) -> Self::Iter {
        self.base.into_par_iter().take_any(self.n)
    }
}

impl<D> ParallelDataset for TakeAny<D> where D: ParallelDataset {}