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
24
25
26
27
28
29

use rayon::prelude::*;

use super::ParallelDataset;

#[derive(Clone)]
pub struct FilterOp<D: ParallelDataset, F> {
    pub base: D,
    pub op: F,
}

impl<D, F> IntoParallelIterator for FilterOp<D, F>
where
    D: ParallelDataset,
    F: (Fn(&D::Item) -> bool) + Sync + Send,
{
    type Iter = rayon::iter::Filter<D::Iter, F>;
    type Item = D::Item;

    fn into_par_iter(self) -> Self::Iter {
        self.base.into_par_iter().filter(self.op)
    }
}

impl<D, F> ParallelDataset for FilterOp<D, F>
where
    D: ParallelDataset,
    F: (Fn(&D::Item) -> bool) + Sync + Send,
{
}