Skip to main content

Crate oxirs_arq

Crate oxirs_arq 

Source
Expand description

§OxiRS ARQ - SPARQL Query Engine

Version docs.rs

Status: Production Release (v0.3.1) Stability: Public APIs are stable. Production-ready with comprehensive testing.

Advanced SPARQL 1.1/1.2 query engine with optimization, federation support, and custom functions. Provides Jena ARQ-style SPARQL algebra with modern Rust performance.

§Features

  • SPARQL 1.1 Query - Complete SPARQL 1.1 query support
  • Query Optimization - Cost-based optimization and join reordering
  • Parallel Execution - Multi-threaded query processing
  • Custom Functions - Extensible function framework
  • Federation Support - Basic federated query capabilities
  • Result Streaming - Memory-efficient result iteration

§Quick Start

use oxirs_core::query::QueryEngine;
use oxirs_core::RdfStore;

let engine = QueryEngine::new();
let store = RdfStore::new()?;

let sparql = "SELECT ?s ?p ?o WHERE { ?s ?p ?o } LIMIT 10";
let results = engine.query(sparql, &store)?;

§See Also

Re-exports§

pub use gql::GqlToSparqlTranslator;
pub use gql::GqlTranslateError;
pub use generate::parse_generate;
pub use generate::GenerateError;
pub use generate::GenerateExecutor;
pub use generate::GenerateResult;
pub use text_search::register_text_query;
pub use text_search::TextQueryPropertyFunction;
pub use text_search::TextSearchError;
pub use text_search::TextSearchIndex;
pub use text_search::TextSearchResult;
pub use execution::ParallelBgpEvaluator;
pub use execution::PatternDependencyGraph;
pub use execution::TripleStore;
pub use optimizer::adaptive::AdaptiveJoinOrderOptimizer;
pub use optimizer::adaptive::AdaptiveStatsStore;
pub use optimizer::adaptive::JoinAlgorithm;
pub use optimizer::adaptive::JoinPlanNode;
pub use optimizer::adaptive::PatternTerm;
pub use optimizer::adaptive::PlanTimer;
pub use optimizer::adaptive::RuntimeStats;
pub use optimizer::adaptive::TriplePatternInfo;
pub use optimizer::materialized_view::BindingRow;
pub use optimizer::materialized_view::MaterializedView;
pub use optimizer::materialized_view::MaterializedViewManager;
pub use optimizer::materialized_view::RdfTerm;
pub use optimizer::materialized_view::ViewManagerConfig;
pub use optimizer::materialized_view::ViewManagerStats;
pub use optimizer::join_order::AdaptiveQueryPlan;
pub use optimizer::join_order::CardinalityEstimate;
pub use optimizer::join_order::JoinGraphStats;
pub use optimizer::join_order::JoinOrderOptimizer;
pub use optimizer::join_order::PatternCost;
pub use optimizer::view_registry::algebra_hash;
pub use optimizer::view_registry::BindingSet;
pub use optimizer::view_registry::ViewDefinition;
pub use optimizer::view_registry::ViewRegistry;
pub use executor_pipeline::BindingMap;
pub use executor_pipeline::ParallelPipelineStage;
pub use executor_pipeline::UnionParallelExecutor;
pub use query_cache_lru::CacheEntry;
pub use query_cache_lru::CacheFingerprint;
pub use query_cache_lru::CacheManagerStats;
pub use query_cache_lru::CompiledQueryCache;
pub use query_cache_lru::LruQueryCache;
pub use query_cache_lru::QueryCacheManager;
pub use aggregates_ext::Accumulator;
pub use aggregates_ext::AggregateFactory;
pub use aggregates_ext::AggregateMetadata;
pub use aggregates_ext::AggregateOptimization;
pub use aggregates_ext::AggregateRegistry;
pub use aggregates_ext::MemoryUsage;
pub use algebra::Aggregate;
pub use algebra::Algebra;
pub use algebra::BinaryOperator;
pub use algebra::Binding;
pub use algebra::Expression;
pub use algebra::GroupCondition;
pub use algebra::Iri;
pub use algebra::Literal;
pub use algebra::OrderCondition;
pub use algebra::Solution;
pub use algebra::Term;
pub use algebra::TriplePattern;
pub use algebra::UnaryOperator;
pub use debug_utilities::DebugBreakpoint;
pub use debug_utilities::DebugConfig;
pub use debug_utilities::DebugReport;
pub use debug_utilities::ExecutionState as DebugExecutionState;
pub use debug_utilities::JoinType;
pub use debug_utilities::Operation;
pub use debug_utilities::QueryDebugger;
pub use debug_utilities::RewriteStep;
pub use debug_utilities::TraceEntry;
pub use debug_utilities::VariableBinding;
pub use debug_utilities::VisualizationFormat;
pub use executor::Dataset;
pub use executor::ExecutionContext;
pub use executor::InMemoryDataset;
pub use executor::ParallelConfig;
pub use executor::QueryExecutor;
pub use graphql_translator::GraphQLDirective;
pub use graphql_translator::GraphQLDocument;
pub use graphql_translator::GraphQLField;
pub use graphql_translator::GraphQLFragment;
pub use graphql_translator::GraphQLOperation;
pub use graphql_translator::GraphQLOperationType;
pub use graphql_translator::GraphQLSelection;
pub use graphql_translator::GraphQLTranslator;
pub use graphql_translator::GraphQLValue;
pub use graphql_translator::GraphQLVariableDefinition;
pub use graphql_translator::SchemaMapping;
pub use graphql_translator::TranslationError;
pub use graphql_translator::TranslationResult;
pub use graphql_translator::TranslationStats;
pub use graphql_translator::TranslatorConfig;
pub use jit_compiler::CompiledQuery;
pub use jit_compiler::CompilerStats;
pub use jit_compiler::ExecutionPlan;
pub use jit_compiler::ExecutionStats;
pub use jit_compiler::FilterType;
pub use jit_compiler::JitCompilerConfig;
pub use jit_compiler::JitJoinStrategy;
pub use jit_compiler::PatternType;
pub use jit_compiler::PlanOperation;
pub use jit_compiler::QueryJitCompiler;
pub use jit_compiler::QueryMetadata;
pub use jit_compiler::Specialization;
pub use jit_compiler::SpecializationType;
pub use path_extensions::BidirectionalPathSearch;
pub use path_extensions::CacheStats;
pub use path_extensions::CachedPathEvaluator;
pub use path_extensions::CostBasedPathOptimizer;
pub use path_extensions::PathAnalyzer;
pub use path_extensions::PathCache;
pub use path_extensions::PathComplexity;
pub use path_extensions::PathEvaluationStrategy;
pub use path_extensions::PathOptimizationConfig;
pub use path_extensions::PathOptimizationHint;
pub use path_extensions::PathStatistics;
pub use path_extensions::ReachabilityIndex;
pub use path_extensions::StrategyCostEstimate;
pub use procedures::Procedure;
pub use procedures::ProcedureArgs;
pub use procedures::ProcedureContext;
pub use procedures::ProcedureFactory;
pub use procedures::ProcedureRegistry;
pub use procedures::ProcedureResult;
pub use property_functions::PropFuncArg;
pub use property_functions::PropertyFunction;
pub use property_functions::PropertyFunctionContext;
pub use property_functions::PropertyFunctionRegistry;
pub use property_functions::PropertyFunctionResult;
pub use query_builder::AskBuilder;
pub use query_builder::ConstructBuilder;
pub use query_builder::DescribeBuilder;
pub use query_builder::SelectBuilder;
pub use query_plan_cache::CacheStats as QueryPlanCacheStats;
pub use query_plan_cache::CachedPlan;
pub use query_plan_cache::CachingConfig;
pub use query_plan_cache::QueryPlanCache;
pub use query_plan_cache::QuerySignature;
pub use query_plan_cache::StatisticsSnapshot;
pub use query_profiler::AverageStats;
pub use query_profiler::QueryPhase;
pub use query_profiler::QueryProfiler;
pub use query_profiler::QueryStats;
pub use query_validator::QueryValidator;
pub use query_validator::ValidationConfig;
pub use query_validator::ValidationResult;
pub use query_validator::ValidationStatistics;
pub use query_validator::ValidationWarning;
pub use query_validator::ValidationWarningType;
pub use result_formats::BinaryResultSerializer;
pub use result_formats::CustomFormatSerializer;
pub use result_formats::FormatConverter;
pub use result_formats::FormatRegistry;
pub use result_formats::StreamingResultIterator;
pub use result_formats::XmlResultSerializer;
pub use results::QueryResult;
pub use results::ResultFormat;
pub use results::ResultSerializer;
pub use scirs_optimize_integration::OptimizationResult;
pub use scirs_optimize_integration::PerformanceAnalysis;
pub use scirs_optimize_integration::QueryInfo;
pub use scirs_optimize_integration::QueryOptimizationConfig;
pub use scirs_optimize_integration::SciRS2QueryOptimizer;
pub use service_description::create_default_service_description;
pub use service_description::AggregateInfo;
pub use service_description::DatasetDescription;
pub use service_description::ExtensionFunction;
pub use service_description::Feature;
pub use service_description::LanguageExtension;
pub use service_description::NamedGraphDescription;
pub use service_description::ParameterInfo;
pub use service_description::ProcedureInfo;
pub use service_description::PropertyFunctionInfo;
pub use service_description::ServiceDescription;
pub use service_description::ServiceDescriptionBuilder;
pub use service_description::ServiceDescriptionRegistry;
pub use service_description::ServiceLimitations;
pub use string_functions_ext::StrAfterFunction;
pub use string_functions_ext::StrBeforeFunction;
pub use string_functions_ext::StrDtFunction;
pub use string_functions_ext::StrLangDirFunction;
pub use string_functions_ext::StrLangFunction;
pub use triple_functions::IsTripleFunction;
pub use triple_functions::ObjectFunction;
pub use triple_functions::PredicateFunction;
pub use triple_functions::SubjectFunction;
pub use triple_functions::TripleFunction;
pub use values_support::IndexedValues;
pub use values_support::JoinStrategy;
pub use values_support::OptimizedValues;
pub use values_support::ValuesBuilder;
pub use values_support::ValuesClause;
pub use values_support::ValuesExecutionStrategy;
pub use values_support::ValuesExecutor;
pub use values_support::ValuesJoinOptimizer;
pub use values_support::ValuesOptimizer;
pub use values_support::ValuesStatistics;
pub use lateral_join::LateralCostEstimate;
pub use lateral_join::LateralJoin;
pub use lateral_join::LateralJoinConfig;
pub use lateral_join::LateralJoinError;
pub use lateral_join::LateralJoinExecutor;
pub use lateral_join::LateralJoinStats;
pub use lateral_join::LateralOptimizer;
pub use lateral_join::LateralOptimizerConfig;
pub use lateral_join::LateralParser;
pub use lateral_join::LateralStrategy;
pub use lateral_join::LateralSubquery;
pub use lateral_join::LateralValidationResult;
pub use lateral_join::LateralValidator;
pub use lateral_join::LateralValue;
pub use lateral_join::OrderSpec;
pub use lateral_join::SolutionMapping;
pub use adaptive_index_advisor::AccessPattern;
pub use adaptive_index_advisor::AdvisorConfig;
pub use adaptive_index_advisor::AdvisorStatistics;
pub use adaptive_index_advisor::AnalysisSummary;
pub use adaptive_index_advisor::IndexAdvisor;
pub use adaptive_index_advisor::IndexAnalysisReport;
pub use adaptive_index_advisor::IndexConfiguration;
pub use adaptive_index_advisor::IndexRecommendation;
pub use adaptive_index_advisor::IndexType;
pub use adaptive_index_advisor::IndexUsageStats;
pub use adaptive_index_advisor::PatternComponent;
pub use adaptive_index_advisor::QueryPattern;
pub use adaptive_index_advisor::RecommendationPriority;
pub use cost_model_calibration::CalibrationConfig;
pub use cost_model_calibration::CalibrationExport;
pub use cost_model_calibration::CalibrationReport;
pub use cost_model_calibration::CalibratorStatistics;
pub use cost_model_calibration::CostModelCalibrator;
pub use cost_model_calibration::CostModelParameters;
pub use cost_model_calibration::ExecutionSample;
pub use cost_model_calibration::OperationCalibrationExport;
pub use cost_model_calibration::OperationCalibrationStats;
pub use cost_model_calibration::OperationSummary;
pub use cost_model_calibration::OperationType;
pub use federation::EndpointCapabilities;
pub use federation::EndpointCriteria;
pub use federation::EndpointDiscovery;
pub use federation::EndpointHealth;
pub use federation::FederatedSubquery;
pub use federation::FederationConfig;
pub use federation::FederationExecutor;
pub use federation::FederationStats;
pub use federation::LoadBalancingStrategy;
pub use gpu_accelerated_ops::DeviceSelection;
pub use gpu_accelerated_ops::GpuConfig;
pub use gpu_accelerated_ops::GpuOperationStats;
pub use gpu_accelerated_ops::GpuQueryEngine;
pub use interactive_query_builder::helpers as query_helpers;
pub use interactive_query_builder::InteractiveQueryBuilder;
pub use interactive_query_builder::PatternBuilder;
pub use interactive_query_builder::QueryType;
pub use materialization::MaterializationAnalysis;
pub use materialization::MaterializationConfig;
pub use materialization::MaterializationSelector;
pub use materialization::MaterializationStats;
pub use materialization::MaterializationStrategy;
pub use materialization::MaterializedResults;
pub use materialization::ResultIterator;
pub use materialization::VariableStats;
pub use production::AuditEventType;
pub use production::BaselineTrackerConfig;
pub use production::CostEstimatorConfig;
pub use production::CostEstimatorStatistics;
pub use production::CostRecommendation;
pub use production::ErrorSeverity;
pub use production::GlobalStatistics;
pub use production::HealthStatus;
pub use production::MemoryStats;
pub use production::PerformanceBaselineTracker;
pub use production::PerformanceTrend;
pub use production::PrioritizedQuery;
pub use production::PrioritySchedulerConfig;
pub use production::PrioritySchedulerStats;
pub use production::QueryAuditEvent;
pub use production::QueryAuditTrail;
pub use production::QueryCancellationToken;
pub use production::QueryCircuitBreaker;
pub use production::QueryCostEstimate;
pub use production::QueryCostEstimator;
pub use production::QueryEngineHealth;
pub use production::QueryErrorContext;
pub use production::QueryFeatures;
pub use production::QueryMemoryTracker;
pub use production::QueryPriority;
pub use production::QueryPriorityScheduler;
pub use production::QueryRateLimiter;
pub use production::QueryResourceQuota;
pub use production::QuerySession;
pub use production::QuerySessionManager;
pub use production::QueryStatistics;
pub use production::QueryTimeoutManager;
pub use production::QueryTimeoutState;
pub use production::RegressionReport;
pub use production::RegressionSeverity;
pub use production::SparqlPerformanceMonitor;
pub use production::SparqlProductionError;
pub use production::TimeoutAction;
pub use production::TimeoutCheckResult;
pub use query_execution_history::ExecutionMetrics;
pub use query_execution_history::ExecutionRecord;
pub use query_execution_history::ExecutionStatus;
pub use query_execution_history::FormDistribution;
pub use query_execution_history::HistoryAnalysis;
pub use query_execution_history::HistoryConfig;
pub use query_execution_history::HistoryStatistics;
pub use query_execution_history::PeriodStatistics;
pub use query_execution_history::QueryExecutionHistory;
pub use query_execution_history::QueryFormType;
pub use query_execution_history::QueryGroupStats;
pub use query_execution_history::SlowQueryEntry;
pub use query_fingerprinting::FingerprintConfig;
pub use query_fingerprinting::FingerprintingStatistics;
pub use query_fingerprinting::HashAlgorithm;
pub use query_fingerprinting::ParameterSlot;
pub use query_fingerprinting::ParameterType;
pub use query_fingerprinting::QueryFeatures as FingerprintQueryFeatures;
pub use query_fingerprinting::QueryFingerprint;
pub use query_fingerprinting::QueryFingerprinter;
pub use query_fingerprinting::QueryForm as FingerprintQueryForm;
pub use query_hints::CacheHint;
pub use query_hints::CardinalityHint;
pub use query_hints::FilterHint;
pub use query_hints::FilterPushdownDirective;
pub use query_hints::HintApplicationResult;
pub use query_hints::HintParser;
pub use query_hints::HintParserStats;
pub use query_hints::HintValidationWarning;
pub use query_hints::HintValidator;
pub use query_hints::IndexDirective;
pub use query_hints::IndexHint;
pub use query_hints::JoinAlgorithmHint;
pub use query_hints::JoinBuildSide;
pub use query_hints::JoinHint;
pub use query_hints::JoinOrderHint;
pub use query_hints::JoinOrderStrategy;
pub use query_hints::MaterializationHint;
pub use query_hints::MaterializationStrategy as HintMaterializationStrategy;
pub use query_hints::MemoryHint;
pub use query_hints::ParallelismHint;
pub use query_hints::QueryHints;
pub use query_hints::QueryHintsBuilder;
pub use query_hints::WarningSeverity;
pub use query_plan_export::CostEstimate;
pub use query_plan_export::ExecutionStats as PlanExecutionStats;
pub use query_plan_export::ExportConfig;
pub use query_plan_export::ExportError;
pub use query_plan_export::ExportFormat;
pub use query_plan_export::ExporterStats;
pub use query_plan_export::OperatorType;
pub use query_plan_export::PlanNode;
pub use query_plan_export::QueryPlanExporter;
pub use query_regression_testing::ExecutionResult as RegressionExecutionResult;
pub use query_regression_testing::ExecutionStatistics as RegressionExecutionStats;
pub use query_regression_testing::GoldenQuery;
pub use query_regression_testing::QueryRegressionAnalysis;
pub use query_regression_testing::RegressionConfig;
pub use query_regression_testing::RegressionReport as QueryRegressionReport;
pub use query_regression_testing::RegressionStatus;
pub use query_regression_testing::RegressionTestSuite;
pub use query_regression_testing::RegressionTestSuiteBuilder;
pub use query_regression_testing::ReportComparison;
pub use query_regression_testing::ReportSummary;
pub use query_regression_testing::SuiteExport;
pub use query_regression_testing::SuiteStatistics;
pub use query_result_cache::CacheConfig as ResultCacheConfig;
pub use query_result_cache::CacheStatistics as ResultCacheStatistics;
pub use query_result_cache::QueryResultCache;
pub use query_result_cache::QueryResultCacheBuilder;
pub use cache::CacheCoordinator;
pub use cache::CacheLevel;
pub use cache::DependencyGraph;
pub use cache::InvalidationConfig;
pub use cache::InvalidationEngine;
pub use cache::InvalidationStatistics;
pub use cache::InvalidationStrategy;
pub use cache::RdfUpdateListener;
pub use simd_query_ops::ComparisonOp;
pub use simd_query_ops::JoinStats;
pub use simd_query_ops::SimdAggregations;
pub use simd_query_ops::SimdConfig;
pub use simd_query_ops::SimdFilterEvaluator;
pub use simd_query_ops::SimdHashJoin;
pub use simd_query_ops::SimdStringOps;
pub use simd_query_ops::SimdTripleMatcher;
pub use simd_query_ops::TripleCandidate;
pub use websocket_streaming::ConnectionStats;
pub use websocket_streaming::ManagerStats;
pub use websocket_streaming::WebSocketConfig;
pub use websocket_streaming::WebSocketManager;
pub use websocket_streaming::WebSocketMessage;
pub use websocket_streaming::WebSocketSession;
pub use star_integration::pattern_matching;
pub use star_integration::sparql_star_functions;
pub use star_integration::star_statistics::SparqlStarStatistics;
pub use star_integration::SparqlStarExecutor;
pub use explain::ExplainFormat;
pub use explain::IndexType as ExplainIndexType;
pub use explain::PlanNode as ExplainPlanNode;
pub use explain::QueryExplainer;
pub use explain::QueryExplainerBuilder;
pub use explain::QueryPlan as QueryExplainPlan;
pub use rdf_star::bind_pattern;
pub use rdf_star::instantiate_quoted_triple;
pub use rdf_star::sparql_star_builtins;
pub use rdf_star::AnnotatedTriple;
pub use rdf_star::Annotation;
pub use rdf_star::QuotedTriple;
pub use rdf_star::RdfStarStore;
pub use rdf_star::StarBinding;
pub use rdf_star::StarObject;
pub use rdf_star::StarOperator;
pub use rdf_star::StarPattern;
pub use rdf_star::StarPredicate;
pub use rdf_star::StarSubject;
pub use analytics::is_dag;
pub use analytics::is_reachable;
pub use analytics::BetweennessCentrality;
pub use analytics::ConnectedComponents;
pub use analytics::DegreeCentrality;
pub use analytics::EdgeWeight;
pub use analytics::GraphStats;
pub use analytics::GraphStatsSummary;
pub use analytics::LouvainCommunities;
pub use analytics::NodeId;
pub use analytics::PageRank;
pub use analytics::RdfGraphAdapter;
pub use analytics::ShortestPaths;
pub use update_graph_management::GraphManagementDataset;
pub use update_graph_management::GraphManagementExecutor;
pub use update_graph_management::GraphManagementOp;
pub use update_graph_management::GraphManagementResult;
pub use update_graph_management::GraphManagementTarget;
pub use update_graph_management::Triple as GraphManagementTriple;
pub use stats::PatternStats;
pub use stats::QueryExecutionStats;
pub use stats::RuntimeStatsCollector;
pub use update_protocol::ArqError as UpdateArqError;
pub use update_protocol::ClearType;
pub use update_protocol::DropType;
pub use update_protocol::ParseError as UpdateParseError;
pub use update_protocol::PatternTerm as UpdatePatternTerm;
pub use update_protocol::SparqlUpdate;
pub use update_protocol::SparqlUpdateParser;
pub use update_protocol::Triple as UpdateTriple;
pub use update_protocol::TriplePattern as UpdateTriplePattern;
pub use update_protocol::UpdateExecutor as SparqlUpdateExecutor;
pub use update_protocol::UpdateResult as SparqlUpdateResult;
pub use optimizer::ConstantFoldingPass;
pub use optimizer::OptimizationPass;
pub use optimizer::OptimizationPipeline;
pub use optimizer::PipelineResult;
pub use optimizer::RedundantJoinEliminationPass;
pub use optimizer::UnusedVariableEliminationPass;
pub use jena_parity::generate_jena_report;
pub use jena_parity::load_catalog;
pub use jena_parity::JenaCategory;
pub use jena_parity::JenaEntry;
pub use jena_parity::JenaParityMatrix;
pub use jena_parity::JenaStatus;
pub use jit::AggVarMap;
pub use jit::BinOp;
pub use jit::BuiltinFunc;
pub use jit::CompiledDistinct;
pub use jit::CompiledFilter;
pub use jit::CompiledJoinKey;
pub use jit::CompiledOrder;
pub use jit::CompiledProject;
pub use jit::DistinctCompiler;
pub use jit::DistinctCompilerError;
pub use jit::DistinctKeySpec;
pub use jit::FilterCompiler;
pub use jit::FilterCompilerError;
pub use jit::FilterExpr;
pub use jit::HavingCompiler;
pub use jit::JitFilterCache;
pub use jit::JoinCompiler;
pub use jit::JoinCompilerError;
pub use jit::JoinKeySpec;
pub use jit::OrderCompiler;
pub use jit::OrderCompilerError;
pub use jit::OrderKeySpec;
pub use jit::ProjectCompiler;
pub use jit::ProjectCompilerError;
pub use jit::ProjectSpec;
pub use jit::VarIndexMap;
pub use path_algebra::NpsItem;
pub use path_algebra::PathAlgebraError;
pub use path_algebra::PathAlgebraEvaluator;
pub use path_algebra::PathDirection;
pub use path_algebra::PropertyPath;
pub use optimizer::federated_plan::FederatedPlanOutcome;
pub use optimizer::federated_plan::FederatedPlanner;
pub use optimizer::federated_plan::FederatedSelectivity;
pub use optimizer::federated_plan::SourceSelectivityProvider;
pub use optimizer::federated_plan::StaticSourceProvider;
pub use sla_integration::AdmittedQuery;
pub use sla_integration::ArqSlaError;
pub use sla_integration::ArqSlaGate;
pub use sla_integration::DispatchedQuery;
pub use sla_integration::SlaClassDisplay;
pub use tenant_config::TenantConfig as ArqTenantConfig;
pub use tenant_config::TenantConfigRegistry;
pub use query_governor::BudgetExceeded;
pub use query_governor::ExecutionBudget;
pub use query_governor::ResourceBudget;
pub use analytics::DegreeDirection;
pub use analytics::GraphAnalyticsAccumulator;
pub use analytics::GraphAnalyticsAggregate;
pub use analytics::GraphAnalyticsError;

Modules§

adaptive_execution
Adaptive Query Execution
adaptive_index_advisor
Adaptive Index Advisor
advanced_optimizer
Advanced Query Optimization Engine
aggregate_executor
SPARQL 1.1 Aggregate Function Executor
aggregates_ext
Extended Aggregate Functions for SPARQL
algebra
SPARQL Algebra Module
algebra_generation
Algebra Generation Module
analytics
Graph Analytics for RDF Knowledge Graphs
bgp_optimizer
Advanced BGP (Basic Graph Pattern) Optimization
bgp_optimizer_types
Type definitions for BGP optimization
buffer_management
Advanced Buffer Pool Management
builtin
Built-in SPARQL Functions — Facade
builtin_fixed
Built-in SPARQL Functions
cache
Intelligent Cache Invalidation System
cache_integration
Advanced Caching Integration for OxiRS ARQ Query Engine
cardinality_estimator
Advanced Cardinality Estimation for Query Optimization
construct_builder
cost_model
Cost Model Module
cost_model_calibration
Cost Model Calibration for Adaptive Query Optimization
debug_utilities
Debugging Utilities for SPARQL Queries
distributed
Distributed Query Processing Module
execution
Execution sub-modules for oxirs-arq
executor
Auto-generated module structure
executor_pipeline
Parallel Query Execution Pipeline
exists_evaluator
SPARQL EXISTS and NOT EXISTS evaluation.
explain
SPARQL Query Explain / Plan
expression
Expression Evaluation System for SPARQL
expression_compiler
SPARQL Expression Compiler and Evaluator with LRU Caching
expression_evaluator
extensions
Extension Framework for Custom Functions and Operators
federation
Federated SPARQL Query Execution
generate
SPARQL-Generate extension module for OxiRS ARQ.
gpu_accelerated_ops
GPU-Accelerated SPARQL Operations
gql
GQL (ISO/IEC 39075:2024) → SPARQL bridge.
graphql_translator
group_by_evaluator
integrated_query_planner
Integrated Query Planner
interactive_query_builder
Interactive SPARQL Query Builder
jena_parity
Apache Jena feature parity tracking for oxirs-arq.
jit
JIT compilation phases b, c, and d — Cranelift-based codegen for filter expressions, hash-join key comparison, ORDER BY evaluation, PROJECT column extraction, DISTINCT deduplication hashing, and HAVING clause predicates over aggregate results.
jit_compiler
JIT Compilation for SPARQL Queries
join_algorithms
Advanced Join Algorithm Selection and Execution
join_optimizer
Cost-based join reordering for SPARQL query optimization.
lateral_join
SPARQL 1.2 LATERAL Join Support
materialization
Query Result Materialization Strategies
materialized_views
Materialized Views for Query Optimization (facade).
materialized_views_manager
High-level orchestration for materialized views.
materialized_views_scheduler
Maintenance scheduling and view recommendation for materialized views.
materialized_views_storage
Storage tier and query-rewriter implementations for materialized views.
materialized_views_types
Type definitions for the materialized view subsystem.
minus_evaluator
SPARQL MINUS pattern evaluation (set-difference algebra).
optimizer
Query Optimization Module
optional_evaluator
parallel
Parallel Query Execution — facade re-exporting all parallel sub-modules.
parallel_executor
Parallel query executor, scan iterator, and work-stealing queue.
parallel_executor_engine
Parallel query executor core: thread pool, algebra dispatch, and the BGP / join / union / filter / order-by / group-by execution paths.
parallel_executor_ops
Parallel query executor operators: property paths, optional/minus joins, federation, projection, and slicing.
parallel_executor_queue
Parallel scan iterator and work-stealing queue.
parallel_planner
Parallel plan generation, partition strategies, and cost-based parallelism decisions.
parallel_types
Parallel execution types, statistics, and traits.
path
Property Path Support for SPARQL
path_algebra
path_expression
SPARQL 1.1 property path expression parser and evaluator.
path_extensions
Extended Property Path Support for SPARQL
plan_cache
Algebra-level JIT plan cache — phase a.
plan_visualizer
SPARQL Query Plan Visualizer
procedures
Stored Procedures for SPARQL
production
Auto-generated module structure
property_functions
Property Functions (Magic Predicates) for SPARQL
query
Auto-generated module structure
query_analysis
Query Analysis Module
query_batch_executor
Smart Query Batch Executor
query_builder
Query Builder API for SPARQL
query_cache_lru
LRU Query Cache
query_execution_history
Query Execution History
query_fingerprinting
Advanced Query Fingerprinting for SPARQL Query Analysis
query_governor
Runtime query resource governor for ARQ.
query_hints
Query Hints System for SPARQL Query Optimization
query_optimization_advisor
Automatic Query Optimization Advisor
query_pagination
Query Result Pagination
query_plan_cache
Query Plan Caching System
query_plan_diff
Query Plan Comparison and Diff Utilities
query_plan_export
Query Plan Export
query_profiler
SPARQL query profiling for performance analysis
query_regression_testing
Query Regression Testing Framework
query_result_cache
Query Result Caching with Fingerprint-Based Keys
query_rewriter
Advanced Query Rewriting
query_templates
SPARQL Query Template System
query_validator
Comprehensive SPARQL Query Validation
rdf_star
SPARQL-star (RDF-star) Completeness Module
result_formats
Extended Result Format Support for SPARQL
results
SPARQL Query Results Format Support
scirs_optimize_integration
SciRS2 Optimization Integration for ARQ Query Processing
service_clause
service_description
SPARQL 1.1 Service Description
simd_query_ops
SIMD-Accelerated Query Operations
sla_integration
SLA-aware admission control integration for the ARQ query executor.
star_integration
SPARQL-star Integration Module
statistics
Statistics and cardinality estimation for query optimization
statistics_collector
Advanced Statistics Collection for Query Optimization
stats
Runtime statistics collection for adaptive query feedback.
streaming
Auto-generated module structure
string_functions_ext
Enhanced String Functions for SPARQL 1.1+
subgraph_matcher
Subgraph isomorphism / pattern matching for RDF graphs.
subquery
system_load_monitor
System Load Monitoring for Adaptive Query Execution
tenant_config
Per-tenant configuration for the ARQ query executor.
term
Comprehensive Term System for SPARQL Query Processing
text_search
JenaText full-text SPARQL integration for OxiRS ARQ.
timeout
SPARQL query timeout enforcement
triple_functions
RDF-star TRIPLE Functions
update
SPARQL UPDATE Operations
update_graph_management
SPARQL 1.1 UPDATE Graph Management Operations — facade module.
update_graph_management_ops
SPARQL 1.1 UPDATE Graph Management — Operation Execution
update_graph_management_protocol
SPARQL 1.1 UPDATE Graph Management — Protocol and Request Parsing
update_graph_management_types
SPARQL 1.1 UPDATE Graph Management — Types and Data Structures
update_protocol
SPARQL 1.1 Update Protocol — standalone parser and in-memory executor (facade).
update_protocol_executor
In-memory executor for SPARQL 1.1 Update operations.
update_protocol_parser
Tokeniser and recursive-descent parser for SPARQL 1.1 Update text.
update_protocol_types
Domain types for the standalone SPARQL 1.1 Update protocol.
values_clause
values_support
VALUES Clause Support for SPARQL
vector_query_optimizer
Vector-Aware Query Optimizer
websocket_streaming
WebSocket Streaming for SPARQL Query Results
window_function

Macros§

iri
literal
path_alt
path_inv
path_opt
path_plus
path_seq
Convenience macros for building property paths
path_star
register_function
Macro for easy function registration
triple
Convenience macros for building algebra expressions
var

Structs§

Variable
Variable identifier - reuse from core A SPARQL variable

Type Aliases§

Result