/root/doris/be/src/exprs/minmax_predicate.h
Line | Count | Source (jump to first uncovered line) |
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 "exprs/runtime_filter.h" |
21 | | #include "exprs/runtime_filter_convertor.h" |
22 | | |
23 | | namespace doris { |
24 | | // only used in Runtime Filter |
25 | | class MinMaxFuncBase : public RuntimeFilterFuncBase { |
26 | | public: |
27 | | virtual void insert_fixed_len(const vectorized::ColumnPtr& column, size_t start) = 0; |
28 | | virtual void* get_max() = 0; |
29 | | virtual void* get_min() = 0; |
30 | | // assign minmax data |
31 | | virtual Status assign(void* min_data, void* max_data) = 0; |
32 | | // merge from other minmax_func |
33 | | virtual Status merge(MinMaxFuncBase* minmax_func) = 0; |
34 | 0 | virtual ~MinMaxFuncBase() = default; |
35 | | |
36 | 0 | bool contain_null() const { return _null_aware && _contain_null; } |
37 | | |
38 | 0 | void set_contain_null() { _contain_null = true; } |
39 | | |
40 | | virtual void to_pb(PMinMaxFilter* filter) = 0; |
41 | | |
42 | | protected: |
43 | | bool _contain_null = false; |
44 | | }; |
45 | | |
46 | | template <class T, bool NeedMax = true, bool NeedMin = true> |
47 | | class MinMaxNumFunc : public MinMaxFuncBase { |
48 | | public: |
49 | 0 | MinMaxNumFunc() = default; Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EEC2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EEC2Ev |
50 | 0 | ~MinMaxNumFunc() override = default; Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EED2Ev Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EED2Ev |
51 | | |
52 | 0 | void insert_fixed_len(const vectorized::ColumnPtr& column, size_t start) override { |
53 | 0 | if (column->is_nullable()) { |
54 | 0 | const auto* nullable = assert_cast<const vectorized::ColumnNullable*>(column.get()); |
55 | 0 | const auto& col = nullable->get_nested_column_ptr(); |
56 | 0 | const auto& nullmap = nullable->get_null_map_data(); |
57 | 0 | if (nullable->has_null()) { |
58 | 0 | update_batch(col, nullmap, start); |
59 | 0 | _contain_null = true; |
60 | 0 | } else { |
61 | 0 | update_batch(col, start); |
62 | 0 | } |
63 | 0 | } else { |
64 | 0 | update_batch(column, start); |
65 | 0 | } |
66 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrISA_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE16insert_fixed_lenERKNS_3COWINS1_7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE16insert_fixed_lenERKNS_3COWINS1_7IColumnEE13immutable_ptrIS9_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE16insert_fixed_lenERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm |
67 | | |
68 | | void _update_batch_string(const auto& column_string, const uint8_t* __restrict nullmap, |
69 | 0 | size_t start, size_t size) { |
70 | 0 | for (size_t i = start; i < size; i++) { |
71 | 0 | if (nullmap == nullptr || !nullmap[i]) { |
72 | 0 | if constexpr (NeedMin) { |
73 | 0 | if (column_string.get_data_at(i) < StringRef(_min)) { |
74 | 0 | _min = column_string.get_data_at(i).to_string(); |
75 | 0 | } |
76 | 0 | } |
77 | 0 | if constexpr (NeedMax) { |
78 | 0 | if (column_string.get_data_at(i) > StringRef(_max)) { |
79 | 0 | _max = column_string.get_data_at(i).to_string(); |
80 | 0 | } |
81 | 0 | } |
82 | 0 | } |
83 | 0 | } |
84 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE20_update_batch_stringINS_10vectorized9ColumnStrImEEEEvRKT_PKhmm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE20_update_batch_stringINS_10vectorized9ColumnStrIjEEEEvRKT_PKhmm |
85 | | |
86 | 0 | void update_batch(const vectorized::ColumnPtr& column, size_t start) { |
87 | 0 | const auto size = column->size(); |
88 | 0 | if constexpr (std::is_same_v<T, std::string>) { |
89 | 0 | if (column->is_column_string64()) { |
90 | 0 | _update_batch_string(assert_cast<const vectorized::ColumnString64&>(*column), |
91 | 0 | nullptr, start, size); |
92 | 0 | } else { |
93 | 0 | _update_batch_string(assert_cast<const vectorized::ColumnString&>(*column), nullptr, |
94 | 0 | start, size); |
95 | 0 | } |
96 | 0 | } else { |
97 | 0 | const T* data = (T*)column->get_raw_data().data; |
98 | 0 | for (size_t i = start; i < size; i++) { |
99 | 0 | if constexpr (NeedMin) { |
100 | 0 | _min = std::min(_min, *(data + i)); |
101 | 0 | } |
102 | 0 | if constexpr (NeedMax) { |
103 | 0 | _max = std::max(_max, *(data + i)); |
104 | 0 | } |
105 | 0 | } |
106 | 0 | } |
107 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrISA_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS5_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS9_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EEm |
108 | | |
109 | | void update_batch(const vectorized::ColumnPtr& column, const vectorized::NullMap& nullmap, |
110 | 0 | size_t start) { |
111 | 0 | const auto size = column->size(); |
112 | 0 | if constexpr (std::is_same_v<T, std::string>) { |
113 | 0 | if (column->is_column_string64()) { |
114 | 0 | _update_batch_string(assert_cast<const vectorized::ColumnString64&>(*column), |
115 | 0 | nullmap.data(), start, size); |
116 | 0 | } else { |
117 | 0 | _update_batch_string(assert_cast<const vectorized::ColumnString&>(*column), |
118 | 0 | nullmap.data(), start, size); |
119 | 0 | } |
120 | 0 | } else { |
121 | 0 | const T* data = (T*)column->get_raw_data().data; |
122 | 0 | for (size_t i = start; i < size; i++) { |
123 | 0 | if (!nullmap[i]) { |
124 | 0 | if constexpr (NeedMin) { |
125 | 0 | _min = std::min(_min, *(data + i)); |
126 | 0 | } |
127 | 0 | if constexpr (NeedMax) { |
128 | 0 | _max = std::max(_max, *(data + i)); |
129 | 0 | } |
130 | 0 | } |
131 | 0 | } |
132 | 0 | } |
133 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EERKNS4_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS5_EERKNS4_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EERKNS6_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS7_EERKNS6_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrISA_EERKNS9_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EERKNS1_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS6_EERKNS1_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS5_EERKNS1_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE12update_batchERKNS_3COWINS1_7IColumnEE13immutable_ptrIS9_EERKNS1_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE12update_batchERKNS_3COWINS_10vectorized7IColumnEE13immutable_ptrIS4_EERKNS3_8PODArrayIhLm4096E9AllocatorILb0ELb0ELb0E22DefaultMemoryAllocatorELm16ELm15EEEm |
134 | | |
135 | 0 | Status merge(MinMaxFuncBase* minmax_func) override { |
136 | 0 | auto* other_minmax = static_cast<MinMaxNumFunc<T>*>(minmax_func); |
137 | 0 | if constexpr (NeedMin) { |
138 | 0 | if (other_minmax->_min < _min) { |
139 | 0 | _min = other_minmax->_min; |
140 | 0 | } |
141 | 0 | } |
142 | 0 | if constexpr (NeedMax) { |
143 | 0 | if (other_minmax->_max > _max) { |
144 | 0 | _max = other_minmax->_max; |
145 | 0 | } |
146 | 0 | } |
147 | |
|
148 | 0 | _contain_null |= minmax_func->contain_null(); |
149 | 0 | return Status::OK(); |
150 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE5mergeEPNS_14MinMaxFuncBaseE |
151 | | |
152 | 0 | void* get_max() override { return &_max; } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE7get_maxEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE7get_maxEv |
153 | | |
154 | 0 | void* get_min() override { return &_min; } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE7get_minEv Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE7get_minEv |
155 | | |
156 | 0 | Status assign(void* min_data, void* max_data) override { |
157 | 0 | _min = *(T*)min_data; |
158 | 0 | _max = *(T*)max_data; |
159 | 0 | return Status::OK(); |
160 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE6assignEPvS3_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE6assignEPvS3_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE6assignEPvS5_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE6assignEPvS5_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE6assignEPvS8_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE6assignEPvS5_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE6assignEPvS5_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE6assignEPvS4_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE6assignEPvS8_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE6assignEPvS2_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE6assignEPvS2_ |
161 | | |
162 | 0 | void set_pb(PMinMaxFilter* filter, auto f) { |
163 | 0 | if constexpr (NeedMin) { |
164 | 0 | f(filter->mutable_min_val(), _min); |
165 | 0 | } |
166 | 0 | if constexpr (NeedMax) { |
167 | 0 | f(filter->mutable_max_val(), _max); |
168 | 0 | } |
169 | 0 | } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE6set_pbIZNS_13get_convertorIbEEDavEUlPNS_12PColumnValueERKbE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE6set_pbIZNS_13get_convertorIS1_EEDavEUlPNS_12PColumnValueERKS1_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE6set_pbIZNS_13get_convertorIaEEDavEUlPNS_12PColumnValueERKaE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE6set_pbIZNS_13get_convertorIsEEDavEUlPNS_12PColumnValueERKsE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE6set_pbIZNS_13get_convertorIiEEDavEUlPNS_12PColumnValueERKiE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE6set_pbIZNS_13get_convertorIlEEDavEUlPNS_12PColumnValueERKlE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE6set_pbIZNS_13get_convertorInEEDavEUlPNS_12PColumnValueERKnE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE6set_pbIZNS_13get_convertorIfEEDavEUlPNS_12PColumnValueERKfE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE6set_pbIZNS_13get_convertorIdEEDavEUlPNS_12PColumnValueERKdE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE6set_pbIZNS_13get_convertorIS1_EEDavEUlPNS_12PColumnValueERKS1_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE6set_pbIZNS_13get_convertorIS3_EEDavEUlPNS_12PColumnValueERKS3_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE6set_pbIZNS_13get_convertorIS3_EEDavEUlPNS_12PColumnValueERKS3_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE6set_pbIZNS_13get_convertorIS6_EEDavEUlPNS_12PColumnValueERKS6_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE6set_pbIZNS_13get_convertorIS3_EEDavEUlPNS_12PColumnValueERKS3_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE6set_pbIZNS_13get_convertorIS3_EEDavEUlPNS_12PColumnValueERKS3_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE6set_pbIZNS_13get_convertorIS2_EEDavEUlPNS_12PColumnValueERKS2_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE6set_pbIZNS_13get_convertorIS6_EEDavEUlPNS_12PColumnValueERKS6_E_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE6set_pbIZNS_13get_convertorIjEEDavEUlPNS_12PColumnValueERKjE_EEvPNS_13PMinMaxFilterET_ Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE6set_pbIZNS_13get_convertorIoEEDavEUlPNS_12PColumnValueERKoE_EEvPNS_13PMinMaxFilterET_ |
170 | | |
171 | 0 | void to_pb(PMinMaxFilter* filter) override { set_pb(filter, get_convertor<T>()); } Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIbLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_14DecimalV2ValueELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIaLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIsLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIiLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIlLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncInLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIfLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIdLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_16VecDateTimeValueELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_15DateV2ValueTypeEEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_11DateV2ValueINS_19DateTimeV2ValueTypeEEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINSt7__cxx1112basic_stringIcSt11char_traitsIcESaIcEEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIiEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIlEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized12Decimal128V3ELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncINS_10vectorized7DecimalIN4wide7integerILm256EiEEEELb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIjLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE Unexecuted instantiation: _ZN5doris13MinMaxNumFuncIoLb1ELb1EE5to_pbEPNS_13PMinMaxFilterE |
172 | | |
173 | | protected: |
174 | | T _max = type_limit<T>::min(); |
175 | | T _min = type_limit<T>::max(); |
176 | | }; |
177 | | |
178 | | template <class T> |
179 | | using MinNumFunc = MinMaxNumFunc<T, false, true>; |
180 | | |
181 | | template <class T> |
182 | | using MaxNumFunc = MinMaxNumFunc<T, true, false>; |
183 | | |
184 | | } // namespace doris |