process_mining 0.5.5

Process Mining library for working with (object-centric) event data
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 std::{collections::HashSet, env::args, path::PathBuf};

use process_mining::{Exportable, Importable, OCEL};
use std::error::Error;

pub fn main() -> Result<(), Box<dyn Error>> {
    let path_opt = args().nth(1);
    if let Some(mut path) = path_opt.map(PathBuf::from) {
        let mut ocel = OCEL::import_from_path(&path)?;
        // Including invalid E2O relations (i.e., to objects that do not exist) can cause corrupted or incomplete SQL exports
        // Thus, we filter the E2O relations to only keep valid ones
        let all_obj_ids: HashSet<_> = ocel.objects.iter().map(|o| &o.id).collect();
        for e in &mut ocel.events {
            e.relationships
                .retain(|r| all_obj_ids.contains(&r.object_id));
        }
        // Export
        path.set_file_name(format!(
            "{}.duckdb",
            path.file_name()
                .and_then(|p| p.to_str())
                .unwrap_or_default()
        ));
        ocel.export_to_path(&path)?;
    }
    Ok(())
}