be/src/exprs/aggregate/aggregate_function_histogram.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 <map> |
21 | | #include <memory> |
22 | | #include <string> |
23 | | #include <utility> |
24 | | #include <vector> |
25 | | |
26 | | #include "common/exception.h" |
27 | | #include "common/status.h" |
28 | | #include "core/assert_cast.h" |
29 | | #include "core/column/column.h" |
30 | | #include "core/column/column_decimal.h" |
31 | | #include "core/column/column_string.h" |
32 | | #include "core/data_type/data_type_string.h" |
33 | | #include "core/string_ref.h" |
34 | | #include "core/types.h" |
35 | | #include "exec/common/histogram_helpers.hpp" |
36 | | #include "exprs/aggregate/aggregate_function.h" |
37 | | #include "exprs/aggregate/aggregate_function_simple_factory.h" |
38 | | #include "util/io_helper.h" |
39 | | |
40 | | namespace doris { |
41 | | #include "common/compile_check_begin.h" |
42 | | } // namespace doris |
43 | | |
44 | | namespace doris { |
45 | | |
46 | | template <PrimitiveType T> |
47 | | struct AggregateFunctionHistogramData { |
48 | | static constexpr auto Ptype = T; |
49 | | using ColVecType = typename PrimitiveTypeTraits<T>::ColumnType; |
50 | | const static size_t DEFAULT_BUCKET_NUM = 128; |
51 | | const static size_t BUCKET_NUM_INIT_VALUE = 0; |
52 | | |
53 | 3.80k | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; }Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE14set_parametersEm _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE14set_parametersEm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE14set_parametersEm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE14set_parametersEm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE14set_parametersEm _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE14set_parametersEm Line | Count | Source | 53 | 2.00k | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE14set_parametersEm Line | Count | Source | 53 | 200 | void set_parameters(size_t input_max_num_buckets) { max_num_buckets = input_max_num_buckets; } |
|
54 | | |
55 | 0 | void reset() { ordered_map.clear(); }Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE5resetEv Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE5resetEv |
56 | | |
57 | 2.00k | void add(const StringRef& value, const UInt64& number = 1) { |
58 | 2.00k | std::string data = value.to_string(); |
59 | 2.00k | auto it = ordered_map.find(data); |
60 | 2.00k | if (it != ordered_map.end()) { |
61 | 0 | it->second = it->second + number; |
62 | 2.00k | } else { |
63 | 2.00k | ordered_map.insert({data, number}); |
64 | 2.00k | } |
65 | 2.00k | } |
66 | | |
67 | 1.80k | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { |
68 | 1.80k | auto it = ordered_map.find(value); |
69 | 1.80k | if (it != ordered_map.end()) { |
70 | 0 | it->second = it->second + number; |
71 | 1.80k | } else { |
72 | 1.80k | ordered_map.insert({value, number}); |
73 | 1.80k | } |
74 | 1.80k | } Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE3addERKhRKm _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE3addERKaRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE3addERKsRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE3addERKiRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE3addERKlRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE3addERKnRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE3addERKfRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE3addERKdRKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE3addERKNS_7DecimalIiEERKm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE3addERKNS_7DecimalIlEERKm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE3addERKNS_12Decimal128V3ERKm Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE3addERKNS_7DecimalIN4wide7integerILm256EiEEEERKm _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE3addERKNS_11DateV2ValueINS_15DateV2ValueTypeEEERKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE3addERKNS_11DateV2ValueINS_19DateTimeV2ValueTypeEEERKm Line | Count | Source | 67 | 200 | void add(const typename PrimitiveTypeTraits<T>::CppType& value, const UInt64& number = 1) { | 68 | 200 | auto it = ordered_map.find(value); | 69 | 200 | if (it != ordered_map.end()) { | 70 | 0 | it->second = it->second + number; | 71 | 200 | } else { | 72 | 200 | ordered_map.insert({value, number}); | 73 | 200 | } | 74 | 200 | } |
|
75 | | |
76 | 18 | void merge(const AggregateFunctionHistogramData& rhs) { |
77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null |
78 | | // we should discard this data, because histogram only fouce on the not-null data |
79 | 18 | if (!rhs.max_num_buckets) { |
80 | 8 | return; |
81 | 8 | } |
82 | | |
83 | 10 | max_num_buckets = rhs.max_num_buckets; |
84 | | |
85 | 1.90k | for (auto rhs_it : rhs.ordered_map) { |
86 | 1.90k | auto lhs_it = ordered_map.find(rhs_it.first); |
87 | 1.90k | if (lhs_it != ordered_map.end()) { |
88 | 1.90k | lhs_it->second += rhs_it.second; |
89 | 1.90k | } else { |
90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); |
91 | 0 | } |
92 | 1.90k | } |
93 | 10 | } Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE5mergeERKS2_ _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE5mergeERKS2_ Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE5mergeERKS2_ Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE5mergeERKS2_ Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE5mergeERKS2_ _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE5mergeERKS2_ Line | Count | Source | 76 | 2 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 2 | if (!rhs.max_num_buckets) { | 80 | 1 | return; | 81 | 1 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 1.00k | for (auto rhs_it : rhs.ordered_map) { | 86 | 1.00k | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 1.00k | if (lhs_it != ordered_map.end()) { | 88 | 1.00k | lhs_it->second += rhs_it.second; | 89 | 1.00k | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 1.00k | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE5mergeERKS2_ Line | Count | Source | 76 | 1 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 1 | if (!rhs.max_num_buckets) { | 80 | 0 | return; | 81 | 0 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE5mergeERKS2_ Line | Count | Source | 76 | 1 | void merge(const AggregateFunctionHistogramData& rhs) { | 77 | | // if rhs.max_num_buckets == 0, it means the input block for serialization is all null | 78 | | // we should discard this data, because histogram only fouce on the not-null data | 79 | 1 | if (!rhs.max_num_buckets) { | 80 | 0 | return; | 81 | 0 | } | 82 | | | 83 | 1 | max_num_buckets = rhs.max_num_buckets; | 84 | | | 85 | 100 | for (auto rhs_it : rhs.ordered_map) { | 86 | 100 | auto lhs_it = ordered_map.find(rhs_it.first); | 87 | 100 | if (lhs_it != ordered_map.end()) { | 88 | 100 | lhs_it->second += rhs_it.second; | 89 | 100 | } else { | 90 | 0 | ordered_map.insert({rhs_it.first, rhs_it.second}); | 91 | 0 | } | 92 | 100 | } | 93 | 1 | } |
|
94 | | |
95 | 18 | void write(BufferWritable& buf) const { |
96 | 18 | buf.write_binary(max_num_buckets); |
97 | 18 | auto element_number = (size_t)ordered_map.size(); |
98 | 18 | buf.write_binary(element_number); |
99 | | |
100 | 18 | auto pair_vector = map_to_vector(); |
101 | | |
102 | 1.91k | for (auto i = 0; i < element_number; i++) { |
103 | 1.90k | auto element = pair_vector[i]; |
104 | 1.90k | buf.write_binary(element.second); |
105 | 1.90k | buf.write_binary(element.first); |
106 | 1.90k | } |
107 | 18 | } Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE5writeERNS_14BufferWritableE _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 102 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 2 | } |
Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE5writeERNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE5writeERNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE5writeERNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE5writeERNS_14BufferWritableE _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 2 | void write(BufferWritable& buf) const { | 96 | 2 | buf.write_binary(max_num_buckets); | 97 | 2 | auto element_number = (size_t)ordered_map.size(); | 98 | 2 | buf.write_binary(element_number); | 99 | | | 100 | 2 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 1.00k | for (auto i = 0; i < element_number; i++) { | 103 | 1.00k | auto element = pair_vector[i]; | 104 | 1.00k | buf.write_binary(element.second); | 105 | 1.00k | buf.write_binary(element.first); | 106 | 1.00k | } | 107 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 1 | void write(BufferWritable& buf) const { | 96 | 1 | buf.write_binary(max_num_buckets); | 97 | 1 | auto element_number = (size_t)ordered_map.size(); | 98 | 1 | buf.write_binary(element_number); | 99 | | | 100 | 1 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 101 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 1 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE5writeERNS_14BufferWritableE Line | Count | Source | 95 | 1 | void write(BufferWritable& buf) const { | 96 | 1 | buf.write_binary(max_num_buckets); | 97 | 1 | auto element_number = (size_t)ordered_map.size(); | 98 | 1 | buf.write_binary(element_number); | 99 | | | 100 | 1 | auto pair_vector = map_to_vector(); | 101 | | | 102 | 101 | for (auto i = 0; i < element_number; i++) { | 103 | 100 | auto element = pair_vector[i]; | 104 | 100 | buf.write_binary(element.second); | 105 | 100 | buf.write_binary(element.first); | 106 | 100 | } | 107 | 1 | } |
|
108 | | |
109 | 18 | void read(BufferReadable& buf) { |
110 | 18 | buf.read_binary(max_num_buckets); |
111 | | |
112 | 18 | size_t element_number = 0; |
113 | 18 | buf.read_binary(element_number); |
114 | | |
115 | 18 | ordered_map.clear(); |
116 | 18 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; |
117 | 1.91k | for (auto i = 0; i < element_number; i++) { |
118 | 1.90k | buf.read_binary(element.first); |
119 | 1.90k | buf.read_binary(element.second); |
120 | 1.90k | ordered_map.insert(element); |
121 | 1.90k | } |
122 | 18 | } Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE4readERNS_14BufferReadableE _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 102 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 2 | } |
Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE4readERNS_14BufferReadableE Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE4readERNS_14BufferReadableE Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE4readERNS_14BufferReadableE Unexecuted instantiation: _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE4readERNS_14BufferReadableE _ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 2 | void read(BufferReadable& buf) { | 110 | 2 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 2 | size_t element_number = 0; | 113 | 2 | buf.read_binary(element_number); | 114 | | | 115 | 2 | ordered_map.clear(); | 116 | 2 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 1.00k | for (auto i = 0; i < element_number; i++) { | 118 | 1.00k | buf.read_binary(element.first); | 119 | 1.00k | buf.read_binary(element.second); | 120 | 1.00k | ordered_map.insert(element); | 121 | 1.00k | } | 122 | 2 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 1 | void read(BufferReadable& buf) { | 110 | 1 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 1 | size_t element_number = 0; | 113 | 1 | buf.read_binary(element_number); | 114 | | | 115 | 1 | ordered_map.clear(); | 116 | 1 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 101 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 1 | } |
_ZN5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE4readERNS_14BufferReadableE Line | Count | Source | 109 | 1 | void read(BufferReadable& buf) { | 110 | 1 | buf.read_binary(max_num_buckets); | 111 | | | 112 | 1 | size_t element_number = 0; | 113 | 1 | buf.read_binary(element_number); | 114 | | | 115 | 1 | ordered_map.clear(); | 116 | 1 | std::pair<typename PrimitiveTypeTraits<T>::CppType, size_t> element; | 117 | 101 | for (auto i = 0; i < element_number; i++) { | 118 | 100 | buf.read_binary(element.first); | 119 | 100 | buf.read_binary(element.second); | 120 | 100 | ordered_map.insert(element); | 121 | 100 | } | 122 | 1 | } |
|
123 | | |
124 | | void insert_result_into(IColumn& to) const { |
125 | | auto pair_vector = map_to_vector(); |
126 | | for (auto i = 0; i < pair_vector.size(); i++) { |
127 | | const auto& element = pair_vector[i]; |
128 | | if constexpr (is_string_type(T)) { |
129 | | assert_cast<ColumnString&>(to).insert_data(element.second.c_str(), |
130 | | element.second.length()); |
131 | | } else { |
132 | | assert_cast<ColVecType&>(to).get_data().push_back(element.second); |
133 | | } |
134 | | } |
135 | | } |
136 | | |
137 | 36 | std::string get(const DataTypePtr& data_type) const { |
138 | 36 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; |
139 | 36 | rapidjson::StringBuffer buffer; |
140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, |
141 | | // when target column is nullable, and input block is all null, |
142 | | // set_parameters will not be called because of the short-circuit in |
143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. |
144 | 36 | build_histogram( |
145 | 36 | buckets, ordered_map, |
146 | 36 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); |
147 | 36 | histogram_to_json(buffer, buckets, data_type); |
148 | 36 | return {buffer.GetString()}; |
149 | 36 | } Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 4 | std::string get(const DataTypePtr& data_type) const { | 138 | 4 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 4 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 4 | build_histogram( | 145 | 4 | buckets, ordered_map, | 146 | 4 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 4 | histogram_to_json(buffer, buckets, data_type); | 148 | 4 | return {buffer.GetString()}; | 149 | 4 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 2 | std::string get(const DataTypePtr& data_type) const { | 138 | 2 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 2 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 2 | build_histogram( | 145 | 2 | buckets, ordered_map, | 146 | 2 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 2 | histogram_to_json(buffer, buckets, data_type); | 148 | 2 | return {buffer.GetString()}; | 149 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE3getB5cxx11ERKSt10shared_ptrIKNS_9IDataTypeEE Line | Count | Source | 137 | 2 | std::string get(const DataTypePtr& data_type) const { | 138 | 2 | std::vector<Bucket<typename PrimitiveTypeTraits<T>::CppType>> buckets; | 139 | 2 | rapidjson::StringBuffer buffer; | 140 | | // NOTE: We need an extral branch for to handle max_num_buckets == 0, | 141 | | // when target column is nullable, and input block is all null, | 142 | | // set_parameters will not be called because of the short-circuit in | 143 | | // AggregateFunctionNullVariadicInline, so max_num_buckets will be 0 in this situation. | 144 | 2 | build_histogram( | 145 | 2 | buckets, ordered_map, | 146 | 2 | max_num_buckets == BUCKET_NUM_INIT_VALUE ? DEFAULT_BUCKET_NUM : max_num_buckets); | 147 | 2 | histogram_to_json(buffer, buckets, data_type); | 148 | 2 | return {buffer.GetString()}; | 149 | 2 | } |
|
150 | | |
151 | 18 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { |
152 | 18 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; |
153 | 1.90k | for (auto it : ordered_map) { |
154 | 1.90k | pair_vector.emplace_back(it.second, it.first); |
155 | 1.90k | } |
156 | 18 | return pair_vector; |
157 | 18 | } Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EE13map_to_vectorEv _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EE13map_to_vectorEv Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EE13map_to_vectorEv Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EE13map_to_vectorEv Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EE13map_to_vectorEv Unexecuted instantiation: _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EE13map_to_vectorEv _ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EE13map_to_vectorB5cxx11Ev Line | Count | Source | 151 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 2 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 1.00k | for (auto it : ordered_map) { | 154 | 1.00k | pair_vector.emplace_back(it.second, it.first); | 155 | 1.00k | } | 156 | 2 | return pair_vector; | 157 | 2 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EE13map_to_vectorEv Line | Count | Source | 151 | 1 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 1 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 1 | return pair_vector; | 157 | 1 | } |
_ZNK5doris30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EE13map_to_vectorEv Line | Count | Source | 151 | 1 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> map_to_vector() const { | 152 | 1 | std::vector<std::pair<size_t, typename PrimitiveTypeTraits<T>::CppType>> pair_vector; | 153 | 100 | for (auto it : ordered_map) { | 154 | 100 | pair_vector.emplace_back(it.second, it.first); | 155 | 100 | } | 156 | 1 | return pair_vector; | 157 | 1 | } |
|
158 | | |
159 | | private: |
160 | | size_t max_num_buckets = BUCKET_NUM_INIT_VALUE; |
161 | | std::map<typename PrimitiveTypeTraits<T>::CppType, size_t> ordered_map; |
162 | | }; |
163 | | |
164 | | template <typename Data, bool has_input_param> |
165 | | class AggregateFunctionHistogram final |
166 | | : public IAggregateFunctionDataHelper<Data, |
167 | | AggregateFunctionHistogram<Data, has_input_param>>, |
168 | | VarargsExpression, |
169 | | NotNullableAggregateFunction { |
170 | | public: |
171 | | AggregateFunctionHistogram() = default; |
172 | | AggregateFunctionHistogram(const DataTypes& argument_types_) |
173 | 18 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( |
174 | 18 | argument_types_), |
175 | 18 | _argument_type(argument_types_[0]) {}Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
_ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Line | Count | Source | 173 | 1 | : IAggregateFunctionDataHelper<Data, AggregateFunctionHistogram<Data, has_input_param>>( | 174 | 1 | argument_types_), | 175 | 1 | _argument_type(argument_types_[0]) {} |
Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE Unexecuted instantiation: _ZN5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EEC2ERKSt6vectorISt10shared_ptrIKNS_9IDataTypeEESaIS9_EE |
176 | | |
177 | 0 | std::string get_name() const override { return "histogram"; }Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE8get_nameB5cxx11Ev Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE8get_nameB5cxx11Ev |
178 | | |
179 | 0 | DataTypePtr get_return_type() const override { return std::make_shared<DataTypeString>(); }Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE15get_return_typeEv Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE15get_return_typeEv |
180 | | |
181 | | void add(AggregateDataPtr __restrict place, const IColumn** columns, ssize_t row_num, |
182 | 3.80k | Arena&) const override { |
183 | 3.80k | if constexpr (has_input_param) { |
184 | 3.80k | Int32 input_max_num_buckets = |
185 | 3.80k | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); |
186 | 3.80k | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { |
187 | 0 | throw doris::Exception( |
188 | 0 | ErrorCode::INVALID_ARGUMENT, |
189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", |
190 | 0 | input_max_num_buckets, row_num); |
191 | 0 | } |
192 | 3.80k | this->data(place).set_parameters(input_max_num_buckets); |
193 | 3.80k | } else { |
194 | 0 | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); |
195 | 0 | } |
196 | | |
197 | 2.00k | if constexpr (is_string_type(Data::Ptype)) { |
198 | 2.00k | this->data(place).add( |
199 | 2.00k | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) |
200 | 2.00k | .get_data_at(row_num)); |
201 | 2.00k | } else { |
202 | 1.80k | this->data(place).add( |
203 | 1.80k | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( |
204 | 1.80k | *columns[0]) |
205 | 1.80k | .get_data()[row_num]); |
206 | 1.80k | } |
207 | 3.80k | } Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 2.00k | Arena&) const override { | 183 | 2.00k | if constexpr (has_input_param) { | 184 | 2.00k | Int32 input_max_num_buckets = | 185 | 2.00k | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 2.00k | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 2.00k | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | 2.00k | if constexpr (is_string_type(Data::Ptype)) { | 198 | 2.00k | this->data(place).add( | 199 | 2.00k | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | 2.00k | .get_data_at(row_num)); | 201 | | } else { | 202 | | this->data(place).add( | 203 | | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | | *columns[0]) | 205 | | .get_data()[row_num]); | 206 | | } | 207 | 2.00k | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Line | Count | Source | 182 | 200 | Arena&) const override { | 183 | 200 | if constexpr (has_input_param) { | 184 | 200 | Int32 input_max_num_buckets = | 185 | 200 | assert_cast<const ColumnInt32*>(columns[1])->get_element(row_num); | 186 | 200 | if (input_max_num_buckets <= 0 || input_max_num_buckets > 1000000) { | 187 | 0 | throw doris::Exception( | 188 | 0 | ErrorCode::INVALID_ARGUMENT, | 189 | 0 | "Invalid max_num_buckets {}, row_num {}, should be in (0, 1000000]", | 190 | 0 | input_max_num_buckets, row_num); | 191 | 0 | } | 192 | 200 | this->data(place).set_parameters(input_max_num_buckets); | 193 | | } else { | 194 | | this->data(place).set_parameters(Data::DEFAULT_BUCKET_NUM); | 195 | | } | 196 | | | 197 | | if constexpr (is_string_type(Data::Ptype)) { | 198 | | this->data(place).add( | 199 | | assert_cast<const ColumnString&, TypeCheckOnRelease::DISABLE>(*columns[0]) | 200 | | .get_data_at(row_num)); | 201 | 200 | } else { | 202 | 200 | this->data(place).add( | 203 | 200 | assert_cast<const typename Data::ColVecType&, TypeCheckOnRelease::DISABLE>( | 204 | 200 | *columns[0]) | 205 | 200 | .get_data()[row_num]); | 206 | 200 | } | 207 | 200 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE3addEPcPPKNS_7IColumnElRNS_5ArenaE |
208 | | |
209 | 0 | void reset(AggregateDataPtr place) const override { this->data(place).reset(); }Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE5resetEPc Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE5resetEPc |
210 | | |
211 | | void merge(AggregateDataPtr __restrict place, ConstAggregateDataPtr rhs, |
212 | 18 | Arena&) const override { |
213 | 18 | this->data(place).merge(this->data(rhs)); |
214 | 18 | } Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE5mergeEPcPKcRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE5mergeEPcPKcRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE5mergeEPcPKcRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE5mergeEPcPKcRNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE5mergeEPcPKcRNS_5ArenaE Line | Count | Source | 212 | 1 | Arena&) const override { | 213 | 1 | this->data(place).merge(this->data(rhs)); | 214 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE5mergeEPcPKcRNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE5mergeEPcPKcRNS_5ArenaE |
215 | | |
216 | 18 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { |
217 | 18 | this->data(place).write(buf); |
218 | 18 | } Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE9serializeEPKcRNS_14BufferWritableE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE9serializeEPKcRNS_14BufferWritableE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE9serializeEPKcRNS_14BufferWritableE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE9serializeEPKcRNS_14BufferWritableE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE9serializeEPKcRNS_14BufferWritableE Line | Count | Source | 216 | 1 | void serialize(ConstAggregateDataPtr __restrict place, BufferWritable& buf) const override { | 217 | 1 | this->data(place).write(buf); | 218 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE9serializeEPKcRNS_14BufferWritableE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE9serializeEPKcRNS_14BufferWritableE |
219 | | |
220 | | void deserialize(AggregateDataPtr __restrict place, BufferReadable& buf, |
221 | 18 | Arena&) const override { |
222 | 18 | this->data(place).read(buf); |
223 | 18 | } Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Line | Count | Source | 221 | 1 | Arena&) const override { | 222 | 1 | this->data(place).read(buf); | 223 | 1 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE11deserializeEPcRNS_14BufferReadableERNS_5ArenaE |
224 | | |
225 | 36 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { |
226 | 36 | const std::string bucket_json = this->data(place).get(_argument_type); |
227 | 36 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); |
228 | 36 | } Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb1EE18insert_result_intoEPKcRNS_7IColumnE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb1EE18insert_result_intoEPKcRNS_7IColumnE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb1EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE2EEELb0EE18insert_result_intoEPKcRNS_7IColumnE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE3EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE4EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE5EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE6EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE7EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE8EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
_ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE9EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE28EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE29EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE30EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE35EEELb0EE18insert_result_intoEPKcRNS_7IColumnE _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE10EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Line | Count | Source | 225 | 2 | void insert_result_into(ConstAggregateDataPtr __restrict place, IColumn& to) const override { | 226 | 2 | const std::string bucket_json = this->data(place).get(_argument_type); | 227 | 2 | assert_cast<ColumnString&>(to).insert_data(bucket_json.c_str(), bucket_json.length()); | 228 | 2 | } |
Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE25EEELb0EE18insert_result_intoEPKcRNS_7IColumnE Unexecuted instantiation: _ZNK5doris26AggregateFunctionHistogramINS_30AggregateFunctionHistogramDataILNS_13PrimitiveTypeE26EEELb0EE18insert_result_intoEPKcRNS_7IColumnE |
229 | | |
230 | | private: |
231 | | DataTypePtr _argument_type; |
232 | | }; |
233 | | |
234 | | } // namespace doris |
235 | | |
236 | | #include "common/compile_check_end.h" |