nodedb-physical 0.6.2

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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

// SPDX-License-Identifier: Apache-2.0

//! Physical plan types dispatched from Control Plane to Data Plane.
//!
//! The top-level [`PhysicalPlan`] enum delegates to per-engine sub-enums,
//! each defined in its own module. This keeps each engine's operations
//! isolated.

pub mod aggregate_functions;
pub mod array;
pub mod calvin_reply;
pub mod cluster_array;
pub mod cluster_event;
pub mod collection;
pub mod columnar;
pub mod crdt;
pub mod document;
pub mod exchange;
pub mod gathered_source;
pub mod graph;
pub mod kv;
pub mod meta;
pub mod meta_calvin;
pub mod meta_home;
pub mod meta_restore;
pub mod meta_snapshot;
pub mod plan;
pub mod query;
pub mod redo_origin;
pub mod rls_write_check_accessor;
pub mod routing;
pub mod set_op;
pub mod sort_key;
pub mod spatial;
pub mod streaming;
pub mod text;
pub mod tiering;
pub mod timeseries;
pub mod truncate_target;
pub mod vector;
pub mod wire;

pub use aggregate_functions::{
    AggregateParam, GENERIC_AGGREGATE_FUNCTIONS, PARAMETERIZED_AGGREGATE_FUNCTIONS,
};
pub use array::{ArrayBinaryOp, ArrayOp, ArrayReducer};
pub use calvin_reply::{
    CalvinInstall, CalvinInstalledTimeseriesSpec, CalvinPostImagesSpec, CalvinReplyRow,
    CalvinReplySpec, CalvinResolved, CalvinRowEngine,
};
pub use cluster_array::ClusterArrayOp;
pub use cluster_event::{ClusterEventOp, MAX_REMOTE_CDC_COMMITTED_OFFSETS};
pub use columnar::{ColumnarInsertIntent, ColumnarOp};
pub use crdt::{CrdtOp, CrdtWriteVerb};
pub use document::{
    BalancedDef, DeclaredColumn, DocumentOp, DocumentPageSource, DocumentResolveOutcome,
    DocumentResolvedMutation, EnforcementOptions, GeneratedColumnSpec, MaterializedSumBinding,
    OllpPredictedEdge, PeriodLockConfig, QuerySource, RedoSumTargets, RegisteredIndex,
    RegisteredIndexState, ResolvedSumTarget, ReturningColumns, ReturningItem, ReturningSpec,
    RowSource, StorageMode, SumTargetKey, TimeseriesSchema, UpdateValue, resolved_sum_surrogate,
};
pub use exchange::{ExchangeMode, ExchangeOp};
pub use gathered_source::GatheredSource;
pub use graph::{
    AlgoEdge, AlgoStage, BatchEdge, BspSuperstepPlan, BspSuperstepResult, GraphOp, RagBindingRow,
    RagLegs, RagStage, RagTextHit, RagVectorHit, WccSuperstepPlan, WccSuperstepResult,
};
pub use kv::{
    KvBatchIntent, KvCounterShape, KvOp, KvResolveOutcome, KvResolvedMutation, SortedIndexRead,
    SortedIndexSpec, TransferAmount,
};
pub use meta::MetaOp;
pub use meta_home::{HomeAnswer, HomeVersion, HomeVersionProbe};
pub use meta_restore::{RestoredEdgeVersion, RestoredIdentity, RestoredRedo, RestoredRow};
pub use meta_snapshot::{CutCaptureRequest, SnapshotClearTarget};
pub use plan::PhysicalPlan;
pub use query::{AggregateSpec, GroupKeySpec, JoinProjection, QueryOp};
pub use redo_origin::RedoOrigin;
pub use routing::plan_contains_cluster_partitioned_leaf;
pub use set_op::SetOpKind;
pub use sort_key::SortKeySpec;
pub use spatial::{SpatialOp, SpatialPredicate};
pub use text::{ScoreScanBound, ScoreScanOrder, TextOp, TextScoreSpec};
pub use tiering::{TierRead, TierSegment, TierSource, TieringError, TieringPlan};
pub use timeseries::{
    AggregateIncarnation, PartitionsAction, RefreshCut, TimeseriesOp, TimeseriesResolve,
    UNBOUNDED_TIME_RANGE,
};
pub use vector::{
    VectorDirectRow, VectorDirectWriteIntent, VectorOp, VectorResolveOutcome,
    VectorResolvedMutation, VectorWriteTargets,
};
pub use wire::{decode, encode};