process_mining 0.6.2

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

//! Stream an OCEL file directly into a DuckDB database (consolidated schema),
//! without materializing the whole log in memory.
//!
//! Run:
//!   cargo run --example ocel_stream_to_duckdb --features ocel-duckdb -- <src.json|.xml> <out.duckdb>
//!
use process_mining::core::event_data::object_centric::ocel_sql::{
    stream_ocel_file_to_duckdb_with, DuckDbImportOptions,
};

fn main() {
    let mut args = std::env::args().skip(1);
    let src = args
        .next()
        .expect("usage: ocel_stream_to_duckdb <src.json|.xml> <out.duckdb>");
    let out = args
        .next()
        .expect("usage: ocel_stream_to_duckdb <src.json|.xml> <out.duckdb>");

    let options = DuckDbImportOptions::default();
    stream_ocel_file_to_duckdb_with(&src, &out, &options).expect("streaming import failed");
    println!("Wrote {out}");
}