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
47
48
49
50
51

// SPDX-License-Identifier: Apache-2.0

use nodedb_types::id::{TxnId, VShardId};
use nodedb_types::{DatabaseId, TenantId};

use crate::physical_plan::PhysicalPlan;

/// Post-execution set operation for merging multi-task results.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum PostSetOp {
    /// No post-merge (single task or independent tasks).
    None,
    /// UNION DISTINCT: deduplicate rows across sub-queries.
    UnionDistinct,
    /// INTERSECT: keep rows that appear in all sub-query results.
    Intersect,
    /// INTERSECT ALL: keep rows appearing in both (with multiplicity).
    IntersectAll,
    /// EXCEPT: keep rows from first that don't appear in second.
    Except,
    /// EXCEPT ALL: keep rows from first not in second (with multiplicity).
    ExceptAll,
}

/// A physical execution task ready for dispatch to the Data Plane.
///
/// The planner produces these after converting a DataFusion logical plan
/// into a concrete physical operation targeting a specific vShard.
#[derive(Debug, Clone)]
pub struct PhysicalTask {
    /// Target tenant.
    pub tenant_id: TenantId,

    /// Target vShard (determines which Data Plane core handles this).
    pub vshard_id: VShardId,

    /// Database scope. All data access is restricted to this database namespace.
    /// `DatabaseId::DEFAULT` (0) is the built-in `default` database.
    pub database_id: DatabaseId,

    /// The physical operation to execute.
    pub plan: PhysicalPlan,

    /// Post-execution merge operation for set operations (UNION, INTERSECT, EXCEPT).
    pub post_set_op: PostSetOp,

    /// Set when this task originates inside a session transaction block;
    /// keys the per-transaction staging overlay. `None` for autocommit /
    /// non-transactional / system tasks.
    pub txn_id: Option<TxnId>,
}