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
43
44
45

//! Max-semiring optimized aggregation code generation.
//!
//! Encodes `max` aggregation in the diff position using `MaxI32`/`MaxI64` semigroups,
//! replacing expensive reduce arrangements with lightweight `threshold_semigroup` or
//! `consolidate` pipelines.
//!
//! Mirror of the min-semiring pipeline with `>` instead of `<`.

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 Max-semiring optimized aggregation pipeline.
pub(crate) fn aggregation_max_optimize(
    arity: usize,
    agg_pos: usize,
    agg_type: DataType,
) -> TokenStream {
    aggregation_optimize_pipeline(
        arity,
        agg_pos,
        row_pattern(arity),
        agg_semiring_new(AggregationOperator::Max, agg_pos, agg_type),
        ThresholdCmp::Gt,
        result_from_key(arity, agg_pos),
    )
}

/// Generates the pre-leave conversion for max-aggregated recursive relations.
pub(crate) fn aggregation_max_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::Max, agg_pos, agg_type),
    )
}