Skip to main content

hawdb_executor/
lib.rs

1// Copyright 2026 Nowledge
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15#[doc(hidden)]
16pub mod analytics;
17#[doc(hidden)]
18pub mod batch;
19#[doc(hidden)]
20pub mod binding;
21#[doc(hidden)]
22pub mod blocking;
23pub mod bm25;
24pub mod columnar;
25pub mod concurrent;
26#[doc(hidden)]
27pub mod execution_request;
28#[doc(hidden)]
29pub mod expression;
30#[doc(hidden)]
31pub mod external;
32#[doc(hidden)]
33pub mod external_order;
34pub mod graph;
35mod graph_match;
36#[doc(hidden)]
37pub mod graph_seed;
38#[doc(hidden)]
39pub mod kernel;
40pub mod limit;
41pub mod load_csv;
42pub mod memory;
43pub mod memory_ledger;
44pub mod morsel;
45#[doc(hidden)]
46pub mod mutation;
47#[doc(hidden)]
48pub mod numeric;
49#[doc(hidden)]
50pub mod observer;
51mod output;
52pub use output::QueryOutput;
53#[doc(hidden)]
54pub mod pipeline;
55#[doc(hidden)]
56pub mod predicate;
57pub mod profile;
58mod read_output;
59#[doc(hidden)]
60pub mod result_delivery;
61#[doc(hidden)]
62pub mod runtime_admission;
63#[doc(hidden)]
64pub mod scan;
65pub mod scoring;
66#[doc(hidden)]
67pub mod spill;
68#[doc(hidden)]
69pub mod store;
70mod store_adapter;
71#[doc(hidden)]
72pub mod transform;
73#[doc(hidden)]
74pub mod traversal;
75pub mod vector;
76pub mod vector_eligibility;
77
78pub use binding::value_payload_bytes as query_value_payload_bytes;
79
80pub use columnar::{
81    filter_boolean_column, filter_float64_values, filter_float64_values_view, filter_int64_values,
82    filter_int64_values_view, filter_numeric_column, select_float64_values_view,
83    select_int64_values_view, BindingSchema, ColumnType, ColumnVector, ColumnarBatch,
84    ColumnarRowRef, NumericLiteral, NumericPredicate, RelationalRowLocator, Selection,
85    SlotDescriptor, SlotId, SlotType, Validity, ValidityBuilder, ValidityView,
86};
87pub use concurrent::{BoundedExecutor, SharedExecutorPool, SharedExecutorPoolError};
88pub use external::{
89    ExternalReadOperator, ExternalReadResourceContract, ExternalReadResultBudget,
90    TextSeedExecutionOutput, TextSeedExecutionRequest, TextSeedExecutionRow,
91    VectorIndexExecutionOutput, VectorIndexExecutionRequest, VectorIndexExecutionRow,
92    VectorSeedExecutionOutput, VectorSeedExecutionRequest, VectorSeedExecutionRow,
93};
94pub use graph::{GraphExpansionExecutionReport, GraphExpansionTruncationReason};
95pub use limit::ExecutionLimit;
96pub use memory::ExecutionMemoryConfig;
97pub use memory_ledger::{
98    QueryMemoryAccount, QueryMemoryClass, QueryMemoryClassSnapshot, QueryMemoryLease,
99    QueryMemoryLedger, QueryMemoryLedgerSnapshot,
100};
101pub use morsel::{
102    admit_morsels, execute_morsels_ordered, Morsel, MorselAdmission, MorselAdmissionRequest,
103    MorselIter, MorselOrdinal, MorselOutput, MorselStreamControl, MorselStreamReport,
104    MorselStreamResources, PipelineId, SequentialMorselScheduler, SharedPoolMorselScheduler,
105};
106mod retrieval_report;
107pub use profile::{
108    BlockingOperatorMemoryReport, OperatorCardinalityProfile, PipelineMemoryReport,
109    ProfiledQueryRows, ProfiledQueryStream, ProjectedRowRef, QueryRow, QueryRowRef, QueryRows,
110    QueryRowsBuilder, QueryRowsIntoIter, QueryRowsIter, QuerySchema, QueryValueRows,
111    ReadExecutionProfile, Row, RowRef, RowRefIter,
112};
113pub use read_output::{BoundedReadQueryOutput, QueryStreamOptions, QueryStreamReport};
114pub use retrieval_report::{
115    GroupedEvidenceExecutionReport, TextSeedExecutionReport, TextSeedSourceReport,
116};
117pub use spill::SpillPoolSnapshot;
118pub use vector::{
119    execute_vector_plan, VectorCandidate, VectorCandidateBatch, VectorCandidateScanMetrics,
120    VectorCandidateScanRequest, VectorCompressionMode, VectorExecutionBackend,
121    VectorExecutionError, VectorExecutionOutput, VectorExecutionReport, VectorExecutionSource,
122    VectorFallbackReasonCode, VectorRawRerankRequest, VectorRawScore, VectorResidualFilterRequest,
123    VectorScoreSource,
124};