nodedb 0.3.0

Local-first, real-time, edge-to-cloud hybrid database for multi-modal workloads
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
28

// SPDX-License-Identifier: BUSL-1.1

//! Read-path methods for `ArrayEngine`.

use nodedb_array::segment::{MbrQueryPredicate, TilePayload};
use nodedb_array::types::ArrayId;

use super::engine::{ArrayEngine, ArrayEngineResult};

impl ArrayEngine {
    pub fn scan_tiles(
        &self,
        id: &ArrayId,
        pred: &MbrQueryPredicate,
    ) -> ArrayEngineResult<Vec<TilePayload>> {
        Ok(self.store(id)?.scan_tiles(pred)?)
    }

    /// Like `scan_tiles` but pairs each tile with its Hilbert prefix for
    /// per-shard range filtering in distributed aggregate queries.
    pub fn scan_tiles_with_hilbert_prefix(
        &self,
        id: &ArrayId,
        pred: &MbrQueryPredicate,
    ) -> ArrayEngineResult<Vec<(u64, TilePayload)>> {
        Ok(self.store(id)?.scan_tiles_with_hilbert_prefix(pred)?)
    }
}