linkrs-query 0.1.0

Query engine, parser, and executor for Linkrs
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

//! Recursive assembly of operators and fragment DAG edges.

use super::super::types::FragmentId;

mod conversion;
pub(super) mod fragment_ops;

pub(super) use conversion::build_subquery_runner_specs;
pub(super) use fragment_ops::BinaryOperatorSpec;
pub(super) use fragment_ops::FragmentCtx;
pub(super) use fragment_ops::HashExchangeParams;

pub(super) struct ArenaPlanAssembler;

pub(super) struct ArenaFragmentAllocator {
    next: usize,
}

impl ArenaFragmentAllocator {
    pub(super) fn new() -> Self {
        Self { next: 0 }
    }

    pub(super) fn allocate(&mut self) -> FragmentId {
        let id = FragmentId(self.next);
        self.next += 1;
        id
    }
}