rudof_lib 0.2.17

RDF data shapes implementation in Rust
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

use crate::{
    Result, Rudof,
    api::generation::GenerationOperations,
    formats::{DataFormat, GenerationSchemaFormat, InputSpec},
};
use std::path::PathBuf;

/// Builder for `generate_data` operation.
///
/// Provides a fluent interface for configuring optional parameters for data
/// generation (result format, seed, parallelism) and executing the operation.
pub struct GenerateDataBuilder<'a> {
    rudof: &'a Rudof,
    schema: &'a InputSpec,
    schema_format: &'a GenerationSchemaFormat,
    output: Option<&'a PathBuf>,
    config_file: Option<&'a PathBuf>,
    result_generation_format: Option<&'a DataFormat>,
    number_entities: usize,
    seed: Option<u64>,
    parallel: Option<usize>,
}

impl<'a> GenerateDataBuilder<'a> {
    /// Create a new builder.
    ///
    /// Internal helper called by `Rudof::generate_data()`; not intended for
    /// direct public construction.
    pub(crate) fn new(
        rudof: &'a Rudof,
        schema: &'a InputSpec,
        schema_format: &'a GenerationSchemaFormat,
        number_entities: usize,
    ) -> Self {
        Self {
            rudof,
            schema,
            schema_format,
            result_generation_format: None,
            number_entities,
            seed: None,
            parallel: None,
            output: None,
            config_file: None,
        }
    }

    /// Set the desired output data format for the generated RDF.
    pub fn with_result_generation_format(mut self, result_generation_format: &'a DataFormat) -> Self {
        self.result_generation_format = Some(result_generation_format);
        self
    }

    /// Set an explicit random seed for reproducible generation.
    pub fn with_seed(mut self, seed: u64) -> Self {
        self.seed = Some(seed);
        self
    }

    /// Set number of parallel worker threads to use.
    pub fn with_parallel(mut self, parallel: usize) -> Self {
        self.parallel = Some(parallel);
        self
    }

    /// Set an optional output file path to write the generated RDF data.
    pub fn with_output(mut self, output: &'a PathBuf) -> Self {
        self.output = Some(output);
        self
    }

    /// Execute data generation with the configured parameters.
    pub async fn execute(self) -> Result<()> {
        <Rudof as GenerationOperations>::generate_data(
            self.rudof,
            self.schema,
            self.schema_format,
            self.result_generation_format,
            self.output,
            self.config_file,
            self.number_entities,
            self.seed,
            self.parallel,
        )
        .await
    }
}