Struct Adapter 

pub struct Adapter { /* private fields */ }

Available on crate feature std only.

An external adapter that proxies an RDF dataset using SPARQL queries.

The SPARQL query is passed to stdin as bytes, relying on the pattern’s default query-file argument of -. The external program evaluates the query and emits RDF as JSONL lines. Execution uses the concurrent streaming and stream-handling behavior described in crate::programs.

Implementations

impl Adapter

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

Configures an adapter without starting it.

Adds --output=<format> when options.output is set, followed by options.other. The input and output values select stdin and stdout; stderr is captured for failure diagnostics.

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

Starts a child and returns its live JSONL graph stream.

After successful spawning, input ownership moves into the stream, which feeds it concurrently when polled. Subsequent executions have no query 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 Adapter

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 Adapter<Pin<Box<dyn Stream<Item = Result<JsonlBatch, ExecutorError>> + Send>>> for Adapter

impl Debug for Adapter

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 Adapter

type Error = ExecutorError

The implementation-specific error returned directly by execution.

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

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

Executes the operation using its current input and configuration.

impl GraphProducer for Adapter

impl PipelineProgram for Adapter