kglite 0.10.25

Pure-Rust knowledge graph engine — Cypher pipeline, snapshot/working CoW transactions, columnar/mmap/disk storage backends, optional dataset loaders (SEC EDGAR, Sodir, Wikidata). PyO3 wrappers live in the sibling kglite-py crate (the Python wheel); embeddable directly from any Rust binary without PyO3 in the dep tree.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

//! Pattern-match source: wraps the materialized result of a MATCH clause
//! into a [`RowStream`].
//!
//! Phase 1 keeps the underlying `Vec<ResultRow>` — Phase 3 will replace
//! this with true streaming pattern expansion that never builds the full
//! vector. Even with the materialization here, downstream operators
//! (aggregate, top-K) accumulate inline, so the pipeline's *peak* memory
//! is bounded by the pattern result, not by every intermediate clause's
//! row set.

// Currently unreferenced: the Phase 1 pipeline shape consumes the
// already-built `ResultSet` directly via `RowStream::from_result_set`.
// This thin wrapper exists for the multi-MATCH absorption that lands
// later — keeping it in tree avoids the tedious re-introduce later.
#![allow(dead_code)]

use super::super::super::result::ResultSet;
use super::RowStream;

/// Build a [`RowStream`] from an already-executed MATCH `ResultSet`.
///
/// Used by [`super::pipeline::try_build_stream_pipeline`] after invoking
/// `execute_match` on the leading clause(s). The inner `Vec` is moved into
/// a boxed iterator; no clones beyond what the executor already produced.
pub fn from_match_result(rs: ResultSet) -> RowStream<'static> {
    RowStream::from_result_set(rs)
}