Struct Matcher 

pub struct Matcher { /* private fields */ }

Available on crate feature std only.

An external matcher that performs exact or approximate matching on RDF.

Output is RDF describing the matches, rather than necessarily a subset of the input dataset. Matching rules belong to the external program; this wrapper passes JSONL lines and command-line options through. Execution uses the concurrent streaming behavior described in crate::programs.

Implementations

impl Matcher

pub fn new( program: impl AsRef<OsStr>, input: GraphInput, output: GraphOutput, options: MatcherOptions, ) -> Self

Configures a matcher without starting it.

Adds any configured --input=<format> and --output=<format> arguments, followed by options.other. The input and output values select stdin and stdout; stderr is captured for failure diagnostics. Byte input is lazily adapted into JSONL batches using GraphInput::into_jsonl.

pub async fn execute(&mut self) -> MatcherResult

Starts a child and returns its live JSONL match stream.

After successful spawning, input ownership moves into the stream, which feeds it concurrently when polled. Subsequent executions have no graph input.

Errors

Spawn failures are returned directly; input, output, wait, and exit failures are stream items. Consume the stream to completion to check process success.

impl Matcher

pub fn with_batching(self, options: BatchOptions) -> Self

Sets batching thresholds for captured JSONL output. This does not change subprocess arguments, native pipeline edges, or listing limits. The default policy is crate::BatchOptions::default.

Trait Implementations

impl Debug for Matcher

fn fmt(&self, __derive_more_f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Execute<Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>> for Matcher

type Error = ExecutorError

The implementation-specific error returned directly by execution.

fn execute<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = MatcherResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Executes the operation using its current input and configuration.

impl GraphConsumer for Matcher

impl GraphProducer for Matcher

impl Matcher<Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>> for Matcher

impl PipelineProgram for Matcher