Struct RdfFusionContext 

pub struct RdfFusionContext { /* private fields */ }

Represents a connection to an instance of an RDF Fusion engine.

An RDF Fusion instance consists of:

• A SessionContext. This is the primary interaction point with DataFusion.
• An RdfFusionFunctionRegistry that holds the currently registered RDF Fusion built-ins.
• A reference to a quad storage.

Implementations

impl RdfFusionContext

pub fn new( config: SessionConfig, runtime_env: Arc<RuntimeEnv>, storage: Arc<dyn QuadStorage>, ) -> RdfFusionContext

Creates a new RdfFusionContext with the default configuration and the given storage.

pub fn create_view(&self) -> RdfFusionContextView

Creates a new RdfFusionContextView on this context. The resulting view should be passed around in the RDF Fusion ecosystem to access the current configuration without directly depending on the RdfFusionContext.

pub fn session_context(&self) -> &SessionContext

Provides a reference to the SessionContext.

pub fn functions(&self) -> &Arc<dyn RdfFusionFunctionRegistry>

Returns a reference to the used RdfFusionFunctionRegistry.

pub fn encodings(&self) -> &RdfFusionEncodings

Returns a reference to the used RdfFusionEncodings.

pub fn storage(&self) -> &Arc<dyn QuadStorage>

Provides access to the QuadStorage of this instance for writing operations.

pub async fn contains( &self, quad: &QuadRef<'_>, ) -> Result<bool, DataFusionError>

Checks whether quad is contained in the instance.

pub async fn len(&self) -> Result<usize, DataFusionError>

Returns the number of quads in the instance.

pub async fn quads_for_pattern( &self, graph_name: Option<GraphNameRef<'_>>, subject: Option<NamedOrBlankNodeRef<'_>>, predicate: Option<NamedNodeRef<'_>>, object: Option<TermRef<'_>>, ) -> Result<Pin<Box<dyn RecordBatchStream<Item = Result<RecordBatch, DataFusionError>> + Send>>, DataFusionError>

Returns a stream of all quads that match the given pattern.

pub async fn execute_query( &self, query: &Query, options: QueryOptions, ) -> Result<(QueryResults, QueryExplanation), QueryEvaluationError>

Evaluates a SPARQL Query over the instance.

Trait Implementations

impl Clone for RdfFusionContext

fn clone(&self) -> RdfFusionContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.