-
Notifications
You must be signed in to change notification settings - Fork 1
features_path_constraints
Constraints für Graph-Pfade und Traversals.
- 📋 Übersicht
- ✨ Features
- 🚀 Schnellstart
- 📖 Detaillierte Dokumentation
- 💡 Best Practices
- 🔧 Troubleshooting
- 📚 Siehe auch
- 📝 Changelog
Aktuell werden FILTER-Ausdrücke in Traversals nur am letzten Level vor dem Enqueue angewendet (konservatives Pruning). Dies ist sicher, aber lässt Optimierungspotenzial auf Zwischenebenen ungenutzt.
Pfad-Constraints ermöglichen aggressiveres Pruning auf allen Tiefen, indem Prädikate entlang des gesamten Pfads gelten.
Query:
FOR v IN 1..3 OUTBOUND 'user1' GRAPH 'social'
FILTER e.type == 'follows'
RETURN v
Naive (falsche) Interpretation:
- "Schneide alle Kanten ab, bei denen
e.type != 'follows'" -
Problem: Bei depth=1 ist
edie Kante von user1 → v1, aber bei depth=2 istedie Kante zum aktuellen Knoten (v2), nicht die gesamte Pfadhistorie.
Ergebnis: Zu viele Pfade abgeschnitten, die über alternative Routen erreichbar wären.
Semantik: FILTER gilt nur für die eingehende Kante zur aktuellen Zeile (depth).
Syntax:
FILTER e.type == 'follows' -- nur am letzten Level sicher
Anwendung:
- Am letzten Level vor Enqueue prüfen (✅ implementiert)
- Auf Zwischenebenen: nicht prunen (würde Pfade abschneiden)
Semantik: FILTER gilt für alle Kanten entlang des Pfads von Start bis aktueller Zeile.
Syntax (zukünftig):
FILTER PATH.ALL(e, e.type == 'follows')
Bedeutung:
- Prüfe bei jedem Expand: Ist die neue Kante ein
follows? - Wenn nein: Pfad ist ungültig → nicht enqueuen
- Sicher auf allen Tiefen!
Implementierung:
- Beim Enqueue: Prüfe
a.edgeIdgegen Constraint - Tracking: Optional Pfad-Historie (Liste der edgeIds) mitführen, falls Constraints auf "vorherige Kante" prüfen
Semantik: Mindestens eine Kante entlang des Pfads erfüllt Prädikat.
Syntax (zukünftig):
FILTER PATH.ANY(e, e.weight > 10)
Implementierung:
- Pfad-State: Boolean Flag
hasSeenHeavyEdge - Beim Enqueue: Update Flag
- Bei Result-Zeile: Prüfe Flag
Semantik: Kein Vertex entlang des Pfads darf Prädikat verletzen.
Syntax (zukünftig):
FILTER PATH.NONE(v, v.blocked == true)
Implementierung:
- Beim Enqueue: Prüfe neuen Vertex
nbgegen Constraint - Wenn
nb.blocked == true: Nicht enqueuen - Sicher auf allen Tiefen!
| Constraint-Typ | Anwendungstiefe | Implementierung |
|---|---|---|
| Last-Edge (e.field OP value) | Nur letztes Level | ✅ Implementiert (evalSingleE) |
| Last-Vertex (v.field OP value) | Nur letztes Level | ✅ Implementiert (evalSingleV) |
| PATH.ALL(e, ...) | Alle Tiefen | 🔜 Geplant (Expand-Zeit-Check) |
| PATH.NONE(v, ...) | Alle Tiefen | 🔜 Geplant (Expand-Zeit-Check) |
| PATH.ANY(e, ...) | Alle Tiefen (State) | 🔜 Geplant (Flag-basiert) |
struct PathConstraintExpr : Expression {
enum class Type { All, Any, None };
Type type;
char varName; // 'e' oder 'v'
std::unique_ptr<Expression> predicate;
};Parser-Syntax:
PATH.ALL(e, e.type == 'follows')
PATH.NONE(v, v.blocked == true)
PATH.ANY(e, e.weight > 10)
struct FilterClassification {
std::vector<Expression*> lastEdgeOnly;
std::vector<Expression*> lastVertexOnly;
std::vector<Expression*> pathAllEdge;
std::vector<Expression*> pathNoneVertex;
std::vector<Expression*> pathAnyEdge;
std::vector<Expression*> mixed; // AND/OR kombiniert, keine einfache Klassifikation
};
FilterClassification classifyFilters(const std::vector<std::unique_ptr<FilterClause>>& filters);auto enqueueOut = [&](const std::vector<AdjacencyInfo>& adj) {
for (const auto& a : adj) {
// PATH.ALL(e, e.type == 'follows')
for (const auto& pathAllE : pathAllEdgeConstraints) {
if (!evalEdgeConstraint(a.edgeId, pathAllE)) {
prunedAllDepths++;
continue; // sicher auf allen Tiefen!
}
}
// PATH.NONE(v, v.blocked == true)
for (const auto& pathNoneV : pathNoneVertexConstraints) {
if (evalVertexConstraint(a.targetPk, pathNoneV)) {
prunedAllDepths++;
continue; // blockierter Vertex → skip
}
}
// Konservative Prüfungen (nur letztes Level)
if (depth + 1 == t.maxDepth) {
// ... (wie bisher)
}
if (visited.insert(a.targetPk).second) {
parent[a.targetPk] = {node, a.edgeId};
qnodes.push({a.targetPk, depth + 1});
enqueuedPerDepth[depth + 1]++;
}
}
};struct PathState {
bool hasSeenHeavyEdge = false;
// weitere Flags je Constraint
};
std::unordered_map<std::string, PathState> pathStates;
// Beim Enqueue:
PathState newState = pathStates[node];
if (checkEdgeWeight(a.edgeId) > 10) newState.hasSeenHeavyEdge = true;
pathStates[a.targetPk] = newState;
// Bei Result-Zeile:
if (pathAnyEdgeConstraints.hasHeavyEdge && !pathStates[node].hasSeenHeavyEdge) {
pass = false; // PATH.ANY nicht erfüllt
}- Frontier-Reduktion: Aggressives Pruning auf allen Tiefen
- Frühzeitiger Abbruch: Ungültige Pfade werden sofort verworfen
- Weniger Entity-Loads: Nur validierte Pfade landen in Result-Set
- Expand-Zeit-Overhead: Jede Kante wird gegen PATH.ALL/NONE geprüft
- Memory: PathState für PATH.ANY (HashMap, kleine Keys)
Faustregel:
- Nutzen > Kosten, wenn Constraints selektiv sind (z. B. nur 10% der Kanten sind
follows)
- Phase 1: Parser-Erweiterung (PATH.ALL/NONE/ANY Syntax)
- Phase 2: AST-Classifier (Filter-Typen erkennen)
- Phase 3: BFS Expand-Zeit-Checks (PATH.ALL/NONE)
- Phase 4: State-Tracking (PATH.ANY)
-
Phase 5: Metriken (
pruned_all_depths,path_state_size) - Phase 6: Tests & Benchmarks (Vergleich mit/ohne Constraints)
FOR v IN 1..3 OUTBOUND 'user1' GRAPH 'social'
FILTER PATH.ALL(e, e.type == 'follows')
RETURN v
Effekt: BFS expandiert nur über follows-Kanten, alle anderen werden auf allen Tiefen gedroppt.
FOR v IN 1..5 OUTBOUND 'user1' GRAPH 'social'
FILTER PATH.NONE(v, v.blocked == true)
RETURN v
Effekt: Pfade, die einen blockierten Vertex passieren, werden sofort verworfen.
FOR v IN 1..4 OUTBOUND 'user1' GRAPH 'social'
FILTER PATH.ANY(e, e.weight > 10)
RETURN v
Effekt: Nur Pfade mit mindestens einer starken Kante (weight > 10) landen im Result.
| Aktuelle Implementierung | Pfad-Constraints (geplant) |
|---|---|
| Pruning nur am letzten Level | Pruning auf allen Tiefen |
| Unsicher für Zwischenebenen | Sichere Semantik durch PATH.ALL/NONE |
| Einfach (kein State) | State-Tracking für PATH.ANY |
| Konservativ (viele False Positives) | Aggressiv (nur valide Pfade expandiert) |
Empfehlung:
- Phase 1-3 implementieren (PATH.ALL/NONE) für sofortigen Nutzen
- Phase 4 (PATH.ANY) optional, falls Use-Cases existieren
- Metriken sammeln:
pruned_all_depthsvs.pruned_last_levelVergleich
Siehe auch:
- Architecture-ACCESS-MODEL-IMPLEMENTATION-SUMMARY
- Architecture-ADR-003-pg-dump-sql-parser
- Architecture-BASEENTITY-PRINCIPLE
- Architecture-CACHE-STORAGE-INTEGRATION
- Architecture-CMAKE-ARCHITECTURE
- Architecture-CMAKE-FLAGS-REFERENCE
- Architecture-CMAKE-MODULAR-ARCHITECTURE
- Architecture-CONCERNS-ARCHITECTURE-DIAGRAM
- Architecture-CONCERNS-IMPLEMENTATION-SUMMARY
- Architecture-CONTENT-MODEL
- Architecture-COPILOT-THEMISDB-GRAPH-RAG-BACKEND-ARCHITECTURE
- Architecture-CRYPTO-AND-KEYS
- Architecture-FEATURE-FLAGS-REFERENCE
- Architecture-GPU-ARCHITECTURE-REVIEW-TEMPLATE
- Architecture-HTTP-SHUTDOWN-HARDENING
- Architecture-MIGRATION-GUIDE-CONCERNS
- Architecture-MIGRATION-GUIDE-v13-v14
- Architecture-MODULARIZATION-GUIDE
- Architecture-MODULAR-ARCHITECTURE-ROADMAP
- Architecture-MODULE-ARCHITECTURE-INDEX
- Architecture-P1D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D08-MAMBA-GOVERNANCE-CONTRACT
- Architecture-P1-P2-IMPLEMENTATION-COMPLETION-INDEX
- Architecture-PHASE0-COMPLETION-ASSESSMENT
- Architecture-PHASE3-QUERYENGINE-DI-ARCHITECTURE
- Architecture-PHASE4-INDEX-MANAGER-DI
- Architecture-POSTGRESQL-WIRE-PROTOCOL
- Architecture-QUERYENGINE-IMPLEMENTATION-GUIDE
- Architecture-QUERY-SCHEDULING
- Architecture-RAFT-CONSENSUS-DESIGN
- Architecture-README
- Architecture-README-SSM-HYBRID-IMPLEMENTATION
- Architecture-REFACTORING-SUMMARY
- Architecture-RESOURCE-POOLING
- Architecture-SOURCE-DIRECTORY-GUIDE
- Architecture-THEMIS-CORE-GUIDE
- Architecture-UNIFIED-ACCESS-MODEL
- Architecture-WAL-GRPC-MTLS-CONFIGURATION
- Architecture-WIRE-PROTOCOL-RETRY
- Architecture-boltzmann-observability-draft
- Architecture-experimental-logarithmic-vector-storage
- Architecture-llm-wiki-mvp-adr
- Architecture-rewrite-engine-architecture
- Architecture-rope-api-architecture
- Architecture-ssm-gguf-mamba-status
- Architecture-ssm-hybrid-analysis
- Architecture-ssm-hybrid-rollout-plan
- Architecture-ssm-plugin-interface-design-review
- Architecture-transaction-coordinators
- Architecture-wiki-secondary-index
- Architecture-wire-protocol
- Governance-DISABLED-STUB-POLICY
- Governance-DOCS-PR-POLICY
- Governance-GA-PROMOTION-SIGN-OFF
- Governance-GITHUB-MILESTONES-SETUP
- Governance-MATURITY-CLAIM-VERIFICATION-CHECKLIST
- Governance-MATURITY-EVIDENCE-REGISTRY
- Governance-MERGE-GATE-BOT-CONFIG
- Governance-MERGE-GATE-STATUS-LIVE
- Governance-PHASE3-ENFORCEMENT-RUNBOOK
- Governance-PHASE-1-CLOSURE-REPORT
- Governance-PHASE-CLOSURE-POLICY
- Governance-PHASE-DEPENDENCY-GRAPH
- Governance-PLUGIN-SUBMODULE-ROLLBACK
- Governance-PRODUCTION-READY-2026-DELIVERY-PLAN
- Governance-PR-VERSION-TARGETING
- Governance-PR-VERSION-TARGETING-BACKFILL
- Governance-QUERY-MODULE-STATUS
- Governance-README
- Governance-RELEASE-PROMOTION-GATE-POLICY
- Governance-RELEASE-VALIDATION-CHECKLIST
- Governance-SECURITY-MODULE-5671-EVIDENCE-SUMMARY
- Governance-SHARDING-P6-RESIDUAL-RISK-ACCEPTANCE
- Governance-SOURCECODE-COMPLIANCE-GOVERNANCE
- Governance-UPDATES-DEVELOPMENT-STATUS-SIGN-OFF
- Governance-WAVE-C-IMPLEMENTATION-COMPLETE
- Module-acceleration-Roadmap
- Module-access-model-Roadmap
- Module-ai-Roadmap
- Module-analytics-Roadmap
- Module-api-Roadmap
- Module-aql-Roadmap
- Module-auth-Roadmap
- Module-base-Roadmap
- Module-cache-Roadmap
- Module-cdc-Roadmap
- Module-chaos-Roadmap
- Module-chimera-Roadmap
- Module-config-Roadmap
- Module-content-Roadmap
- Module-core-Roadmap
- Module-distributed-knowledge-Roadmap
- Module-distributed-tensor-Roadmap
- Module-document-Roadmap
- Module-ethics-ai-Roadmap
- Module-evaluation-Roadmap
- Module-execution-Roadmap
- Module-exporters-Roadmap
- Module-failover-Roadmap
- Module-geo-Roadmap
- Module-governance-Roadmap
- Module-gpu-Roadmap
- Module-graph-Roadmap
- Module-image-analysis-Roadmap
- Module-importers-Roadmap
- Module-index-Roadmap
- Module-ingestion-Roadmap
- Module-llama-cpp-Roadmap
- Module-llm-Roadmap
- Module-llm-streaming-Roadmap
- Module-llm-wiki-Roadmap
- Module-maintenance-Roadmap
- Module-metadata-Roadmap
- Module-network-Roadmap
- Module-observability-Roadmap
- Module-onnx-clip-Roadmap
- Module-performance-Roadmap
- Module-plugins-Roadmap
- Module-process-Roadmap
- Module-projects-Roadmap
- Module-prompt-engineering-Roadmap
- Module-query-Roadmap
- Module-rag-Roadmap
- Module-replication-Roadmap
- Module-retrieval-Roadmap
- Module-rpc-grpc-Roadmap
- Module-scheduler-Roadmap
- Module-scraper-Roadmap
- Module-search-Roadmap
- Module-security-Roadmap
- Module-server-Roadmap
- Module-sharding-Roadmap
- Module-stable-diffusion-Roadmap
- Module-storage-Roadmap
- Module-temporal-Roadmap
- Module-tensor-Roadmap
- Module-themis-Roadmap
- Module-timeseries-Roadmap
- Module-toolbox-Roadmap
- Module-training-Roadmap
- Module-transaction-Roadmap
- Module-updates-Roadmap
- Module-user-storage-encrypted-Roadmap
- Module-utils-Roadmap
- Module-vector-search-Roadmap
- Module-voice-Roadmap
- Module-whisper-Roadmap