lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
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

#include "function/aggregate/min_max.h"

#include "common/type_utils.h"
#include "function/comparison/comparison_functions.h"

namespace lbug {
namespace function {

using namespace lbug::common;

template<typename FUNC>
static void getMinMaxFunction(std::string name, function_set& set) {
    std::unique_ptr<AggregateFunction> func;
    for (auto& type : LogicalTypeUtils::getAllValidComparableLogicalTypes()) {
        auto inputTypes = std::vector<common::LogicalTypeID>{type};
        for (auto isDistinct : std::vector<bool>{true, false}) {
            common::TypeUtils::visit(
                LogicalType::getPhysicalType(type),
                [&]<ComparableTypes T>(T) {
                    func = std::make_unique<AggregateFunction>(name, inputTypes, type,
                        MinMaxFunction<T>::initialize, MinMaxFunction<T>::template updateAll<FUNC>,
                        MinMaxFunction<T>::template updatePos<FUNC>,
                        MinMaxFunction<T>::template combine<FUNC>, MinMaxFunction<T>::finalize,
                        isDistinct);
                },
                [](auto) { UNREACHABLE_CODE; });
            set.push_back(std::move(func));
        }
    }
}

function_set AggregateMinFunction::getFunctionSet() {
    function_set result;
    getMinMaxFunction<LessThan>(AggregateMinFunction::name, result);
    return result;
}

function_set AggregateMaxFunction::getFunctionSet() {
    function_set result;
    getMinMaxFunction<GreaterThan>(AggregateMaxFunction::name, result);
    return result;
}

} // namespace function
} // namespace lbug