Coverage Report

Created: 2026-09-17 20:04

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
78
                                                    const AggregateFunctionAttr& attr) {
34
78
    if (distinct) {
35
34
        if constexpr (T == INVALID_TYPE) {
36
0
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
0
                            "unexpected type for collect, please check the input");
38
34
        } else {
39
34
            return creator_without_type::create<AggregateFunctionCollect<
40
34
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
34
                    argument_types, result_is_nullable, attr);
42
34
        }
43
44
    } else {
44
44
        return creator_without_type::create<
45
44
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
44
                argument_types, result_is_nullable, attr);
47
44
    }
48
78
}
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
14
                                                    const AggregateFunctionAttr& attr) {
34
14
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
7
        } else {
39
7
            return creator_without_type::create<AggregateFunctionCollect<
40
7
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
7
                    argument_types, result_is_nullable, attr);
42
7
        }
43
7
    } else {
44
7
        return creator_without_type::create<
45
7
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
7
                argument_types, result_is_nullable, attr);
47
7
    }
48
14
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE6ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
2
                                                    const AggregateFunctionAttr& attr) {
34
2
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
1
        } else {
39
1
            return creator_without_type::create<AggregateFunctionCollect<
40
1
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
1
                    argument_types, result_is_nullable, attr);
42
1
        }
43
1
    } else {
44
1
        return creator_without_type::create<
45
1
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
1
                argument_types, result_is_nullable, attr);
47
1
    }
48
2
}
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
14
                                                    const AggregateFunctionAttr& attr) {
34
14
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
7
        } else {
39
7
            return creator_without_type::create<AggregateFunctionCollect<
40
7
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
7
                    argument_types, result_is_nullable, attr);
42
7
        }
43
7
    } else {
44
7
        return creator_without_type::create<
45
7
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
7
                argument_types, result_is_nullable, attr);
47
7
    }
48
14
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE0ELb1EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
5
                                                    const AggregateFunctionAttr& attr) {
34
5
    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
5
    } else {
44
5
        return creator_without_type::create<
45
5
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
5
                argument_types, result_is_nullable, attr);
47
5
    }
48
5
}
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
2
                                                    const AggregateFunctionAttr& attr) {
34
2
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
1
        } else {
39
1
            return creator_without_type::create<AggregateFunctionCollect<
40
1
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
1
                    argument_types, result_is_nullable, attr);
42
1
        }
43
1
    } else {
44
1
        return creator_without_type::create<
45
1
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
1
                argument_types, result_is_nullable, attr);
47
1
    }
48
2
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE4ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
2
                                                    const AggregateFunctionAttr& attr) {
34
2
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
1
        } else {
39
1
            return creator_without_type::create<AggregateFunctionCollect<
40
1
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
1
                    argument_types, result_is_nullable, attr);
42
1
        }
43
1
    } else {
44
1
        return creator_without_type::create<
45
1
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
1
                argument_types, result_is_nullable, attr);
47
1
    }
48
2
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE5ELb0EEESt10shared_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_13PrimitiveTypeE6ELb0EEESt10shared_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_13PrimitiveTypeE7ELb0EEESt10shared_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_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
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_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
2
                                                    const AggregateFunctionAttr& attr) {
34
2
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
1
        } else {
39
1
            return creator_without_type::create<AggregateFunctionCollect<
40
1
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
1
                    argument_types, result_is_nullable, attr);
42
1
        }
43
1
    } else {
44
1
        return creator_without_type::create<
45
1
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
1
                argument_types, result_is_nullable, attr);
47
1
    }
48
2
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE26ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
2
                                                    const AggregateFunctionAttr& attr) {
34
2
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
1
        } else {
39
1
            return creator_without_type::create<AggregateFunctionCollect<
40
1
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
1
                    argument_types, result_is_nullable, attr);
42
1
        }
43
1
    } else {
44
1
        return creator_without_type::create<
45
1
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
1
                argument_types, result_is_nullable, attr);
47
1
    }
48
2
}
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
10
                                                    const AggregateFunctionAttr& attr) {
34
10
    if (distinct) {
35
        if constexpr (T == INVALID_TYPE) {
36
            throw Exception(ErrorCode::INTERNAL_ERROR,
37
                            "unexpected type for collect, please check the input");
38
5
        } else {
39
5
            return creator_without_type::create<AggregateFunctionCollect<
40
5
                    AggregateFunctionCollectSetData<T, HasLimit>, HasLimit>>(
41
5
                    argument_types, result_is_nullable, attr);
42
5
        }
43
5
    } else {
44
5
        return creator_without_type::create<
45
5
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
5
                argument_types, result_is_nullable, attr);
47
5
    }
48
10
}
_ZN5doris30do_create_agg_function_collectILNS_13PrimitiveTypeE0ELb0EEESt10shared_ptrINS_18IAggregateFunctionEEbRKSt6vectorIS2_IKNS_9IDataTypeEESaIS8_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
33
5
                                                    const AggregateFunctionAttr& attr) {
34
5
    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
5
    } else {
44
5
        return creator_without_type::create<
45
5
                AggregateFunctionCollect<AggregateFunctionCollectListData<T, HasLimit>, HasLimit>>(
46
5
                argument_types, result_is_nullable, attr);
47
5
    }
48
5
}
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
78
                                                            const AggregateFunctionAttr& attr) {
56
78
    bool distinct = name == "collect_set";
57
58
78
    AggregateFunctionPtr agg_fn;
59
78
    auto call = [&](const auto& type) -> bool {
60
68
        using DispatcType = std::decay_t<decltype(type)>;
61
68
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
68
                distinct, argument_types, result_is_nullable, attr);
63
68
        return true;
64
68
    };
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
14
    auto call = [&](const auto& type) -> bool {
60
14
        using DispatcType = std::decay_t<decltype(type)>;
61
14
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
14
                distinct, argument_types, result_is_nullable, attr);
63
14
        return true;
64
14
    };
_ZZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE6EEEEEbSP_
Line
Count
Source
59
2
    auto call = [&](const auto& type) -> bool {
60
2
        using DispatcType = std::decay_t<decltype(type)>;
61
2
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
2
                distinct, argument_types, result_is_nullable, attr);
63
2
        return true;
64
2
    };
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
14
    auto call = [&](const auto& type) -> bool {
60
14
        using DispatcType = std::decay_t<decltype(type)>;
61
14
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
14
                distinct, argument_types, result_is_nullable, attr);
63
14
        return true;
64
14
    };
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
2
    auto call = [&](const auto& type) -> bool {
60
2
        using DispatcType = std::decay_t<decltype(type)>;
61
2
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
2
                distinct, argument_types, result_is_nullable, attr);
63
2
        return true;
64
2
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE4EEEEEbSP_
Line
Count
Source
59
2
    auto call = [&](const auto& type) -> bool {
60
2
        using DispatcType = std::decay_t<decltype(type)>;
61
2
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
2
                distinct, argument_types, result_is_nullable, attr);
63
2
        return true;
64
2
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE5EEEEEbSP_
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_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
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE7EEEEEbSP_
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_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
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_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
2
    auto call = [&](const auto& type) -> bool {
60
2
        using DispatcType = std::decay_t<decltype(type)>;
61
2
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
2
                distinct, argument_types, result_is_nullable, attr);
63
2
        return true;
64
2
    };
_ZZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrEENKUlRKT_E_clINS_16DispatchDataTypeILNS_13PrimitiveTypeE26EEEEEbSP_
Line
Count
Source
59
2
    auto call = [&](const auto& type) -> bool {
60
2
        using DispatcType = std::decay_t<decltype(type)>;
61
2
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
2
                distinct, argument_types, result_is_nullable, attr);
63
2
        return true;
64
2
    };
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
10
    auto call = [&](const auto& type) -> bool {
60
10
        using DispatcType = std::decay_t<decltype(type)>;
61
10
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
10
                distinct, argument_types, result_is_nullable, attr);
63
10
        return true;
64
10
    };
65
66
78
    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
78
    return agg_fn;
72
78
}
_ZN5doris38create_aggregate_function_collect_implILb1EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
55
35
                                                            const AggregateFunctionAttr& attr) {
56
35
    bool distinct = name == "collect_set";
57
58
35
    AggregateFunctionPtr agg_fn;
59
35
    auto call = [&](const auto& type) -> bool {
60
35
        using DispatcType = std::decay_t<decltype(type)>;
61
35
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
35
                distinct, argument_types, result_is_nullable, attr);
63
35
        return true;
64
35
    };
65
66
35
    if (!dispatch_switch_all(argument_types[0]->get_primitive_type(), call)) {
67
        // We do not care what the real type is.
68
5
        agg_fn = do_create_agg_function_collect<INVALID_TYPE, HasLimit>(distinct, argument_types,
69
5
                                                                        result_is_nullable, attr);
70
5
    }
71
35
    return agg_fn;
72
35
}
_ZN5doris38create_aggregate_function_collect_implILb0EEESt10shared_ptrINS_18IAggregateFunctionEERKNSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEERKSt6vectorIS1_IKNS_9IDataTypeEESaISF_EEbRKNS_21AggregateFunctionAttrE
Line
Count
Source
55
43
                                                            const AggregateFunctionAttr& attr) {
56
43
    bool distinct = name == "collect_set";
57
58
43
    AggregateFunctionPtr agg_fn;
59
43
    auto call = [&](const auto& type) -> bool {
60
43
        using DispatcType = std::decay_t<decltype(type)>;
61
43
        agg_fn = do_create_agg_function_collect<DispatcType::PType, HasLimit>(
62
43
                distinct, argument_types, result_is_nullable, attr);
63
43
        return true;
64
43
    };
65
66
43
    if (!dispatch_switch_all(argument_types[0]->get_primitive_type(), call)) {
67
        // We do not care what the real type is.
68
5
        agg_fn = do_create_agg_function_collect<INVALID_TYPE, HasLimit>(distinct, argument_types,
69
5
                                                                        result_is_nullable, attr);
70
5
    }
71
43
    return agg_fn;
72
43
}
73
74
} // namespace doris