raphtory-storage 0.17.0

Raphtory storage interface
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
30

use raphtory_api::core::entities::EID;
use raphtory_core::{
    entities::graph::tgraph_storage::GraphStorage, storage::raw_edges::EdgeRGuard,
};
use rayon::prelude::*;

#[derive(Copy, Clone, Debug)]
pub struct UnlockedEdges<'a>(pub(crate) &'a GraphStorage);

impl<'a> UnlockedEdges<'a> {
    pub fn iter(self) -> impl Iterator<Item = EdgeRGuard<'a>> + 'a {
        let storage = self.0;
        (0..storage.edges_len())
            .map(EID)
            .filter_map(|eid| storage.try_edge_entry(eid))
    }

    pub fn par_iter(self) -> impl ParallelIterator<Item = EdgeRGuard<'a>> + 'a {
        let storage = self.0;
        (0..storage.edges_len())
            .into_par_iter()
            .map(EID)
            .filter_map(|eid| storage.try_edge_entry(eid))
    }

    #[inline]
    pub fn len(self) -> usize {
        self.0.edges_len()
    }
}