hawdb-executor 0.7.0

An embedded Rust graph database for local data-plane 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
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
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

// Copyright 2026 Nowledge
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#[doc(hidden)]
pub mod analytics;
#[doc(hidden)]
pub mod batch;
#[doc(hidden)]
pub mod binding;
#[doc(hidden)]
pub mod blocking;
pub mod columnar;
pub mod concurrent;
#[doc(hidden)]
pub mod execution_request;
#[doc(hidden)]
pub mod expression;
#[doc(hidden)]
pub mod external;
#[doc(hidden)]
pub mod external_order;
pub mod graph;
mod graph_match;
#[doc(hidden)]
pub mod graph_seed;
#[doc(hidden)]
pub mod kernel;
pub mod limit;
pub mod memory;
pub mod memory_ledger;
pub mod morsel;
#[doc(hidden)]
pub mod mutation;
#[doc(hidden)]
pub mod numeric;
#[doc(hidden)]
pub mod observer;
mod output;
pub use output::QueryOutput;
#[doc(hidden)]
pub mod pipeline;
#[doc(hidden)]
pub mod predicate;
pub mod profile;
mod read_output;
#[doc(hidden)]
pub mod result_delivery;
#[doc(hidden)]
pub mod runtime_admission;
#[doc(hidden)]
pub mod scan;
pub mod scoring;
#[doc(hidden)]
pub mod spill;
#[doc(hidden)]
pub mod store;
mod store_adapter;
#[doc(hidden)]
pub mod transform;
#[doc(hidden)]
pub mod traversal;
pub mod vector;

pub use binding::value_payload_bytes as query_value_payload_bytes;

pub use columnar::{
    filter_boolean_column, filter_float64_values, filter_float64_values_view, filter_int64_values,
    filter_int64_values_view, filter_numeric_column, select_float64_values_view,
    select_int64_values_view, BindingSchema, ColumnType, ColumnVector, ColumnarBatch,
    ColumnarRowRef, NumericLiteral, NumericPredicate, RelationalRowLocator, Selection,
    SlotDescriptor, SlotId, SlotType, Validity, ValidityBuilder, ValidityView,
};
pub use concurrent::{BoundedExecutor, SharedExecutorPool, SharedExecutorPoolError};
pub use external::{
    ExternalReadOperator, ExternalReadResourceContract, ExternalReadResultBudget,
    TextSeedExecutionOutput, TextSeedExecutionRequest, TextSeedExecutionRow,
    VectorSeedExecutionOutput, VectorSeedExecutionRequest, VectorSeedExecutionRow,
};
pub use graph::{GraphExpansionExecutionReport, GraphExpansionTruncationReason};
pub use limit::ExecutionLimit;
pub use memory::ExecutionMemoryConfig;
pub use memory_ledger::{
    QueryMemoryAccount, QueryMemoryClass, QueryMemoryClassSnapshot, QueryMemoryLease,
    QueryMemoryLedger, QueryMemoryLedgerSnapshot,
};
pub use morsel::{
    admit_morsels, execute_morsels_ordered, Morsel, MorselAdmission, MorselAdmissionRequest,
    MorselIter, MorselOrdinal, MorselOutput, MorselStreamControl, MorselStreamReport,
    MorselStreamResources, PipelineId, SequentialMorselScheduler, SharedPoolMorselScheduler,
};
pub use profile::{
    BlockingOperatorMemoryReport, OperatorCardinalityProfile, PipelineMemoryReport,
    ProfiledQueryRows, ProfiledQueryStream, QueryRow, QueryRowRef, QueryRows, QueryRowsBuilder,
    QueryRowsIntoIter, QueryRowsIter, QuerySchema, QueryValueRows, ReadExecutionProfile, Row,
    RowRef, RowRefIter,
};
pub use read_output::{BoundedReadQueryOutput, QueryStreamOptions, QueryStreamReport};
pub use spill::SpillPoolSnapshot;
pub use vector::{
    execute_vector_plan, VectorCandidate, VectorCandidateBatch, VectorCandidateScanMetrics,
    VectorCandidateScanRequest, VectorCompressionMode, VectorExecutionBackend,
    VectorExecutionError, VectorExecutionOutput, VectorExecutionReport, VectorExecutionSource,
    VectorFallbackReasonCode, VectorRawRerankRequest, VectorRawScore, VectorResidualFilterRequest,
    VectorScoreSource,
};