Coverage Report

Created: 2026-09-28 17:01

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
be/src/exprs/aggregate/aggregate_function_collect_impl.h
Line
Count
Source
1
// Licensed to the Apache Software Foundation (ASF) under one
2
// or more contributor license agreements.  See the NOTICE file
3
// distributed with this work for additional information
4
// regarding copyright ownership.  The ASF licenses this file
5
// to you under the Apache License, Version 2.0 (the
6
// "License"); you may not use this file except in compliance
7
// with the License.  You may obtain a copy of the License at
8
//
9
//   http://www.apache.org/licenses/LICENSE-2.0
10
//
11
// Unless required by applicable law or agreed to in writing,
12
// software distributed under the License is distributed on an
13
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
14
// KIND, either express or implied.  See the License for the
15
// specific language governing permissions and limitations
16
// under the License.
17
18
#pragma once
19
20
#include "common/exception.h"
21
#include "common/status.h"
22
#include "core/call_on_type_index.h"
23
#include "exprs/aggregate/aggregate_function_collect.h"
24
#include "exprs/aggregate/factory_helpers.h"
25
#include "exprs/aggregate/helpers.h"
26
27
namespace doris {
28
29
template <PrimitiveType T, bool HasLimit>
30
AggregateFunctionPtr do_create_agg_function_collect(bool distinct, const DataTypes& argument_types,
31
                                                    const bool result_is_nullable,
32
33
156
                                                    const AggregateFunctionAttr& attr) {
34
156
    if (distinct) {
35
68
        if constexpr (T == INVALID_TYPE) {
36
0
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
0
                            "unexpected type for collect, please check the input");
38
68
        } else {
39
68
            return creator_without_type::create<AggregateFunctionCollect<
40
68
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
68
                    argument_types, result_is_nullable, attr);
42
68
        }
43
88
    } else {
44
88
        return creator_without_type::create<
45
88
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
88
                argument_types, result_is_nullable, attr);
47
88
    }
48
156
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE2ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE3ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE4ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE5ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
28
                                                    const AggregateFunctionAttr& attr) {
34
28
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
14
        } else {
39
14
            return creator_without_type::create<AggregateFunctionCollect<
40
14
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
14
                    argument_types, result_is_nullable, attr);
42
14
        }
43
14
    } else {
44
14
        return creator_without_type::create<
45
14
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
14
                argument_types, result_is_nullable, attr);
47
14
    }
48
28
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE6ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
4
                                                    const AggregateFunctionAttr& attr) {
34
4
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
2
        } else {
39
2
            return creator_without_type::create<AggregateFunctionCollect<
40
2
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
2
                    argument_types, result_is_nullable, attr);
42
2
        }
43
2
    } else {
44
2
        return creator_without_type::create<
45
2
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
2
                argument_types, result_is_nullable, attr);
47
2
    }
48
4
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE7ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE8ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE9ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE28ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE29ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE20ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE30ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE35ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE11ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE25ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE26ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE43ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE12ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE27ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE42ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE36ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE37ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE23ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
28
                                                    const AggregateFunctionAttr& attr) {
34
28
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
14
        } else {
39
14
            return creator_without_type::create<AggregateFunctionCollect<
40
14
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
14
                    argument_types, result_is_nullable, attr);
42
14
        }
43
14
    } else {
44
14
        return creator_without_type::create<
45
14
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
14
                argument_types, result_is_nullable, attr);
47
14
    }
48
28
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE0ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
10
                                                    const AggregateFunctionAttr& attr) {
34
10
    if (distinct) {
35
0
        if constexpr (T == INVALID_TYPE) {
36
0
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
0
                            "unexpected type for collect, please check the input");
38
        } else {
39
            return creator_without_type::create<AggregateFunctionCollect<
40
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
                    argument_types, result_is_nullable, attr);
42
        }
43
10
    } else {
44
10
        return creator_without_type::create<
45
10
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
10
                argument_types, result_is_nullable, attr);
47
10
    }
48
10
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE2ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE3ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
4
                                                    const AggregateFunctionAttr& attr) {
34
4
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
2
        } else {
39
2
            return creator_without_type::create<AggregateFunctionCollect<
40
2
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
2
                    argument_types, result_is_nullable, attr);
42
2
        }
43
2
    } else {
44
2
        return creator_without_type::create<
45
2
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
2
                argument_types, result_is_nullable, attr);
47
2
    }
48
4
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE4ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
4
                                                    const AggregateFunctionAttr& attr) {
34
4
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
2
        } else {
39
2
            return creator_without_type::create<AggregateFunctionCollect<
40
2
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
2
                    argument_types, result_is_nullable, attr);
42
2
        }
43
2
    } else {
44
2
        return creator_without_type::create<
45
2
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
2
                argument_types, result_is_nullable, attr);
47
2
    }
48
4
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE5ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
16
                                                    const AggregateFunctionAttr& attr) {
34
16
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
8
        } else {
39
8
            return creator_without_type::create<AggregateFunctionCollect<
40
8
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
8
                    argument_types, result_is_nullable, attr);
42
8
        }
43
8
    } else {
44
8
        return creator_without_type::create<
45
8
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
8
                argument_types, result_is_nullable, attr);
47
8
    }
48
16
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE6ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
8
                                                    const AggregateFunctionAttr& attr) {
34
8
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
4
        } else {
39
4
            return creator_without_type::create<AggregateFunctionCollect<
40
4
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
4
                    argument_types, result_is_nullable, attr);
42
4
        }
43
4
    } else {
44
4
        return creator_without_type::create<
45
4
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
4
                argument_types, result_is_nullable, attr);
47
4
    }
48
8
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE7ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
8
                                                    const AggregateFunctionAttr& attr) {
34
8
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
4
        } else {
39
4
            return creator_without_type::create<AggregateFunctionCollect<
40
4
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
4
                    argument_types, result_is_nullable, attr);
42
4
        }
43
4
    } else {
44
4
        return creator_without_type::create<
45
4
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
4
                argument_types, result_is_nullable, attr);
47
4
    }
48
8
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE8ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE9ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE28ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE29ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE20ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
8
                                                    const AggregateFunctionAttr& attr) {
34
8
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
4
        } else {
39
4
            return creator_without_type::create<AggregateFunctionCollect<
40
4
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
4
                    argument_types, result_is_nullable, attr);
42
4
        }
43
4
    } else {
44
4
        return creator_without_type::create<
45
4
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
4
                argument_types, result_is_nullable, attr);
47
4
    }
48
8
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE30ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE35ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE11ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE25ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
4
                                                    const AggregateFunctionAttr& attr) {
34
4
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
2
        } else {
39
2
            return creator_without_type::create<AggregateFunctionCollect<
40
2
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
2
                    argument_types, result_is_nullable, attr);
42
2
        }
43
2
    } else {
44
2
        return creator_without_type::create<
45
2
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
2
                argument_types, result_is_nullable, attr);
47
2
    }
48
4
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE26ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
4
                                                    const AggregateFunctionAttr& attr) {
34
4
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
2
        } else {
39
2
            return creator_without_type::create<AggregateFunctionCollect<
40
2
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
2
                    argument_types, result_is_nullable, attr);
42
2
        }
43
2
    } else {
44
2
        return creator_without_type::create<
45
2
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
2
                argument_types, result_is_nullable, attr);
47
2
    }
48
4
}
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE43ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE12ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE27ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE42ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE36ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Unexecuted instantiation: _ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE37ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE23ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
20
                                                    const AggregateFunctionAttr& attr) {
34
20
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
10
        } else {
39
10
            return creator_without_type::create<AggregateFunctionCollect<
40
10
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
10
                    argument_types, result_is_nullable, attr);
42
10
        }
43
10
    } else {
44
10
        return creator_without_type::create<
45
10
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
10
                argument_types, result_is_nullable, attr);
47
10
    }
48
20
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE0ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
10
                                                    const AggregateFunctionAttr& attr) {
34
10
    if (distinct) {
35
0
        if constexpr (T == INVALID_TYPE) {
36
0
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
0
                            "unexpected type for collect, please check the input");
38
        } else {
39
            return creator_without_type::create<AggregateFunctionCollect<
40
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
                    argument_types, result_is_nullable, attr);
42
        }
43
10
    } else {
44
10
        return creator_without_type::create<
45
10
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
10
                argument_types, result_is_nullable, attr);
47
10
    }
48
10
}
49
50
template <bool HasLimit>
51
AggregateFunctionPtr create_aggregate_function_collect_impl(const std::string& name,
52
                                                            const DataTypes& argument_types,
53
                                                            const bool result_is_nullable,
54
55
156
                                                            const AggregateFunctionAttr& attr) {
56
156
    bool distinct = name == "collect_set";
57
58
156
    AggregateFunctionPtr agg_fn;
59
156
    auto call = [&](const auto& type) -> bool {
60
136
        using DispatcType = std::decay_t<decltype(type)>;
61
136
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
136
                distinct, argument_types, result_is_nullable, attr);
63
136
        return true;
64
136
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE2EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE3EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE4EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE5EEEEEbSP_
Line
Count
Source
59
28
    auto call = [&](const auto& type) -> bool {
60
28
        using DispatcType = std::decay_t<decltype(type)>;
61
28
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
28
                distinct, argument_types, result_is_nullable, attr);
63
28
        return true;
64
28
    };
_ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE6EEEEEbSP_
Line
Count
Source
59
4
    auto call = [&](const auto& type) -> bool {
60
4
        using DispatcType = std::decay_t<decltype(type)>;
61
4
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
4
                distinct, argument_types, result_is_nullable, attr);
63
4
        return true;
64
4
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE7EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE8EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE9EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE28EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE29EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE20EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE30EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE35EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE11EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE25EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE26EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE43EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE12EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE27EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE42EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE36EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE37EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE23EEEEEbSP_
Line
Count
Source
59
28
    auto call = [&](const auto& type) -> bool {
60
28
        using DispatcType = std::decay_t<decltype(type)>;
61
28
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
28
                distinct, argument_types, result_is_nullable, attr);
63
28
        return true;
64
28
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE2EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE3EEEEEbSP_
Line
Count
Source
59
4
    auto call = [&](const auto& type) -> bool {
60
4
        using DispatcType = std::decay_t<decltype(type)>;
61
4
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
4
                distinct, argument_types, result_is_nullable, attr);
63
4
        return true;
64
4
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE4EEEEEbSP_
Line
Count
Source
59
4
    auto call = [&](const auto& type) -> bool {
60
4
        using DispatcType = std::decay_t<decltype(type)>;
61
4
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
4
                distinct, argument_types, result_is_nullable, attr);
63
4
        return true;
64
4
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE5EEEEEbSP_
Line
Count
Source
59
16
    auto call = [&](const auto& type) -> bool {
60
16
        using DispatcType = std::decay_t<decltype(type)>;
61
16
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
16
                distinct, argument_types, result_is_nullable, attr);
63
16
        return true;
64
16
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE6EEEEEbSP_
Line
Count
Source
59
8
    auto call = [&](const auto& type) -> bool {
60
8
        using DispatcType = std::decay_t<decltype(type)>;
61
8
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
8
                distinct, argument_types, result_is_nullable, attr);
63
8
        return true;
64
8
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE7EEEEEbSP_
Line
Count
Source
59
8
    auto call = [&](const auto& type) -> bool {
60
8
        using DispatcType = std::decay_t<decltype(type)>;
61
8
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
8
                distinct, argument_types, result_is_nullable, attr);
63
8
        return true;
64
8
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE8EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE9EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE28EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE29EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE20EEEEEbSP_
Line
Count
Source
59
8
    auto call = [&](const auto& type) -> bool {
60
8
        using DispatcType = std::decay_t<decltype(type)>;
61
8
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
8
                distinct, argument_types, result_is_nullable, attr);
63
8
        return true;
64
8
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE30EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE35EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE11EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE25EEEEEbSP_
Line
Count
Source
59
4
    auto call = [&](const auto& type) -> bool {
60
4
        using DispatcType = std::decay_t<decltype(type)>;
61
4
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
4
                distinct, argument_types, result_is_nullable, attr);
63
4
        return true;
64
4
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE26EEEEEbSP_
Line
Count
Source
59
4
    auto call = [&](const auto& type) -> bool {
60
4
        using DispatcType = std::decay_t<decltype(type)>;
61
4
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
4
                distinct, argument_types, result_is_nullable, attr);
63
4
        return true;
64
4
    };
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE43EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE12EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE27EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE42EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE36EEEEEbSP_
Unexecuted instantiation: _ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE37EEEEEbSP_
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE23EEEEEbSP_
Line
Count
Source
59
20
    auto call = [&](const auto& type) -> bool {
60
20
        using DispatcType = std::decay_t<decltype(type)>;
61
20
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
20
                distinct, argument_types, result_is_nullable, attr);
63
20
        return true;
64
20
    };
65
66
156
    if (!dispatch_switch_all(argument_types[0]->get_primitive_type(), call)) {
67
        // We do not care what the real type is.
68
20
        agg_fn = do_create_agg_function_collect<INVALID_TYPE, HasLimit>(distinct, argument_types,
69
20
                                                                        result_is_nullable, attr);
70
20
    }
71
156
    return agg_fn;
72
156
}
_ZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
55
70
                                                            const AggregateFunctionAttr& attr) {
56
70
    bool distinct = name == "collect_set";
57
58
70
    AggregateFunctionPtr agg_fn;
59
70
    auto call = [&](const auto& type) -> bool {
60
70
        using DispatcType = std::decay_t<decltype(type)>;
61
70
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
70
                distinct, argument_types, result_is_nullable, attr);
63
70
        return true;
64
70
    };
65
66
70
    if (!dispatch_switch_all(argument_types[0]->get_primitive_type(), call)) {
67
        // We do not care what the real type is.
68
10
        agg_fn = do_create_agg_function_collect<INVALID_TYPE, HasLimit>(distinct, argument_types,
69
10
                                                                        result_is_nullable, attr);
70
10
    }
71
70
    return agg_fn;
72
70
}
_ZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
55
86
                                                            const AggregateFunctionAttr& attr) {
56
86
    bool distinct = name == "collect_set";
57
58
86
    AggregateFunctionPtr agg_fn;
59
86
    auto call = [&](const auto& type) -> bool {
60
86
        using DispatcType = std::decay_t<decltype(type)>;
61
86
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
86
                distinct, argument_types, result_is_nullable, attr);
63
86
        return true;
64
86
    };
65
66
86
    if (!dispatch_switch_all(argument_types[0]->get_primitive_type(), call)) {
67
        // We do not care what the real type is.
68
10
        agg_fn = do_create_agg_function_collect<INVALID_TYPE, HasLimit>(distinct, argument_types,
69
10
                                                                        result_is_nullable, attr);
70
10
    }
71
86
    return agg_fn;
72
86
}
73
74
} // namespace doris