nodedb-physical 0.6.1

Shared PhysicalTask IR and SqlPlan-to-PhysicalPlan converter for NodeDB Origin and Lite
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
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

// SPDX-License-Identifier: Apache-2.0

//! Which user collection a vector-primary direct write targets.
//!
//! Kept beside the operation enum rather than inside it so `op.rs` stays the
//! single declaration of the wire shape and nothing else.

use super::op::VectorOp;

impl VectorOp {
    /// The vector-primary collection a direct write targets, or `None` for
    /// every op outside that family. `ResolveDirectWrite` reports the wrapped
    /// write's collection so the resolve dispatch routes to the core that
    /// owns exactly the rows the write reads.
    pub fn direct_write_collection(&self) -> Option<&str> {
        match self {
            VectorOp::DirectUpsert { collection, .. }
            | VectorOp::DirectInsert { collection, .. }
            | VectorOp::DirectInsertIfAbsent { collection, .. }
            | VectorOp::DirectBatchWrite { collection, .. }
            | VectorOp::DirectDelete { collection, .. }
            | VectorOp::DirectTruncate { collection, .. }
            | VectorOp::DirectUpdate { collection, .. }
            | VectorOp::ResolvedDirectWrite { collection, .. } => Some(collection.as_str()),
            VectorOp::ResolveDirectWrite(inner) => inner.direct_write_collection(),
            VectorOp::Search { .. }
            | VectorOp::Insert { .. }
            | VectorOp::BatchInsert { .. }
            | VectorOp::MultiSearch { .. }
            | VectorOp::Delete { .. }
            | VectorOp::DeleteBySurrogate { .. }
            | VectorOp::SetParams { .. }
            | VectorOp::DropIndex { .. }
            | VectorOp::QueryStats { .. }
            | VectorOp::Seal { .. }
            | VectorOp::CompactIndex { .. }
            | VectorOp::Rebuild { .. }
            | VectorOp::SparseInsert { .. }
            | VectorOp::SparseSearch { .. }
            | VectorOp::SparseDelete { .. }
            | VectorOp::MultiVectorInsert { .. }
            | VectorOp::MultiVectorDelete { .. }
            | VectorOp::MultiVectorScoreSearch { .. } => None,
        }
    }
}