fosk 0.1.6

In-memory SQL-like query engine and lightweight data store for testing and prototyping.
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

use crate::{parser::{
    aggregators_helper::Accumulator,
    analyzer::{AnalysisContext, AnalyzerError},
    ast::Function
}, JsonPrimitive};

/// Per-aggregate metadata + factory.
/// One instance is registered globally per function name.
/// It is stateless and thread-safe to share.
pub trait AggregateImpl: Send + Sync {
    /// Canonical lowercase function name ("count", "sum", ...).
    fn name(&self) -> &'static str;

    /// Type inference for this function.
    /// - args are as in the parsed Function (qualified & folded already).
    /// - return (type, nullable)
    fn infer_type(&self, fun: &Function, ctx: &AnalysisContext) -> Result<(JsonPrimitive, bool), AnalyzerError>;

    /// Whether constant folding is allowed for this aggregate (usually false).
    fn allow_fold(&self) -> bool { false }

    /// Create a fresh accumulator instance for one group.
    fn create_accumulator(&self) -> Box<dyn Accumulator>;
}