ArcFlow
Company
Managed Services
Markets
  • News
  • LOG IN
  • GET STARTED

OZ brings Visual Intelligence to physical venues, a managed edge layer that lets real-world environments see, understand, and act in real time.

Talk to us

ArcFlow

  • World Models
  • Sensors

Managed Services

  • OZ VI Venue 1
  • Case Studies

Markets

  • Sports
  • Broadcasting
  • Robotics

Company

  • About
  • Technology
  • Careers
  • Contact

Ready to see it live?

Talk to the OZ team about deploying at your venues, from a single pilot match to a full regional rollout.

Schedule a deployment review

© 2026 OZ. All rights reserved.

LinkedIn
ArcFlow Docs
Start
  • Quickstart
  • Installation
  • Bindings
  • Platforms
  • Get Started
  • Cookbook
Concepts
  • World Model
  • Graph Model
  • Evidence Model
  • Observations
  • Confidence & Provenance
  • Proof Artifacts & Gates
  • SQL vs GQL
  • Graph Patterns
  • Parameters
  • Query Results
  • Persistence & WAL
  • Snapshot-Pinned Reads
  • Error Handling
  • Execution Models
  • Causal Edges
  • Adapter Discipline
  • Time Decay
  • Layers
  • 1. World Store
  • 1a. World Store · Smart Reader
  • 2. Perception Lake
  • 3. World Graph
  • 4. Query Engine
  • 5. Live Surface
  • 6. Event Bus
  • 7. Behavior Engine
  • 8. Algorithm Library
  • Virtual Computed Columns
  • Threading Model
  • Typed ID Contract
WorldCypher
  • Overview
  • Execution Options
  • Statements
  • MATCH
  • WHERE
  • RETURN
  • OPTIONAL MATCH
  • CREATE
  • SET
  • MERGE
  • DELETE
  • REMOVE
  • Composition
  • WITH
  • UNION
  • UNWIND
  • CASE
  • Schema
  • Schema Overview
  • Indexes
  • Constraints
  • Functions
  • Built-in Functions
  • Aggregations
  • Procedures
  • Shortest Path
  • EXPLAIN
  • PROFILE
  • Temporal Queriesfacet
  • Spatial Queriesfacet
  • Algorithmsfacet
  • Triggers
Capabilities
  • Live Queries
  • Vector Search
  • Trusted RAG
  • Spatial Knowledge
  • Temporal
  • Behavior Graphs
  • Graph Algorithms
  • Skills
  • CREATE SKILL
  • PROCESS NODE
  • REPROCESS EDGES
  • Sync
  • Programs
  • GPU Acceleration
  • Agent-Native
  • MCP Server
  • Event Sourcing
  • Intent Relay
  • Event Bus
Use Cases
  • Agent Tooling
  • Trusted RAG
  • Knowledge Management
  • Behavior Graphs
  • Autonomous Systems
  • Physical AI
  • Digital Twins
  • Robotics & Perception
  • Sports Analytics
  • Grounded Neural Objects
  • Fraud Detection
Walkthroughs
    Guides
  • Agent Integration
  • Building a World Model
  • Modeling a Social Graph
  • Build a RAG Pipeline
  • Using Skills
  • Behavior Graphs
  • Swarm & Multi-Agent
  • Fleet Coordination
  • Migrate from Cypher / Neo4j
  • From SQL to GQL
  • Filesystem Workspace
  • Data Quality
  • Code Intelligence
  • Scale Patterns
  • v0.7 → v0.8 Lakehouse Fast-Path
  • Tutorials
  • Knowledge Graph
  • Entity Linking
  • Vector Search
  • Graph Algorithms
  • Recipes
  • CRUD
  • Multi-MATCH
  • MERGE (Upsert)
  • Full-Text Search
  • Batch Projection
  • Multi-Source Observation
  • Sports Analytics
Operations
  • CLI
  • REPL Commands
  • Snapshot & Restore
  • Filesystem Projection
  • Plugin Management
  • Agent Governance
  • Server Modes & PG Wire
  • Persistence (ops)
  • Import & Export
  • Deployment
  • Deployment Modes
  • Daemon (UDS)
  • Why not Docker
  • Architecture
  • Engine Architecture
  • Cloud Architecture
  • Sync Protocol (Deep Dive)
  • World Graph Substrate (Preview)
Reference
  • TypeScript API
  • Glossary
  • Naming & Domain Map
  • Data Types
  • Operators
  • Error Codes
  • GQL Reference
  • Known Issues
  • Versioning
  • Licensing
  • Conformance
  • GQL Conformance
  • openCypher TCK
  • Extension Regressions
GQL Reference
    Conformance
  • Conformance Dashboard
  • openCypher TCK Results
  • Extension Regressions
  • Features
  • MATCH Basic
  • CREATE Nodes Edges
  • SET REMOVE Properties
  • DELETE Detach DELETE
  • RETURN WITH WHERE
  • Order BY Limit Skip
  • Order BY Nulls First Last
  • UNWIND
  • Aggregate Functions
  • OPTIONAL MATCH
  • Variable Length Paths
  • Label OR AND NOT Expressions
  • Label Wildcard
  • Quantified Path Sugar
  • Path Modes Walk Trail Simple Acyclic
  • Shortest Path Variants
  • IS Labeled Predicate
  • Element ID Function
  • IS Type Predicate
  • Binary Literals
  • Line Comments Solidus
  • Line Comments Minus
  • GQLSTATUS Result Codes
  • GQL Error Code Mapping
  • Transaction Control Syntax
  • SET Session
  • Conditional Execution WHEN THEN ELSE
  • RETURN NEXT Pipeline
  • Primary Key Constraint
  • Unique Constraint
  • Deterministic MERGE Via PK
  • Undirected Edge MATCH
  • Cast Type Conversion
  • GQL Directories
  • Multiple Labels Per Node
  • GQL Flagger
  • NEXT Linear Composition
  • Cardinality Function
  • INT64 BIGINT Type Names
  • FLOAT64 Double Type Names
  • Log10 Log2 Functions
  • Trim Leading Trailing Both
  • FILTER Clause
  • LET Statement
  • Group BY Explicit
  • EXCEPT SET Operations
  • INTERSECT SET Operations
  • ALL Different Predicate
  • Same Predicate
  • Property Exists Function
  • Path Variable Binding
  • USE Graph Clause
  • FOR IN List
  • Typed Temporal Literals
  • Session SET Value Params
  • Typed List Annotations
  • arcflow.cosine() function
  • arcflow.embed() function
  • arcflow.similar() procedure
  • arcflow.graphrag() procedure
  • ArcFlow Extensions
  • LIVE Queries
  • Triggered Write-Back Views
  • Evidence Algebra
  • Relationship Skills
  • AI Function Namespace
  • Graph Embedding Algorithms
  • ASOF JOIN
  • Durable Workflows
  • Incremental Z-Set Engine
  • GPU GraphBLAS
  • Triggers
  • HNSW Vector Index
  • Extensions Moat

Procedures

This reference is designed for both human developers and AI coding agents. Every entry includes complete CALL syntax and return columns that can be used directly in queries.

140+ CALL procedures: Database Introspection (25), Graph Algorithms (37), Embedding (6), Knowledge Graph (9), Temporal (9), Live Queries (5), System (21), Spatial System (3), GPU (4), Observability (2), Health (3), Auth (7), Extensions (6), and Behavior Graph (3). All return tabular results.

CALL db.procedures()

Returns the full list of available procedures (column: name).

Database Introspection (25)#

Core procedures for inspecting database state, schema, and metadata.

ProcedureReturn ColumnsDescription
CALL db.nodeCount()countTotal node count
CALL db.relCount()countTotal relationship count
CALL db.labels()labelAll node labels in use
CALL db.types()typeAll relationship types in use
CALL db.keys()keyAll property keys in use
CALL db.version()name, version, crates, wavesEngine version and build info
CALL db.capabilities()capability, valueEngine version, GPU backend status, compute capabilities, index counts, memory footprint, and algorithm availability
CALL db.stats()nodes, relationships, skills, labels, indexes, constraints, properties, dense_store_enabled, dense_store_nodes, dense_store_tables, dense_store_memory_bytes, csr_cacheDatabase statistics including storage engine state
CALL db.stats.json()jsonAll metadata as single JSON object
CALL db.schema()label, properties, countSchema overview: labels, property keys per label, counts, and relationship patterns
CALL db.indexes()label, propertyAll indexes with target label and property
CALL db.constraints()label, property, typeAll constraints with target and type
CALL db.procedures()nameList all available procedure names
CALL db.help()procedure, description, exampleQuick-reference of key procedures with examples
CALL db.tutorial()step, title, query, descriptionInteractive 6-step walkthrough for new users
CALL db.doctor()check, status, detailDiagnostic health check: 5 checks + HEALTHY/ISSUES_FOUND summary
CALL db.embeddingStats()model, version, count, oldest_embedded_atEmbedding statistics by model/version including count and oldest embedding timestamp
CALL db.explainSpatialJoin(left_label, left_key, right_label, right_key)strategy, left_count, right_count, thresholdSpatial join planner explanation with chosen strategy and node counts per side
CALL db.idFrom(key1, key2, ...)nodeId, keysDeterministic content-addressed NodeId from key values via FNV-1a hashing
CALL db.export()snapshot, nodes, relationships, generationExport full graph as JSON snapshot
CALL db.import('<json>')status, nodes_before, nodes_afterImport graph from JSON snapshot (mutating)
CALL db.import.csv('<csv>', '<Label>')importedImport CSV rows as nodes with given label (mutating)
CALL db.clear()status, nodes_removed, rels_removedDelete all nodes, relationships, and indexes (mutating)
CALL db.demo()(demo graph)Load sample social network graph with example queries (mutating)
CALL db.provenance(nodeId)nodeId, label, name, confidence, depthTrace a node's derivation back through skills — provenance chain walk
CALL db.triggers()name, skill, trigger, max_cascade_depthList all registered triggers with skill bindings
CALL arcflow.skills()name, tier, allowed_on, threshold, active, versionList all registered skills
CALL arcflow.skills.export(name, version)jsonExport a skill pack as a portable JSON blob
CALL arcflow.skills.import(json)name, version, skill_countImport a skill pack from JSON
CALL arcflow.flywheel.tune(query1, query2, ...)action, rationale, boundedDry-run query analysis with actionable remediation proposals (missing indexes, cache pressure, failure fixes)
-- Get a schema overview
CALL db.schema()

Returns one row per label with property keys and node count, plus relationship patterns.

-- Run diagnostics
CALL db.doctor()

Returns rows for each check (node_count, relationship_integrity, index_consistency, constraints, generation) plus a summary row with HEALTHY or ISSUES_FOUND status.

Graph Algorithms (37)#

Centrality (5)#

ProcedureReturn ColumnsDescription
CALL algo.pageRank([maxIterations], [damping])nodeId, name, labels, rankPageRank (default 20 iterations, 0.85 damping). GPU-accelerated when available.
CALL algo.confidencePageRank()nodeId, name, confidence, rankPageRank weighted by node confidence scores
CALL algo.betweenness()nodeId, name, betweennessBetweenness centrality scores
CALL algo.closeness()nodeId, name, closenessCloseness centrality scores
CALL algo.degreeCentrality()nodeId, name, centralityDegree centrality scores
CALL algo.pageRank()

Returns one row per node, sorted by rank. Uses 20 iterations with damping factor 0.85.

Community Detection (7)#

ProcedureReturn ColumnsDescription
CALL algo.connectedComponents()nodeId, name, componentConnected component IDs
CALL algo.communityDetection()nodeId, name, communityCommunity IDs via label propagation. GPU-accelerated when available.
CALL algo.louvain()nodeId, name, communityCommunity IDs via Louvain modularity optimization. GPU-accelerated when available.
CALL algo.leiden()nodeId, communityCommunity IDs via Leiden algorithm (20 iterations)
CALL algo.kCore()nodeId, name, corenessK-core decomposition values
CALL algo.labelPropagation([label_property], [rel_types])node_id, propagated_label, label_confidence, hops_from_seedStochastic label propagation over optional relation types
CALL algo.cAndSLabelPropagation([label_property], [rel_types])node_id, propagated_label, label_confidence, hops_from_seedStochastic label propagation, C&S variant with seed-anchored confidence
CALL algo.louvain()

Returns one row per node with hierarchical community assignment.

Graph Metrics (6)#

ProcedureReturn ColumnsDescription
CALL algo.density()densityGraph density ratio (0.0 to 1.0)
CALL algo.diameter()diameterGraph diameter (longest shortest path)
CALL algo.triangleCount()trianglesTotal triangle count in the graph. GPU-accelerated when available.
CALL algo.clusteringCoefficient()nodeId, name, coefficientPer-node clustering coefficients. GPU-accelerated when available.
CALL algo.cycleDetectionDirected()hasCycle, cycleNodes, cycleNodeCountDirected cycle detection (Kosaraju SCC; cuGraph on GPU, fallback on CPU)
CALL algo.cycleDetectionUndirected()hasCycle, cycleNodes, cycleNodeCountUndirected cycle detection via DFS
CALL algo.triangleCount()

Returns a single row with the total number of triangles.

Path Analysis (5)#

ProcedureReturn ColumnsDescription
CALL algo.allPairsShortestPath()source, target, distanceShortest path distances between all node pairs (capped at 100 rows). GPU-accelerated when available.
CALL algo.confidencePath(startId, endId)path, cost, lengthShortest path between two nodes weighted by confidence
CALL algo.dijkstra(startId, endId, 'weight')path, distanceWeighted shortest path
CALL algo.astar(startId, endId, 'weight', 'heuristic')path, distanceHeuristic-guided shortest path (A*)
CALL algo.maxFlow(sourceId, sinkId, [capacityProperty])maxFlow, source, sinkMaximum flow from source to sink using a capacity edge property (default capacity)
-- Find confidence-weighted shortest path between node 1 and node 5
CALL algo.confidencePath(1, 5)

Returns the path as "id1 -> id2 -> id3", total cost, and hop count.

Similarity and Spatial (7)#

ProcedureReturn ColumnsDescription
CALL algo.nodeSimilarity()node1, node2, similarityPairs of nodes with Jaccard similarity scores (top 20)
CALL algo.similarNodes([sourceNodeId], [k])nodeId, scoreNodes similar to a source node (cosine similarity); auto-picks first vector-bearing node if source omitted, k defaults to 10
CALL algo.pairSimilarity(sourceIds, targetIds)node1, node2, scoreJaccard similarity for explicit node pairs (variadic — accept paired or interleaved args)
CALL algo.nearestNodes(point, label, k)node, distanceK nearest nodes by exact spatial distance (ArcFlow Spatial Index)
CALL arcflow.scene.frustumQuery(ox,oy,oz, dx,dy,dz, fovDeg, nearZ, farZ)node, distanceEntities within a camera frustum (6-plane containment)
CALL spatial.raycast(origin, direction, maxDist)hit, distanceFirst node along a ray within max distance

Vector Search and RAG (7)#

ProcedureReturn ColumnsDescription
CALL algo.vectorSearch()nodeId, score, labelsVector similarity search over vector index. Accepts optional query vector argument. GPU-accelerated when available.
CALL algo.hybridSearch([sourceNodeId])nodeId, score, hopsCombined vector + graph traversal search; accepts optional explicit source node
CALL algo.graphRAG()nodeId, score, hops, labelsGraph-augmented retrieval for RAG pipelines. Accepts optional query vector argument.
CALL algo.graphRAGContext()context, node_count, tokens_approxFormatted LLM context from graph retrieval. Accepts optional query vector and max_tokens arguments.
CALL algo.graphRAGTrusted()nodeId, trusted_score, hops, observationTrusted RAG with confidence-filtered context, ranked by observation class
CALL algo.graphRAGMultiModel(label, [k], [queryVector])nodeId, fusedScore, modelCountMulti-model RAG fusing scores across all embedding properties on a label
CALL algo.similarThenTraverse(label, embeddingProperty, queryVector, [k], [maxHops], [relType], [minEdgeConfidence])seedEntityId, vectorSimilarity, reachableJson, backendk-NN vector seed + per-seed BFS traversal with optional relation-type and confidence filters
-- Vector similarity search with a query vector
CALL algo.vectorSearch([0.1, 0.9, 0.3])

Returns nodes ranked by cosine similarity to the query vector.

-- Trusted RAG pipeline
CALL algo.graphRAGTrusted()

Returns nodes with trusted_score, observation class (observed > inferred > predicted), filtering low-trust paths.

Embedding Algorithms (6)#

Generate node embeddings for downstream vector search, classification, and similarity tasks.

ProcedureReturn ColumnsDescription
CALL algo.node2vec(dims, walkLen, walks)(sets node.embedding)Structural random walk embeddings
CALL algo.struc2vec(dims)(sets node.embedding)Structural equivalence embeddings
CALL algo.graphSAGE(dims)(sets node.embedding)Inductive neighborhood aggregation embeddings
CALL algo.staleEmbeddings()nodeId, nameNodes whose embeddings are outdated (property changed after last embed)
CALL algo.classify($vec, 'indexName', {k: 10})nodeId, label, confidenceClassify by similarity to labeled examples in a vector index
CALL algo.embeddingProperties([label])property, dimensions, withProvenanceList embedding properties for a label, with dimensions and provenance count
-- Embed all nodes with 128-dimensional Node2Vec vectors
CALL algo.node2vec(128, 80, 10)
 
-- Find stale embeddings after property updates
CALL algo.staleEmbeddings()

Knowledge Graph Algorithms (9)#

Algorithms for reasoning over facts, confidence, and semantic relationships.

ProcedureReturn ColumnsDescription
CALL algo.entityResolution()nodeId1, nodeId2, similarityFind nodes referring to the same real-world entity
CALL algo.factContradiction()nodeId1, nodeId2, contradiction_type, confidenceDetect contradictory facts in the graph
CALL algo.relationshipStrength()fromId, toId, strengthScore relationship strength by frequency, recency, mutual links
CALL algo.compoundingScore()nodeId, scoreComposite confidence propagated through fact chains
CALL algo.entityFreshness()nodeId, name, freshness, last_observed_atFreshness of each entity based on last observation
CALL algo.semanticDedup()nodeId1, nodeId2, similarityNear-duplicate nodes via embedding similarity
CALL algo.confidenceCalibration(entityId, [window])ece_score, sample_count, calibration_curve, calibration_statusExpected Calibration Error (ECE) — predicted confidence vs observed accuracy (WorldScore methodology)
CALL algo.predictionDrift(entityId, [horizonMs])entity_id, horizon_ms, predicted_x, observed_x, delta_x, predicted_y, observed_y, delta_y, delta_magnitude, prediction_source, observation_seq, predicted_seqDrift between predicted and observed entity positions within a time horizon
CALL algo.temporalDecay(nodeId, [halfLifeDays], [floor], [staleThreshold])decayed_confidence, days_elapsed, is_stale, freshness_classLazy temporal decay of confidence based on last corroboration timestamp

Physical AI Algorithms (3)#

Procedures for multi-agent world models: sensor reliability scoring, multi-agent belief fusion, and multi-sample weighted-centroid fusion.

ProcedureReturn ColumnsDescriptionSinceMutating
CALL algo.sensorReliability('sensor-id')accuracy, drift_rate, sample_count, calibration_recommendedCompute mean confidence across all Entity nodes sourced from this sensor. Updates reliability_7d or reliability_30d on the Sensor node. Pass '30d' as second arg for 30-day window.0.8.0Yes
CALL algo.beliefReconcile('entity-id')fused_confidence, source_agents, source_confidences, reconciliation_method, observation_seqKalman precision-weighted fusion of all Agent BELIEVES edges pointing to the entity. Writes _observation_class: 'inferred', _propagation_rule: 'kalman-fusion', _source_agents, _source_count back onto the entity. Algorithm: fused = Σ(cᵢ²) / Σ(cᵢ).0.8.0Yes
CALL algo.fusion.weighted_centroid('Label', 'posProp', 'weightProp') (alias algo.fusion.weightedCentroid)x, y, z, var_x, var_y, var_z, total_weight, nMulti-sample weighted centroid + per-axis variance over every node carrying a 3D position (Point3d / Vector3d; 2D Point accepted as z=0) and a numeric weight (Float / Int, ≥ 0). Replaces the per-service np.average(positions, weights=…) round-trip with one in-engine call. Errors: EMPTY_SAMPLE_SET, WEIGHT_NOT_NUMERIC, NEGATIVE_WEIGHT, INVALID_WEIGHT_SUM, NAN_IN_INPUT. See Sensor Fusion.0.8.0No
-- Check sensor reliability after a calibration run
CALL algo.sensorReliability('lidar-front')
YIELD accuracy, drift_rate, sample_count, calibration_recommended

Returns mean confidence of all Entity nodes attributed to lidar-front, plus a calibration flag when accuracy < 0.85.

-- Fuse two agents' conflicting observations of 'player-07' into one inferred fact
CALL algo.beliefReconcile('player-07')
YIELD fused_confidence, source_agents, reconciliation_method

Scans all [:BELIEVES] edges ending at the entity, computes precision-weighted Kalman mean, writes the result as _observation_class: 'inferred' on the entity. See Fleet Coordination guide for the full multi-agent pattern.

-- Find entities that may refer to the same person
CALL algo.entityResolution()

Auth & Governance (7)#

API key management and audit log procedures.

ProcedureReturn ColumnsDescription
CALL db.auth.whoami()identity, role, scopesCurrent authenticated identity
CALL db.auth.policies()resource, action, allowedACL policy definitions
CALL db.auth.check('resource', 'action')allowed, reasonCheck if current identity has permission
CALL db.auth.createApiKey('name')key, created_atCreate a new API key (write)
CALL db.auth.revokeApiKey('key')revokedRevoke an API key (write)
CALL db.auth.listApiKeys()name, created_at, last_usedList all API keys
CALL db.auth.auditLog()timestamp, identity, action, resourceRecent auth audit events

Temporal (9)#

Procedures for temporal queries, clock management, and change tracking.

ProcedureReturn ColumnsDescription
CALL db.clock()name, tickCurrent engine clock name and tick value
CALL db.clockDomains()domain, countAll registered clock domains with node counts
CALL db.temporalCompare()changeCount, fromSequence, toSequence, operationCompare mutations from sequence 0 to current
CALL db.temporalGate()valid, violationCount, violationCheck temporal gate consistency; lists violations if any
CALL db.temporalReplay()sequence, operation, timestampReplay all WAL mutations from sequence 0
CALL db.nodesAsOf()nodeId, labels, createdAtReturn all nodes that existed at or before current time
CALL db.changesSince()sequence, operationRecent mutations (last 100 entries)
CALL db.mutations()sequence, operation, timestampRecent mutation log (last 50 entries) with timestamps
CALL db.fingerprint()fingerprintDeterministic FNV hash of current graph state (hex string)
-- See recent mutations with timestamps
CALL db.mutations()

Returns rows with sequence number, operation description, and timestamp.

-- Point-in-time query (query modifier, not a CALL procedure)
MATCH (n:Person) AS OF seq N
RETURN n.name

Note: AS OF is a query modifier, not a CALL procedure.

Live Queries (5)#

Procedures for live queries: topics, subscriptions, live views, and causal chains.

ProcedureReturn ColumnsDescription
CALL db.topics()id, name, eventsAll registered event topics with event counts. Topic creation, publishes, and retention changes are WAL-journaled and survive restart
CALL db.subscriptions()name, topic, query, activeActive subscriptions with topic bindings
CALL db.liveQueries()name, queryActive live query registrations
CALL db.causalChain()origin, depth, target, target_labels, confidenceTraces CAUSES chains from all Action nodes (depth 10)
CALL db.views()name, queryMaterialized view definitions

Topic event sequences are strictly monotonic per topic — retention pruning never re-uses a sequence number. See Live Queries → Topics for the retention policy and subscription cursor replay surfaces.

CALL db.causalChain()

Finds all :Action nodes and traces outgoing CAUSES relationships up to depth 10, returning each hop with confidence scores.

System (21)#

Procedures for backend management, validation, observability, and storage internals.

ProcedureReturn ColumnsDescription
CALL db.backends()id, available, messageAvailable compute backends (CPU, CUDA, Metal) with status
CALL db.storageInfo()format, nodesStorage backend details (format, generation, node/rel counts, mutation sequence)
CALL db.storageMode()mode, node_count, csr_warm, csr_auto_threshold, dense_store_enabled, dense_store_nodesActive storage mode (HashMap, DenseStore, CSR, or hybrid) with thresholds
CALL db.csrStats()status, vertices, edges, rel_types, edge_type_distribution, memory_bytes, delta_added, delta_removedCSR (Compressed Sparse Row) cache statistics — warm/stale status, vertex / edge counts, memory footprint, pending delta size
CALL db.denseStore()enabled, nodes, tables, memory_bytes, coverageDenseStore status with node and table counts, memory footprint, coverage percentage
CALL db.warmCsr()statusWarm the CSR cache; returns warm or rebuilt
CALL db.parallelConfig()morsel_size, rayon_threads, rayon_nodescan_threshold, dense_store_enabled, dense_store_coverage, csr_status, csr_delta_pendingMorsel scheduler, parallelism configuration, and CSR delta queue depth
CALL db.validateQuery()valid, warningsParse and validate a query without executing
CALL db.vectorIndexes()name, label, property, dimensions, similarityAll vector indexes with configuration
CALL db.observationClasses()class, countObservation class counts (observed, inferred, predicted)
CALL db.nodesByObservation.observed()_id, _labels, _observation_class, _confidenceAll nodes with observation class "observed"
CALL db.nodesByObservation.inferred()_id, _labels, _observation_class, _confidenceAll nodes with observation class "inferred"
CALL db.nodesByObservation.predicted()_id, _labels, _observation_class, _confidenceAll nodes with observation class "predicted"
CALL db.nodesByPlane.semantic()_id, _labels, _authority_planeNodes in the semantic authority plane
CALL db.nodesByPlane.scene()_id, _labels, _authority_planeNodes in the scene authority plane
CALL db.proofGates()gate, status, evidenceProof gate definitions and their validation status
CALL db.proofArtifacts()artifact, type, detailGenerated proof artifacts
CALL db.executionContext()context, fallback_disabled, backends_available, gpu_available, distributed_availableCurrent execution context (backend, GPU availability, distributed availability)
CALL db.requireExecutionContext('local_cpu' | 'local_gpu' | 'distributed')context, statusEnforces a required execution context; raises a hard error on mismatch
CALL db.syncConflicts()id, local_op, remote_op, local_clock, remote_clock, resolution, timestampReplication conflict log with operations, vector clocks, and resolution per conflict
CALL db.affordances()from, to, confidenceAll AFFORDS relationships in the graph
-- Check available GPU backends
CALL db.backends()

Returns one row per backend (cpu, metal, cuda) with availability and status message.

-- Query by observation class
CALL db.nodesByObservation.observed()

Returns all nodes classified as "observed" with their confidence scores.

Spatial System (3)#

Coordinate frame management and spatial query observability.

ProcedureReturn ColumnsDescription
CALL db.spatialMetadata()crs, meters_per_unit, up_axis, handedness, calibration_versionCurrent coordinate frame settings. Hard error raised on mismatch at ingest.
CALL arcflow.spatial.dispatch_stats()lane_chosen, estimated_candidates, actual_candidates, prefilter_us, rtree_us, gpu_transfer_us, kernel_us, total_usLast spatial query execution metrics. lane_chosen: CpuLive, CpuBatch, GpuLocal, GpuMulti.
-- Inspect current coordinate frame
CALL db.spatialMetadata()
 
-- Check dispatch lane after a spatial query
CALL arcflow.spatial.dispatch_stats()

GPU (4)#

GPU residency and capability inspection. The engine routes algorithms to GPU automatically when available; these procedures expose the routing decisions and stack details.

ProcedureReturn ColumnsDescription
CALL db.gpuStack()cuda, thrust, cugraph, cuvsGPU stack availability — CUDA driver, Thrust, cuGraph, cuVS. Optional fields: compute_capability, gpu_device, cugraph_algorithms, cuvs_algorithms
CALL db.gpuCsrStatus()resident, size_bytes, mutation_sequenceGPU CSR cache residency including size in bytes and the mutation sequence the cache reflects
CALL db.gpuVectorSearch(query, label, property, k)nodeId, similarity, backendGPU-accelerated vector similarity search via cuVS CAGRA (falls back to CPU HNSW)
CALL algo.gpu_capabilities()symbol, available, detailGPU algorithm capability report — cuGraph availability, compute capability, per-algorithm probes
-- Confirm GPU stack is fully wired before running large-graph algorithms
CALL db.gpuStack()

Observability (2)#

OpenTelemetry policy controls. Span recording is off by default; enable lite or full to surface execution traces in your collector.

ProcedureReturn ColumnsDescription
CALL db.otelPolicy()policyCurrent span recording policy (off, lite, or full)
CALL db.setOtelPolicy('off' | 'lite' | 'full')policySet span recording policy and return the new value

Health (3)#

ProcedureReturn ColumnsDescription
CALL db.replicationStatus()mode, replica_count, writes_enabled, last_replicated_seq, primary_endpointReplication mode, replica count, write status, and primary endpoint
CALL db.checkpointMeta()generation, nodesLast checkpoint generation, node/rel counts, mutation sequence
CALL db.schemaRegistry()label, property, typeRegistered schema versions with property types
CALL db.replicationStatus()

Returns the current replication mode (standalone/primary/replica), replica count, and whether writes are enabled.

Extension Procedures (6)#

Additional domain-specific procedures.

ProcedureReturn ColumnsDescription
CALL db.extensions()name, description, syntax, referenceAll ArcFlow-unique query language extensions — LIVE views, Evidence algebra, write-back surfaces
CALL vector.search()nodeId, score, labelsAlias for algo.vectorSearch — searches first available vector index
CALL swarm.agents()id, type, status, positionAll registered agent definitions
CALL swarm.register('agent_id', 'agent_type')id, type, statusRegister a new agent (requires agent_id argument)
CALL swarm.agentCount()active, totalNumber of active and total registered agents
CALL geo.cells()cell_id, name, status, entities, agentsSpatial grid cells with entity/agent counts
-- Register a drone agent
CALL swarm.register('drone_01', 'drone')

Behavior Graph (3)#

Behavior tree procedures backed by the world model. Nodes labeled :BehaviorNode form the tree; CHILD relationships define structure.

ProcedureReturn ColumnsDescription
CALL behavior.tick('treeName')tree, status, running, success, failureTick a behavior tree: evaluate from root, propagate SUCCESS/FAILURE/RUNNING
CALL behavior.status('treeName')nodeId, name, type, status, lastTickCurrent status of all nodes in a behavior tree
CALL behavior.nodes()nodeId, name, type, childrenList all behavior tree nodes with child counts
-- Tick a behavior tree named "patrol"
CALL behavior.tick('patrol')
-- List all behavior nodes
CALL behavior.nodes()

See Also#

  • Built-in Functions -- 93 scalar functions (17 math, 14 aggregation, 24 string, ...)
  • EXPLAIN -- query plan introspection
  • PROFILE -- query execution profiling
  • RAG Pipeline Guide -- building RAG with ArcFlow
Try it
Open ↗⌘↵ to run
Loading engine…
← PreviousAggregationsNext →Shortest Path