Skip to main content

harmos_storage/
query.rs

1/* ***
2 *
3 * Harmos
4 *
5 * SPDX-License-Identifier: Apache-2.0
6 *
7 * ***
8 */
9
10// Declarative Storage Queries Over Arrow
11
12/* === Modules === */
13
14mod accumulate;
15mod execute;
16mod object_schemas;
17mod order_stats;
18mod ordering;
19mod reader;
20mod reduction;
21mod source;
22mod spill;
23mod table;
24pub mod transform;
25mod typed;
26
27/* === Re-Exports === */
28
29pub use accumulate::Accumulator;
30pub use harmos_domain::model::storage::query::{
31    FileSelection, ObjectSelection, ObjectVersions, QueryCompletion, QueryOutput, RecordSelection, RowSlice, SchemaSelection, Source,
32    StreamSelection, scalar,
33};
34pub(crate) use reader::schema_at;
35pub use reader::{Query, QueryArrow, QueryReader};
36pub use table::{Table, TableReader, TableWriter};
37pub use typed::{ObjectRead, ObjectReader, RecordRead, RecordReader, StreamRead, StreamReader};
38
39/* === Imports === */
40
41// Standard Library Imports
42
43// Third Party Imports
44
45// Local Imports
46
47/* === Constants === */
48
49/* === Macros === */
50
51/* === Type Aliases === */
52
53/* === Structs === */
54
55/* === Enums === */
56
57/* === Traits === */
58
59/* === Implementations === */
60
61/* === Public Functions === */
62
63/* === Private Functions === */
64
65/* === Tests === */