flowlog-build 0.3.4

Build-time FlowLog compiler for library mode.
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

//! Min-semiring optimized aggregation code generation.
//!
//! Encodes `min` aggregation in the diff position using `MinI32`/`MinI64` semigroups,
//! replacing expensive reduce arrangements with lightweight `threshold_semigroup` or
//! `consolidate` pipelines.

use crate::parser::{AggregationOperator, DataType};
use proc_macro2::TokenStream;

use super::common::{
    ThresholdCmp, agg_semiring_new, aggregation_optimize_pipeline, aggregation_pre_leave_pipeline,
    result_from_key, row_pattern,
};
/// Generates the Min-semiring optimized aggregation pipeline.
pub(crate) fn aggregation_min_optimize(
    arity: usize,
    agg_pos: usize,
    agg_type: DataType,
) -> TokenStream {
    aggregation_optimize_pipeline(
        arity,
        agg_pos,
        row_pattern(arity),
        agg_semiring_new(AggregationOperator::Min, agg_pos, agg_type),
        ThresholdCmp::Lt,
        result_from_key(arity, agg_pos),
    )
}

/// Generates the pre-leave conversion for min-aggregated recursive relations.
pub(crate) fn aggregation_min_pre_leave(
    arity: usize,
    agg_pos: usize,
    agg_type: DataType,
) -> TokenStream {
    aggregation_pre_leave_pipeline(
        arity,
        agg_pos,
        row_pattern(arity),
        agg_semiring_new(AggregationOperator::Min, agg_pos, agg_type),
    )
}