Struct ReadSnapshot

Source

pub struct ReadSnapshot {
    pub store: NodeStore,
    pub catalog: Catalog,
    pub csrs: HashMap<u32, CsrForward>,
    pub db_root: PathBuf,
    pub label_row_counts: HashMap<LabelId, usize>,
    pub rel_degree_stats: HashMap<u32, DegreeStats>,
}

Expand description

Immutable snapshot of storage state required to execute a read query.

Groups the fields that are needed for read-only access to the graph so they can eventually be cloned/shared across parallel executor threads without bundling the mutable per-query state that lives in Engine.

Fields§

§store: NodeStore§catalog: Catalog§csrs: HashMap<u32, CsrForward>

Per-relationship-type CSR forward files, keyed by RelTableId (u32).

§db_root: PathBuf§label_row_counts: HashMap<LabelId, usize>

Cached live node count per label, updated on every node creation.

Used by the planner to estimate cardinality without re-scanning the node store’s high-water-mark file on every query.

§rel_degree_stats: HashMap<u32, DegreeStats>

Per-relationship-type out-degree statistics (SPA-273).

Keyed by RelTableId (u32). Built eagerly at engine open time from CSR forward files. Used by future join-order heuristics to estimate how many neighbor hops a traversal on a given relationship type will produce.

Auto Trait Implementations§

§

ReadSnapshot

Struct ReadSnapshot Copy item path

Fields§

Auto Trait Implementations§

impl Freeze for ReadSnapshot

impl RefUnwindSafe for ReadSnapshot

impl Send for ReadSnapshot

impl Sync for ReadSnapshot

impl Unpin for ReadSnapshot

impl UnsafeUnpin for ReadSnapshot

impl UnwindSafe for ReadSnapshot

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ReadSnapshot

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,