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 <string> |
21 | | |
22 | | #include "common/exception.h" |
23 | | #include "common/status.h" |
24 | | #include "core/column/column_array.h" |
25 | | #include "core/column/column_complex.h" |
26 | | #include "core/column/column_const.h" |
27 | | #include "core/column/column_decimal.h" |
28 | | #include "core/column/column_map.h" |
29 | | #include "core/column/column_nullable.h" |
30 | | #include "core/column/column_struct.h" |
31 | | #include "core/column/variant_v2/column_variant_v2.h" |
32 | | #include "core/data_type/data_type_nullable.h" |
33 | | #include "core/data_type/data_type_variant_v2.h" |
34 | | #include "core/data_type/define_primitive_type.h" |
35 | | #include "core/data_type/primitive_type.h" |
36 | | #include "exprs/function/function.h" |
37 | | #include "exprs/function_context.h" |
38 | | #include "exprs/vexpr.h" |
39 | | |
40 | | namespace doris { |
41 | | class RowDescriptor; |
42 | | class RuntimeState; |
43 | | class TExprNode; |
44 | | |
45 | | class Block; |
46 | | } // namespace doris |
47 | | |
48 | | namespace doris { |
49 | | |
50 | | class VCaseExpr final : public VExpr { |
51 | | ENABLE_FACTORY_CREATOR(VCaseExpr); |
52 | | |
53 | | public: |
54 | | VCaseExpr(const TExprNode& node); |
55 | | ~VCaseExpr() override = default; |
56 | | Status execute_column_impl(VExprContext* context, const Block* block, const Selector* selector, |
57 | | size_t count, ColumnPtr& result_column) const override; |
58 | | Status prepare(RuntimeState* state, const RowDescriptor& desc, VExprContext* context) override; |
59 | | Status open(RuntimeState* state, VExprContext* context, |
60 | | FunctionContext::FunctionStateScope scope) override; |
61 | | void close(VExprContext* context, FunctionContext::FunctionStateScope scope) override; |
62 | | const std::string& expr_name() const override; |
63 | | std::string debug_string() const override; |
64 | 0 | bool has_else_expr() const { return _has_else_expr; } |
65 | 1 | Status clone_node(VExprSPtr* cloned_expr) const override { |
66 | 1 | DORIS_CHECK(cloned_expr != nullptr); |
67 | 1 | auto node = clone_texpr_node(); |
68 | 1 | TCaseExpr case_node; |
69 | 1 | case_node.__set_has_case_expr(false); |
70 | 1 | case_node.__set_has_else_expr(_has_else_expr); |
71 | 1 | node.__set_case_expr(case_node); |
72 | 1 | *cloned_expr = VCaseExpr::create_shared(node); |
73 | 1 | return Status::OK(); |
74 | 1 | } |
75 | | |
76 | | private: |
77 | | template <typename IndexType, typename ColumnType> |
78 | | ColumnPtr _execute_update_result_impl(const IndexType* then_idx, |
79 | | std::vector<ColumnPtr>& then_columns, |
80 | 2.08k | size_t rows_count) const { |
81 | 2.08k | auto result_column_ptr = data_type()->create_column(); |
82 | 2.08k | result_column_ptr->reserve(rows_count); |
83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || |
84 | | std::is_same_v<ColumnType, ColumnBitmap> || |
85 | | std::is_same_v<ColumnType, ColumnArray> || |
86 | | std::is_same_v<ColumnType, ColumnMap> || |
87 | | std::is_same_v<ColumnType, ColumnStruct> || |
88 | | std::is_same_v<ColumnType, ColumnVariantV2> || |
89 | | std::is_same_v<ColumnType, ColumnHLL> || |
90 | | std::is_same_v<ColumnType, ColumnQuantileState> || |
91 | | std::is_same_v<ColumnType, ColumnIPv4> || |
92 | | std::is_same_v<ColumnType, ColumnIPv6> || |
93 | 167 | std::is_same_v<ColumnType, ColumnUUID>) { |
94 | | // result_column and all then_column is not nullable. |
95 | | // can't simd when type is string. |
96 | 167 | if (data_type()->is_nullable()) { |
97 | 109 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, |
98 | 109 | then_columns, rows_count); |
99 | 109 | } else { |
100 | 58 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, |
101 | 58 | then_columns, rows_count); |
102 | 58 | } |
103 | 1.91k | } else if (data_type()->is_nullable()) { |
104 | | // result_column and all then_column is nullable. |
105 | 48 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, |
106 | 48 | then_columns, rows_count); |
107 | 1.86k | } else { |
108 | 1.86k | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, |
109 | 1.86k | then_columns, rows_count); |
110 | 1.86k | } |
111 | 2.08k | return result_column_ptr; |
112 | 2.08k | } Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE2EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE3EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE4EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE5EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE6EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE7EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE8EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_9ColumnStrIjEEEENS_3COWINS_7IColumnEE13immutable_ptrIS5_EEPKT_RSt6vectorIS8_SaIS8_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE37EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE44EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE36EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_11ColumnArrayEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_9ColumnMapEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnStructEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_15ColumnVariantV2EEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE2EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE3EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 1.47k | size_t rows_count) const { | 81 | 1.47k | auto result_column_ptr = data_type()->create_column(); | 82 | 1.47k | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 1.47k | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 2 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 2 | then_columns, rows_count); | 107 | 1.46k | } else { | 108 | 1.46k | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 1.46k | then_columns, rows_count); | 110 | 1.46k | } | 111 | 1.47k | return result_column_ptr; | 112 | 1.47k | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE4EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE5EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 40 | size_t rows_count) const { | 81 | 40 | auto result_column_ptr = data_type()->create_column(); | 82 | 40 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 40 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 40 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 40 | then_columns, rows_count); | 107 | 40 | } else { | 108 | 0 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 0 | then_columns, rows_count); | 110 | 0 | } | 111 | 40 | return result_column_ptr; | 112 | 40 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE6EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 98 | size_t rows_count) const { | 81 | 98 | auto result_column_ptr = data_type()->create_column(); | 82 | 98 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 98 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 98 | } else { | 108 | 98 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 98 | then_columns, rows_count); | 110 | 98 | } | 111 | 98 | return result_column_ptr; | 112 | 98 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE7EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE8EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 26 | size_t rows_count) const { | 81 | 26 | auto result_column_ptr = data_type()->create_column(); | 82 | 26 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 26 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 1 | then_columns, rows_count); | 107 | 25 | } else { | 108 | 25 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 25 | then_columns, rows_count); | 110 | 25 | } | 111 | 26 | return result_column_ptr; | 112 | 26 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 29 | size_t rows_count) const { | 81 | 29 | auto result_column_ptr = data_type()->create_column(); | 82 | 29 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 29 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 4 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 4 | then_columns, rows_count); | 107 | 25 | } else { | 108 | 25 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 25 | then_columns, rows_count); | 110 | 25 | } | 111 | 29 | return result_column_ptr; | 112 | 29 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 1 | size_t rows_count) const { | 81 | 1 | auto result_column_ptr = data_type()->create_column(); | 82 | 1 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 1 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 1 | then_columns, rows_count); | 107 | 1 | } else { | 108 | 0 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 0 | then_columns, rows_count); | 110 | 0 | } | 111 | 1 | return result_column_ptr; | 112 | 1 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_9ColumnStrIjEEEENS_3COWINS_7IColumnEE13immutable_ptrIS5_EEPKT_RSt6vectorIS8_SaIS8_EEm Line | Count | Source | 80 | 156 | size_t rows_count) const { | 81 | 156 | auto result_column_ptr = data_type()->create_column(); | 82 | 156 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | 156 | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | 156 | if (data_type()->is_nullable()) { | 97 | 98 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | 98 | then_columns, rows_count); | 99 | 98 | } else { | 100 | 58 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | 58 | then_columns, rows_count); | 102 | 58 | } | 103 | | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | | then_columns, rows_count); | 107 | | } else { | 108 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | | then_columns, rows_count); | 110 | | } | 111 | 156 | return result_column_ptr; | 112 | 156 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 18 | size_t rows_count) const { | 81 | 18 | auto result_column_ptr = data_type()->create_column(); | 82 | 18 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | | if (data_type()->is_nullable()) { | 97 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | | then_columns, rows_count); | 99 | | } else { | 100 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | | then_columns, rows_count); | 102 | | } | 103 | 18 | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | 0 | then_columns, rows_count); | 107 | 18 | } else { | 108 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | 18 | then_columns, rows_count); | 110 | 18 | } | 111 | 18 | return result_column_ptr; | 112 | 18 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE37EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE44EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 6 | size_t rows_count) const { | 81 | 6 | auto result_column_ptr = data_type()->create_column(); | 82 | 6 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | 6 | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | 6 | if (data_type()->is_nullable()) { | 97 | 6 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | 6 | then_columns, rows_count); | 99 | 6 | } else { | 100 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | 0 | then_columns, rows_count); | 102 | 0 | } | 103 | | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | | then_columns, rows_count); | 107 | | } else { | 108 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | | then_columns, rows_count); | 110 | | } | 111 | 6 | return result_column_ptr; | 112 | 6 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE36EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_11ColumnArrayEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_9ColumnMapEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnStructEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 80 | 5 | size_t rows_count) const { | 81 | 5 | auto result_column_ptr = data_type()->create_column(); | 82 | 5 | result_column_ptr->reserve(rows_count); | 83 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 84 | | std::is_same_v<ColumnType, ColumnBitmap> || | 85 | | std::is_same_v<ColumnType, ColumnArray> || | 86 | | std::is_same_v<ColumnType, ColumnMap> || | 87 | | std::is_same_v<ColumnType, ColumnStruct> || | 88 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 89 | | std::is_same_v<ColumnType, ColumnHLL> || | 90 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 91 | | std::is_same_v<ColumnType, ColumnIPv4> || | 92 | | std::is_same_v<ColumnType, ColumnIPv6> || | 93 | 5 | std::is_same_v<ColumnType, ColumnUUID>) { | 94 | | // result_column and all then_column is not nullable. | 95 | | // can't simd when type is string. | 96 | 5 | if (data_type()->is_nullable()) { | 97 | 5 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 98 | 5 | then_columns, rows_count); | 99 | 5 | } else { | 100 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 101 | 0 | then_columns, rows_count); | 102 | 0 | } | 103 | | } else if (data_type()->is_nullable()) { | 104 | | // result_column and all then_column is nullable. | 105 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 106 | | then_columns, rows_count); | 107 | | } else { | 108 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 109 | | then_columns, rows_count); | 110 | | } | 111 | 5 | return result_column_ptr; | 112 | 5 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_15ColumnVariantV2EEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm |
113 | | |
114 | | template <typename IndexType> |
115 | | ColumnPtr _execute_update_result(const IndexType* then_idx, |
116 | | std::vector<ColumnPtr>& then_columns, |
117 | 1.79k | size_t rows_count) const { |
118 | 1.79k | #define CASE_TYPE(ptype, coltype) \ |
119 | 1.79k | case PrimitiveType::ptype: \ |
120 | 1.79k | return _execute_update_result_impl<IndexType, coltype>(then_idx, then_columns, rows_count); |
121 | | |
122 | 1.79k | switch (data_type()->get_primitive_type()) { |
123 | 0 | CASE_TYPE(TYPE_BOOLEAN, ColumnUInt8) |
124 | 1.47k | CASE_TYPE(TYPE_TINYINT, ColumnInt8) |
125 | 0 | CASE_TYPE(TYPE_SMALLINT, ColumnInt16) |
126 | 40 | CASE_TYPE(TYPE_INT, ColumnInt32) |
127 | 98 | CASE_TYPE(TYPE_BIGINT, ColumnInt64) |
128 | 0 | CASE_TYPE(TYPE_LARGEINT, ColumnInt128) |
129 | 8 | CASE_TYPE(TYPE_FLOAT, ColumnFloat32) |
130 | 11 | CASE_TYPE(TYPE_DOUBLE, ColumnFloat64) |
131 | 0 | CASE_TYPE(TYPE_DECIMAL32, ColumnDecimal32) |
132 | 1 | CASE_TYPE(TYPE_DECIMAL64, ColumnDecimal64) |
133 | 0 | CASE_TYPE(TYPE_DECIMAL256, ColumnDecimal256) |
134 | 0 | CASE_TYPE(TYPE_DECIMAL128I, ColumnDecimal128V3) |
135 | 0 | CASE_TYPE(TYPE_DECIMALV2, ColumnDecimal128V2) |
136 | 2 | CASE_TYPE(TYPE_STRING, ColumnString) |
137 | 0 | CASE_TYPE(TYPE_CHAR, ColumnString) |
138 | 154 | CASE_TYPE(TYPE_VARCHAR, ColumnString) |
139 | 0 | CASE_TYPE(TYPE_JSONB, ColumnString) |
140 | 0 | CASE_TYPE(TYPE_DATE, ColumnDate) |
141 | 0 | CASE_TYPE(TYPE_DATETIME, ColumnDateTime) |
142 | 0 | CASE_TYPE(TYPE_DATEV2, ColumnDateV2) |
143 | 0 | CASE_TYPE(TYPE_DATETIMEV2, ColumnDateTimeV2) |
144 | 0 | CASE_TYPE(TYPE_TIMESTAMP_NS, ColumnTimeStampNs) |
145 | 0 | CASE_TYPE(TYPE_TIMESTAMPTZ, ColumnTimeStampTz) |
146 | 0 | CASE_TYPE(TYPE_IPV6, ColumnIPv6) |
147 | 6 | CASE_TYPE(TYPE_UUID, ColumnUUID) |
148 | 0 | CASE_TYPE(TYPE_IPV4, ColumnIPv4) |
149 | 0 | CASE_TYPE(TYPE_ARRAY, ColumnArray) |
150 | 0 | CASE_TYPE(TYPE_MAP, ColumnMap) |
151 | 0 | CASE_TYPE(TYPE_STRUCT, ColumnStruct) |
152 | 5 | CASE_TYPE(TYPE_BITMAP, ColumnBitmap) |
153 | 0 | CASE_TYPE(TYPE_HLL, ColumnHLL) |
154 | 0 | CASE_TYPE(TYPE_QUANTILE_STATE, ColumnQuantileState) |
155 | 0 | case PrimitiveType::TYPE_VARIANT: { |
156 | 0 | const IDataType* variant_type = remove_nullable(data_type()).get(); |
157 | 0 | DORIS_CHECK(dynamic_cast<const DataTypeVariantV2*>(variant_type) != nullptr); |
158 | 0 | return _execute_update_result_impl<IndexType, ColumnVariantV2>(then_idx, then_columns, |
159 | 0 | rows_count); |
160 | 0 | } |
161 | 0 | default: |
162 | 0 | throw Exception(ErrorCode::NOT_IMPLEMENTED_ERROR, "argument_type {} not supported", |
163 | 0 | data_type()->get_name()); |
164 | 1.79k | } |
165 | 1.79k | #undef CASE_TYPE |
166 | 1.79k | } Unexecuted instantiation: _ZNK5doris9VCaseExpr22_execute_update_resultItEENS_3COWINS_7IColumnEE13immutable_ptrIS3_EEPKT_RSt6vectorIS6_SaIS6_EEm _ZNK5doris9VCaseExpr22_execute_update_resultIhEENS_3COWINS_7IColumnEE13immutable_ptrIS3_EEPKT_RSt6vectorIS6_SaIS6_EEm Line | Count | Source | 117 | 1.79k | size_t rows_count) const { | 118 | 1.79k | #define CASE_TYPE(ptype, coltype) \ | 119 | 1.79k | case PrimitiveType::ptype: \ | 120 | 1.79k | return _execute_update_result_impl<IndexType, coltype>(then_idx, then_columns, rows_count); | 121 | | | 122 | 1.79k | switch (data_type()->get_primitive_type()) { | 123 | 0 | CASE_TYPE(TYPE_BOOLEAN, ColumnUInt8) | 124 | 1.47k | CASE_TYPE(TYPE_TINYINT, ColumnInt8) | 125 | 0 | CASE_TYPE(TYPE_SMALLINT, ColumnInt16) | 126 | 40 | CASE_TYPE(TYPE_INT, ColumnInt32) | 127 | 98 | CASE_TYPE(TYPE_BIGINT, ColumnInt64) | 128 | 0 | CASE_TYPE(TYPE_LARGEINT, ColumnInt128) | 129 | 8 | CASE_TYPE(TYPE_FLOAT, ColumnFloat32) | 130 | 11 | CASE_TYPE(TYPE_DOUBLE, ColumnFloat64) | 131 | 0 | CASE_TYPE(TYPE_DECIMAL32, ColumnDecimal32) | 132 | 1 | CASE_TYPE(TYPE_DECIMAL64, ColumnDecimal64) | 133 | 0 | CASE_TYPE(TYPE_DECIMAL256, ColumnDecimal256) | 134 | 0 | CASE_TYPE(TYPE_DECIMAL128I, ColumnDecimal128V3) | 135 | 0 | CASE_TYPE(TYPE_DECIMALV2, ColumnDecimal128V2) | 136 | 2 | CASE_TYPE(TYPE_STRING, ColumnString) | 137 | 0 | CASE_TYPE(TYPE_CHAR, ColumnString) | 138 | 154 | CASE_TYPE(TYPE_VARCHAR, ColumnString) | 139 | 0 | CASE_TYPE(TYPE_JSONB, ColumnString) | 140 | 0 | CASE_TYPE(TYPE_DATE, ColumnDate) | 141 | 0 | CASE_TYPE(TYPE_DATETIME, ColumnDateTime) | 142 | 0 | CASE_TYPE(TYPE_DATEV2, ColumnDateV2) | 143 | 0 | CASE_TYPE(TYPE_DATETIMEV2, ColumnDateTimeV2) | 144 | 0 | CASE_TYPE(TYPE_TIMESTAMP_NS, ColumnTimeStampNs) | 145 | 0 | CASE_TYPE(TYPE_TIMESTAMPTZ, ColumnTimeStampTz) | 146 | 0 | CASE_TYPE(TYPE_IPV6, ColumnIPv6) | 147 | 6 | CASE_TYPE(TYPE_UUID, ColumnUUID) | 148 | 0 | CASE_TYPE(TYPE_IPV4, ColumnIPv4) | 149 | 0 | CASE_TYPE(TYPE_ARRAY, ColumnArray) | 150 | 0 | CASE_TYPE(TYPE_MAP, ColumnMap) | 151 | 0 | CASE_TYPE(TYPE_STRUCT, ColumnStruct) | 152 | 5 | CASE_TYPE(TYPE_BITMAP, ColumnBitmap) | 153 | 0 | CASE_TYPE(TYPE_HLL, ColumnHLL) | 154 | 0 | CASE_TYPE(TYPE_QUANTILE_STATE, ColumnQuantileState) | 155 | 0 | case PrimitiveType::TYPE_VARIANT: { | 156 | 0 | const IDataType* variant_type = remove_nullable(data_type()).get(); | 157 | 0 | DORIS_CHECK(dynamic_cast<const DataTypeVariantV2*>(variant_type) != nullptr); | 158 | 0 | return _execute_update_result_impl<IndexType, ColumnVariantV2>(then_idx, then_columns, | 159 | 0 | rows_count); | 160 | 0 | } | 161 | 0 | default: | 162 | 0 | throw Exception(ErrorCode::NOT_IMPLEMENTED_ERROR, "argument_type {} not supported", | 163 | 0 | data_type()->get_name()); | 164 | 1.79k | } | 165 | 1.79k | #undef CASE_TYPE | 166 | 1.79k | } |
|
167 | | |
168 | | template <typename IndexType, typename ColumnType, bool then_null> |
169 | | void update_result_normal(MutableColumnPtr& result_column_ptr, |
170 | | const IndexType* __restrict then_idx, |
171 | 215 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
172 | 215 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); |
173 | 215 | std::vector<uint8_t> is_consts(then_columns.size()); |
174 | 215 | std::vector<uint8_t> is_nullable(then_columns.size()); |
175 | 1.43k | for (size_t i = 0; i < then_columns.size(); i++) { |
176 | 1.21k | if (!then_columns[i]) { |
177 | 6 | continue; |
178 | 6 | } |
179 | 1.21k | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); |
180 | 1.21k | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); |
181 | 1.21k | } |
182 | | |
183 | 215 | auto* raw_result_column = result_column_ptr.get(); |
184 | 167k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
185 | 167k | if (!_has_else_expr && !then_idx[row_idx]) { |
186 | 10 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) |
187 | 10 | ->insert_default(); |
188 | 10 | continue; |
189 | 10 | } |
190 | 167k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; |
191 | 167k | if constexpr (then_null) { |
192 | 35.8k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( |
193 | 35.8k | result_column_ptr.get()); |
194 | 35.8k | if (is_nullable[then_idx[row_idx]]) { |
195 | 16.7k | nullable->insert_from_with_type<ColumnType>( |
196 | 16.7k | *raw_then_columns[then_idx[row_idx]], target); |
197 | 19.1k | } else { |
198 | 19.1k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( |
199 | 19.1k | nullable->get_nested_column_ptr().get()); |
200 | 19.1k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); |
201 | 19.1k | nullable->push_false_to_nullmap(1); |
202 | 19.1k | } |
203 | 131k | } else { |
204 | 131k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) |
205 | 131k | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); |
206 | 131k | } |
207 | 167k | } |
208 | 215 | } Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE2EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE3EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE4EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE5EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE6EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE7EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE8EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE9EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_9ColumnStrIjEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS5_EEPKT_RSt6vectorINS6_13immutable_ptrIS5_EESaISF_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_9ColumnStrIjEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS5_EEPKT_RSt6vectorINS6_13immutable_ptrIS5_EESaISF_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE11EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE12EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE25EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE26EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE43EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE42EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE37EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE37EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE44EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE44EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE36EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnVectorILNS_13PrimitiveTypeE36EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_11ColumnArrayELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_11ColumnArrayELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_9ColumnMapELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_9ColumnMapELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnStructELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_12ColumnStructELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_15ColumnVariantV2ELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_15ColumnVariantV2ELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE2EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE3EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 2 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 2 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 2 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 2 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 6 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 4 | if (!then_columns[i]) { | 177 | 1 | continue; | 178 | 1 | } | 179 | 3 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 3 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 3 | } | 182 | | | 183 | 2 | auto* raw_result_column = result_column_ptr.get(); | 184 | 5 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 3 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 3 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 3 | if constexpr (then_null) { | 192 | 3 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 3 | result_column_ptr.get()); | 194 | 3 | if (is_nullable[then_idx[row_idx]]) { | 195 | 1 | nullable->insert_from_with_type<ColumnType>( | 196 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 2 | } else { | 198 | 2 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 2 | nullable->get_nested_column_ptr().get()); | 200 | 2 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 2 | nullable->push_false_to_nullmap(1); | 202 | 2 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 3 | } | 208 | 2 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE4EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE5EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 40 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 40 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 40 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 40 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 107 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 67 | if (!then_columns[i]) { | 177 | 0 | continue; | 178 | 0 | } | 179 | 67 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 67 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 67 | } | 182 | | | 183 | 40 | auto* raw_result_column = result_column_ptr.get(); | 184 | 96 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 56 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 56 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 56 | if constexpr (then_null) { | 192 | 56 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 56 | result_column_ptr.get()); | 194 | 56 | if (is_nullable[then_idx[row_idx]]) { | 195 | 56 | nullable->insert_from_with_type<ColumnType>( | 196 | 56 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 56 | } else { | 198 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 0 | nullable->get_nested_column_ptr().get()); | 200 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 0 | nullable->push_false_to_nullmap(1); | 202 | 0 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 56 | } | 208 | 40 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE6EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE7EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE8EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 4 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 3 | if (!then_columns[i]) { | 177 | 1 | continue; | 178 | 1 | } | 179 | 2 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 2 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 2 | } | 182 | | | 183 | 1 | auto* raw_result_column = result_column_ptr.get(); | 184 | 4 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 3 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 1 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 1 | ->insert_default(); | 188 | 1 | continue; | 189 | 1 | } | 190 | 2 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 2 | if constexpr (then_null) { | 192 | 2 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 2 | result_column_ptr.get()); | 194 | 2 | if (is_nullable[then_idx[row_idx]]) { | 195 | 0 | nullable->insert_from_with_type<ColumnType>( | 196 | 0 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 2 | } else { | 198 | 2 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 2 | nullable->get_nested_column_ptr().get()); | 200 | 2 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 2 | nullable->push_false_to_nullmap(1); | 202 | 2 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 2 | } | 208 | 1 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 4 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 4 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 4 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 4 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 15 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 11 | if (!then_columns[i]) { | 177 | 1 | continue; | 178 | 1 | } | 179 | 10 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 10 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 10 | } | 182 | | | 183 | 4 | auto* raw_result_column = result_column_ptr.get(); | 184 | 17 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 13 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 1 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 1 | ->insert_default(); | 188 | 1 | continue; | 189 | 1 | } | 190 | 12 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 12 | if constexpr (then_null) { | 192 | 12 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 12 | result_column_ptr.get()); | 194 | 12 | if (is_nullable[then_idx[row_idx]]) { | 195 | 7 | nullable->insert_from_with_type<ColumnType>( | 196 | 7 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 7 | } else { | 198 | 5 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 5 | nullable->get_nested_column_ptr().get()); | 200 | 5 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 5 | nullable->push_false_to_nullmap(1); | 202 | 5 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 12 | } | 208 | 4 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 2 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 1 | if (!then_columns[i]) { | 177 | 0 | continue; | 178 | 0 | } | 179 | 1 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 1 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 1 | } | 182 | | | 183 | 1 | auto* raw_result_column = result_column_ptr.get(); | 184 | 2 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 1 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 1 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 1 | if constexpr (then_null) { | 192 | 1 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 1 | result_column_ptr.get()); | 194 | 1 | if (is_nullable[then_idx[row_idx]]) { | 195 | 1 | nullable->insert_from_with_type<ColumnType>( | 196 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 1 | } else { | 198 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 0 | nullable->get_nested_column_ptr().get()); | 200 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 0 | nullable->push_false_to_nullmap(1); | 202 | 0 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 1 | } | 208 | 1 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_9ColumnStrIjEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS5_EEPKT_RSt6vectorINS6_13immutable_ptrIS5_EESaISF_EEm Line | Count | Source | 171 | 98 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 98 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 98 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 98 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 1.04k | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 948 | if (!then_columns[i]) { | 177 | 3 | continue; | 178 | 3 | } | 179 | 945 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 945 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 945 | } | 182 | | | 183 | 98 | auto* raw_result_column = result_column_ptr.get(); | 184 | 3.11k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 3.01k | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 8 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 8 | ->insert_default(); | 188 | 8 | continue; | 189 | 8 | } | 190 | 3.00k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 3.00k | if constexpr (then_null) { | 192 | 3.00k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 3.00k | result_column_ptr.get()); | 194 | 3.00k | if (is_nullable[then_idx[row_idx]]) { | 195 | 305 | nullable->insert_from_with_type<ColumnType>( | 196 | 305 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 2.70k | } else { | 198 | 2.70k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 2.70k | nullable->get_nested_column_ptr().get()); | 200 | 2.70k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 2.70k | nullable->push_false_to_nullmap(1); | 202 | 2.70k | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 3.00k | } | 208 | 98 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_9ColumnStrIjEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS5_EEPKT_RSt6vectorINS6_13immutable_ptrIS5_EESaISF_EEm Line | Count | Source | 171 | 58 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 58 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 58 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 58 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 208 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 150 | if (!then_columns[i]) { | 177 | 0 | continue; | 178 | 0 | } | 179 | 150 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 150 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 150 | } | 182 | | | 183 | 58 | auto* raw_result_column = result_column_ptr.get(); | 184 | 131k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 131k | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 131k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | | if constexpr (then_null) { | 192 | | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | | result_column_ptr.get()); | 194 | | if (is_nullable[then_idx[row_idx]]) { | 195 | | nullable->insert_from_with_type<ColumnType>( | 196 | | *raw_then_columns[then_idx[row_idx]], target); | 197 | | } else { | 198 | | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | | nullable->get_nested_column_ptr().get()); | 200 | | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | | nullable->push_false_to_nullmap(1); | 202 | | } | 203 | 131k | } else { | 204 | 131k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | 131k | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | 131k | } | 207 | 131k | } | 208 | 58 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE11EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE12EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE25EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE26EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE43EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE42EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE37EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE37EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE44EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 6 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 6 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 6 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 6 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 30 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 24 | if (!then_columns[i]) { | 177 | 0 | continue; | 178 | 0 | } | 179 | 24 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 24 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 24 | } | 182 | | | 183 | 6 | auto* raw_result_column = result_column_ptr.get(); | 184 | 32.7k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 32.7k | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 32.7k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 32.7k | if constexpr (then_null) { | 192 | 32.7k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 32.7k | result_column_ptr.get()); | 194 | 32.7k | if (is_nullable[then_idx[row_idx]]) { | 195 | 16.3k | nullable->insert_from_with_type<ColumnType>( | 196 | 16.3k | *raw_then_columns[then_idx[row_idx]], target); | 197 | 16.3k | } else { | 198 | 16.3k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 16.3k | nullable->get_nested_column_ptr().get()); | 200 | 16.3k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 16.3k | nullable->push_false_to_nullmap(1); | 202 | 16.3k | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 32.7k | } | 208 | 6 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE44EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE36EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE36EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_11ColumnArrayELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_11ColumnArrayELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_9ColumnMapELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_9ColumnMapELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnStructELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnStructELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 171 | 5 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 172 | 5 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 173 | 5 | std::vector<uint8_t> is_consts(then_columns.size()); | 174 | 5 | std::vector<uint8_t> is_nullable(then_columns.size()); | 175 | 15 | for (size_t i = 0; i < then_columns.size(); i++) { | 176 | 10 | if (!then_columns[i]) { | 177 | 0 | continue; | 178 | 0 | } | 179 | 10 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 180 | 10 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 181 | 10 | } | 182 | | | 183 | 5 | auto* raw_result_column = result_column_ptr.get(); | 184 | 10 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 185 | 5 | if (!_has_else_expr && !then_idx[row_idx]) { | 186 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 187 | 0 | ->insert_default(); | 188 | 0 | continue; | 189 | 0 | } | 190 | 5 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 191 | 5 | if constexpr (then_null) { | 192 | 5 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 193 | 5 | result_column_ptr.get()); | 194 | 5 | if (is_nullable[then_idx[row_idx]]) { | 195 | 0 | nullable->insert_from_with_type<ColumnType>( | 196 | 0 | *raw_then_columns[then_idx[row_idx]], target); | 197 | 5 | } else { | 198 | 5 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 199 | 5 | nullable->get_nested_column_ptr().get()); | 200 | 5 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 201 | 5 | nullable->push_false_to_nullmap(1); | 202 | 5 | } | 203 | | } else { | 204 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 205 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 206 | | } | 207 | 5 | } | 208 | 5 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE22EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE19EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_17ColumnComplexTypeILNS_13PrimitiveTypeE24EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVariantV2ELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVariantV2ELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm |
209 | | |
210 | | template <typename IndexType, typename ColumnType> |
211 | | void update_result_auto_simd(MutableColumnPtr& result_column_ptr, |
212 | | const IndexType* __restrict then_idx, |
213 | 1.86k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
214 | 12.8k | for (auto& then_ptr : then_columns) { |
215 | 12.8k | then_ptr = then_ptr->convert_to_full_column_if_const(); |
216 | 12.8k | } |
217 | | |
218 | 1.86k | result_column_ptr->resize(rows_count); |
219 | 1.86k | auto* __restrict result_raw_data = |
220 | 1.86k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) |
221 | 1.86k | ->get_data() |
222 | 1.86k | .data(); |
223 | | |
224 | | // set default value |
225 | 408k | for (int i = 0; i < rows_count; i++) { |
226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || |
227 | | std::is_same_v<ColumnType, ColumnDateTime> || |
228 | | std::is_same_v<ColumnType, ColumnDateV2> || |
229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || |
230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || |
231 | 297k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { |
232 | 297k | result_raw_data[i] = ColumnType::default_value(); |
233 | 297k | } else { |
234 | 109k | result_raw_data[i] = {}; |
235 | 109k | } |
236 | 406k | } |
237 | | |
238 | 14.7k | for (IndexType i = 0; i < then_columns.size(); i++) { |
239 | 12.8k | if (!then_columns[i]) { |
240 | 0 | continue; |
241 | 0 | } |
242 | 12.8k | const auto* __restrict column_raw_data = |
243 | 12.8k | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( |
244 | 12.8k | then_columns[i].get()) |
245 | 12.8k | ->get_data() |
246 | 12.8k | .data(); |
247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || |
248 | | std::is_same_v<ColumnType, ColumnFloat64> || |
249 | | std::is_same_v<ColumnType, ColumnDate> || |
250 | | std::is_same_v<ColumnType, ColumnDateTime> || |
251 | | std::is_same_v<ColumnType, ColumnDateV2> || |
252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || |
253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || |
254 | 10.5k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { |
255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. |
256 | | // Conditional stores also let the compiler vectorize without loading from a |
257 | | // selected source/destination pointer, as a ternary assignment can do. |
258 | 35.9M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { |
259 | 35.9M | if (then_idx[row_idx] == i) { |
260 | 404k | result_raw_data[row_idx] = column_raw_data[row_idx]; |
261 | 404k | } |
262 | 35.9M | } |
263 | 10.5k | } else { |
264 | 4.91k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
265 | 2.56k | result_raw_data[row_idx] += |
266 | 2.56k | typename ColumnType::value_type(then_idx[row_idx] == i) * |
267 | 2.56k | column_raw_data[row_idx]; |
268 | 2.56k | } |
269 | 2.35k | } |
270 | 12.8k | } |
271 | 1.86k | } Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE2EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE3EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE4EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE5EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE6EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE7EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE8EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 24.7k | } else { | 234 | 24.7k | result_raw_data[i] = {}; | 235 | 24.7k | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 24.7k | } else { | 234 | 24.7k | result_raw_data[i] = {}; | 235 | 24.7k | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 658 | for (auto& then_ptr : then_columns) { | 215 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 658 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 658 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 658 | const auto* __restrict column_raw_data = | 243 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 658 | then_columns[i].get()) | 245 | 658 | ->get_data() | 246 | 658 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 658 | } | 271 | 18 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE2EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE3EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 1.46k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 2.25k | for (auto& then_ptr : then_columns) { | 215 | 2.25k | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 2.25k | } | 217 | | | 218 | 1.46k | result_column_ptr->resize(rows_count); | 219 | 1.46k | auto* __restrict result_raw_data = | 220 | 1.46k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 1.46k | ->get_data() | 222 | 1.46k | .data(); | 223 | | | 224 | | // set default value | 225 | 2.94k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 1.48k | } else { | 234 | 1.48k | result_raw_data[i] = {}; | 235 | 1.48k | } | 236 | 1.48k | } | 237 | | | 238 | 3.72k | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 2.25k | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 2.25k | const auto* __restrict column_raw_data = | 243 | 2.25k | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 2.25k | then_columns[i].get()) | 245 | 2.25k | ->get_data() | 246 | 2.25k | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | | if (then_idx[row_idx] == i) { | 260 | | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | | } | 262 | | } | 263 | 2.25k | } else { | 264 | 4.55k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | 2.29k | result_raw_data[row_idx] += | 266 | 2.29k | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | 2.29k | column_raw_data[row_idx]; | 268 | 2.29k | } | 269 | 2.25k | } | 270 | 2.25k | } | 271 | 1.46k | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE4EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE5EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE6EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 98 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 100 | for (auto& then_ptr : then_columns) { | 215 | 100 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 100 | } | 217 | | | 218 | 98 | result_column_ptr->resize(rows_count); | 219 | 98 | auto* __restrict result_raw_data = | 220 | 98 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 98 | ->get_data() | 222 | 98 | .data(); | 223 | | | 224 | | // set default value | 225 | 340 | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 242 | } else { | 234 | 242 | result_raw_data[i] = {}; | 235 | 242 | } | 236 | 242 | } | 237 | | | 238 | 198 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 100 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 100 | const auto* __restrict column_raw_data = | 243 | 100 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 100 | then_columns[i].get()) | 245 | 100 | ->get_data() | 246 | 100 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | | if (then_idx[row_idx] == i) { | 260 | | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | | } | 262 | | } | 263 | 100 | } else { | 264 | 368 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | 268 | result_raw_data[row_idx] += | 266 | 268 | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | 268 | column_raw_data[row_idx]; | 268 | 268 | } | 269 | 100 | } | 270 | 100 | } | 271 | 98 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE7EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE8EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 25 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 675 | for (auto& then_ptr : then_columns) { | 215 | 675 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 675 | } | 217 | | | 218 | 25 | result_column_ptr->resize(rows_count); | 219 | 25 | auto* __restrict result_raw_data = | 220 | 25 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 25 | ->get_data() | 222 | 25 | .data(); | 223 | | | 224 | | // set default value | 225 | 28.9k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 28.8k | } else { | 234 | 28.8k | result_raw_data[i] = {}; | 235 | 28.8k | } | 236 | 28.8k | } | 237 | | | 238 | 700 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 675 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 675 | const auto* __restrict column_raw_data = | 243 | 675 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 675 | then_columns[i].get()) | 245 | 675 | ->get_data() | 246 | 675 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 675 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 28.8k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 28.8k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 675 | } | 271 | 25 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 25 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 675 | for (auto& then_ptr : then_columns) { | 215 | 675 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 675 | } | 217 | | | 218 | 25 | result_column_ptr->resize(rows_count); | 219 | 25 | auto* __restrict result_raw_data = | 220 | 25 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 25 | ->get_data() | 222 | 25 | .data(); | 223 | | | 224 | | // set default value | 225 | 28.9k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | | result_raw_data[i] = ColumnType::default_value(); | 233 | 28.8k | } else { | 234 | 28.8k | result_raw_data[i] = {}; | 235 | 28.8k | } | 236 | 28.8k | } | 237 | | | 238 | 700 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 675 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 675 | const auto* __restrict column_raw_data = | 243 | 675 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 675 | then_columns[i].get()) | 245 | 675 | ->get_data() | 246 | 675 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 675 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.25M | if (then_idx[row_idx] == i) { | 260 | 28.8k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 28.8k | } | 262 | 2.25M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 675 | } | 271 | 25 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_13ColumnDecimalILNS_13PrimitiveTypeE28EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_13ColumnDecimalILNS_13PrimitiveTypeE29EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_13ColumnDecimalILNS_13PrimitiveTypeE30EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_13ColumnDecimalILNS_13PrimitiveTypeE20EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 213 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 214 | 654 | for (auto& then_ptr : then_columns) { | 215 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 216 | 654 | } | 217 | | | 218 | 18 | result_column_ptr->resize(rows_count); | 219 | 18 | auto* __restrict result_raw_data = | 220 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 221 | 18 | ->get_data() | 222 | 18 | .data(); | 223 | | | 224 | | // set default value | 225 | 24.7k | for (int i = 0; i < rows_count; i++) { | 226 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 227 | | std::is_same_v<ColumnType, ColumnDateTime> || | 228 | | std::is_same_v<ColumnType, ColumnDateV2> || | 229 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 230 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 231 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 232 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 233 | | } else { | 234 | | result_raw_data[i] = {}; | 235 | | } | 236 | 24.7k | } | 237 | | | 238 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 239 | 654 | if (!then_columns[i]) { | 240 | 0 | continue; | 241 | 0 | } | 242 | 654 | const auto* __restrict column_raw_data = | 243 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 244 | 654 | then_columns[i].get()) | 245 | 654 | ->get_data() | 246 | 654 | .data(); | 247 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 248 | | std::is_same_v<ColumnType, ColumnFloat64> || | 249 | | std::is_same_v<ColumnType, ColumnDate> || | 250 | | std::is_same_v<ColumnType, ColumnDateTime> || | 251 | | std::is_same_v<ColumnType, ColumnDateV2> || | 252 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 253 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 254 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 255 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 256 | | // Conditional stores also let the compiler vectorize without loading from a | 257 | | // selected source/destination pointer, as a ternary assignment can do. | 258 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 259 | 2.23M | if (then_idx[row_idx] == i) { | 260 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 261 | 24.7k | } | 262 | 2.23M | } | 263 | | } else { | 264 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 265 | | result_raw_data[row_idx] += | 266 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 267 | | column_raw_data[row_idx]; | 268 | | } | 269 | | } | 270 | 654 | } | 271 | 18 | } |
|
272 | | |
273 | | template <typename IndexType> |
274 | | ColumnPtr _execute_impl(const std::vector<ColumnPtr>& when_columns, |
275 | 1.79k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
276 | 1.79k | std::vector<IndexType> then_idx(rows_count, 0); |
277 | 1.79k | IndexType* __restrict then_idx_ptr = then_idx.data(); |
278 | 3.61k | for (IndexType i = 0; i < when_columns.size(); i++) { |
279 | 1.82k | IndexType column_idx = i + 1; |
280 | 1.82k | auto [raw_when_column, is_consts] = unpack_if_const(when_columns[i]); |
281 | | |
282 | 1.82k | if (is_consts) { |
283 | 0 | if (raw_when_column->get_bool(0)) { |
284 | 0 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
285 | 0 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx]) * column_idx; |
286 | 0 | } |
287 | 0 | break; |
288 | 0 | } |
289 | 0 | continue; |
290 | 0 | } |
291 | | |
292 | 1.82k | if (is_column_nullable(*raw_when_column)) { |
293 | 1.46k | const auto* column_nullable_ptr = |
294 | 1.46k | assert_cast<const ColumnNullable*, TypeCheckOnRelease::DISABLE>( |
295 | 1.46k | raw_when_column.get()); |
296 | 1.46k | const auto* __restrict cond_raw_data = |
297 | 1.46k | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( |
298 | 1.46k | column_nullable_ptr->get_nested_column_ptr().get()) |
299 | 1.46k | ->get_data() |
300 | 1.46k | .data(); |
301 | 1.46k | if (!column_nullable_ptr->has_null()) { |
302 | 389k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
303 | 388k | then_idx_ptr[row_idx] |= |
304 | 388k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; |
305 | 388k | } |
306 | 1.43k | continue; |
307 | 1.43k | } |
308 | 31 | const auto* __restrict cond_raw_nullmap = |
309 | 31 | column_nullable_ptr->get_null_map_column_ptr()->get_data().data(); |
310 | 168 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
311 | 137 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx] * cond_raw_data[row_idx] * |
312 | 137 | !cond_raw_nullmap[row_idx]) * |
313 | 137 | column_idx; |
314 | 137 | } |
315 | 360 | } else { |
316 | 360 | const auto* __restrict cond_raw_data = |
317 | 360 | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( |
318 | 360 | raw_when_column.get()) |
319 | 360 | ->get_data() |
320 | 360 | .data(); |
321 | 17.2k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
322 | 16.8k | then_idx_ptr[row_idx] |= |
323 | 16.8k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; |
324 | 16.8k | } |
325 | 360 | } |
326 | 1.82k | } |
327 | | |
328 | 1.79k | return _execute_update_result<IndexType>(then_idx_ptr, then_columns, rows_count); |
329 | 1.79k | } Unexecuted instantiation: _ZNK5doris9VCaseExpr13_execute_implItEENS_3COWINS_7IColumnEE13immutable_ptrIS3_EERKSt6vectorIS6_SaIS6_EERS9_m _ZNK5doris9VCaseExpr13_execute_implIhEENS_3COWINS_7IColumnEE13immutable_ptrIS3_EERKSt6vectorIS6_SaIS6_EERS9_m Line | Count | Source | 275 | 1.79k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 276 | 1.79k | std::vector<IndexType> then_idx(rows_count, 0); | 277 | 1.79k | IndexType* __restrict then_idx_ptr = then_idx.data(); | 278 | 3.61k | for (IndexType i = 0; i < when_columns.size(); i++) { | 279 | 1.82k | IndexType column_idx = i + 1; | 280 | 1.82k | auto [raw_when_column, is_consts] = unpack_if_const(when_columns[i]); | 281 | | | 282 | 1.82k | if (is_consts) { | 283 | 0 | if (raw_when_column->get_bool(0)) { | 284 | 0 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 285 | 0 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx]) * column_idx; | 286 | 0 | } | 287 | 0 | break; | 288 | 0 | } | 289 | 0 | continue; | 290 | 0 | } | 291 | | | 292 | 1.82k | if (is_column_nullable(*raw_when_column)) { | 293 | 1.46k | const auto* column_nullable_ptr = | 294 | 1.46k | assert_cast<const ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 295 | 1.46k | raw_when_column.get()); | 296 | 1.46k | const auto* __restrict cond_raw_data = | 297 | 1.46k | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( | 298 | 1.46k | column_nullable_ptr->get_nested_column_ptr().get()) | 299 | 1.46k | ->get_data() | 300 | 1.46k | .data(); | 301 | 1.46k | if (!column_nullable_ptr->has_null()) { | 302 | 389k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 303 | 388k | then_idx_ptr[row_idx] |= | 304 | 388k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; | 305 | 388k | } | 306 | 1.43k | continue; | 307 | 1.43k | } | 308 | 31 | const auto* __restrict cond_raw_nullmap = | 309 | 31 | column_nullable_ptr->get_null_map_column_ptr()->get_data().data(); | 310 | 168 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 311 | 137 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx] * cond_raw_data[row_idx] * | 312 | 137 | !cond_raw_nullmap[row_idx]) * | 313 | 137 | column_idx; | 314 | 137 | } | 315 | 360 | } else { | 316 | 360 | const auto* __restrict cond_raw_data = | 317 | 360 | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( | 318 | 360 | raw_when_column.get()) | 319 | 360 | ->get_data() | 320 | 360 | .data(); | 321 | 17.2k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 322 | 16.8k | then_idx_ptr[row_idx] |= | 323 | 16.8k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; | 324 | 16.8k | } | 325 | 360 | } | 326 | 1.82k | } | 327 | | | 328 | 1.79k | return _execute_update_result<IndexType>(then_idx_ptr, then_columns, rows_count); | 329 | 1.79k | } |
|
330 | | |
331 | | bool _has_else_expr; |
332 | | |
333 | | inline static const std::string FUNCTION_NAME = "case"; |
334 | | inline static const std::string EXPR_NAME = "vcase expr"; |
335 | | }; |
336 | | } // namespace doris |