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_spatial.h" |
31 | | #include "core/column/column_struct.h" |
32 | | #include "core/column/column_varbinary.h" |
33 | | #include "core/column/variant_v2/column_variant_v2.h" |
34 | | #include "core/data_type/data_type_nullable.h" |
35 | | #include "core/data_type/data_type_variant_v2.h" |
36 | | #include "core/data_type/define_primitive_type.h" |
37 | | #include "core/data_type/primitive_type.h" |
38 | | #include "exprs/function/function.h" |
39 | | #include "exprs/function_context.h" |
40 | | #include "exprs/vexpr.h" |
41 | | |
42 | | namespace doris { |
43 | | class RowDescriptor; |
44 | | class RuntimeState; |
45 | | class TExprNode; |
46 | | |
47 | | class Block; |
48 | | } // namespace doris |
49 | | |
50 | | namespace doris { |
51 | | |
52 | | class VCaseExpr final : public VExpr { |
53 | | ENABLE_FACTORY_CREATOR(VCaseExpr); |
54 | | |
55 | | public: |
56 | | VCaseExpr(const TExprNode& node); |
57 | | ~VCaseExpr() override = default; |
58 | | Status execute_column_impl(VExprContext* context, const Block* block, const Selector* selector, |
59 | | size_t count, ColumnPtr& result_column) const override; |
60 | | Status prepare(RuntimeState* state, const RowDescriptor& desc, VExprContext* context) override; |
61 | | Status open(RuntimeState* state, VExprContext* context, |
62 | | FunctionContext::FunctionStateScope scope) override; |
63 | | void close(VExprContext* context, FunctionContext::FunctionStateScope scope) override; |
64 | | const std::string& expr_name() const override; |
65 | | std::string debug_string() const override; |
66 | 0 | bool has_else_expr() const { return _has_else_expr; } |
67 | 1 | Status clone_node(VExprSPtr* cloned_expr) const override { |
68 | 1 | DORIS_CHECK(cloned_expr != nullptr); |
69 | 1 | auto node = clone_texpr_node(); |
70 | 1 | TCaseExpr case_node; |
71 | 1 | case_node.__set_has_case_expr(false); |
72 | 1 | case_node.__set_has_else_expr(_has_else_expr); |
73 | 1 | node.__set_case_expr(case_node); |
74 | 1 | *cloned_expr = VCaseExpr::create_shared(node); |
75 | 1 | return Status::OK(); |
76 | 1 | } |
77 | | |
78 | | private: |
79 | | template <typename IndexType, typename ColumnType> |
80 | | ColumnPtr _execute_update_result_impl(const IndexType* then_idx, |
81 | | std::vector<ColumnPtr>& then_columns, |
82 | 2.07k | size_t rows_count) const { |
83 | 2.07k | auto result_column_ptr = data_type()->create_column(); |
84 | 2.07k | result_column_ptr->reserve(rows_count); |
85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; |
86 | | // the fixed-width SIMD path would copy only the views. |
87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || |
88 | | std::is_same_v<ColumnType, ColumnVarbinary> || |
89 | | std::is_same_v<ColumnType, ColumnBitmap> || |
90 | | std::is_same_v<ColumnType, ColumnArray> || |
91 | | std::is_same_v<ColumnType, ColumnMap> || |
92 | | std::is_same_v<ColumnType, ColumnStruct> || |
93 | | std::is_same_v<ColumnType, ColumnSpatial> || |
94 | | std::is_same_v<ColumnType, ColumnVariantV2> || |
95 | | std::is_same_v<ColumnType, ColumnHLL> || |
96 | | std::is_same_v<ColumnType, ColumnQuantileState> || |
97 | | std::is_same_v<ColumnType, ColumnIPv4> || |
98 | | std::is_same_v<ColumnType, ColumnIPv6> || |
99 | 1.47k | std::is_same_v<ColumnType, ColumnUUID>) { |
100 | | // result_column and all then_column is not nullable. |
101 | | // can't simd when type is string. |
102 | 1.47k | if (data_type()->is_nullable()) { |
103 | 1.38k | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, |
104 | 1.38k | then_columns, rows_count); |
105 | 1.38k | } else { |
106 | 88 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, |
107 | 88 | then_columns, rows_count); |
108 | 88 | } |
109 | 1.47k | } else if (data_type()->is_nullable()) { |
110 | | // result_column and all then_column is nullable. |
111 | 73 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, |
112 | 73 | then_columns, rows_count); |
113 | 528 | } else { |
114 | 528 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, |
115 | 528 | then_columns, rows_count); |
116 | 528 | } |
117 | 2.07k | return result_column_ptr; |
118 | 2.07k | } 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 | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 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 Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_15ColumnVarbinaryEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implItNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 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_13ColumnSpatialEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_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 | 82 | 86 | size_t rows_count) const { | 83 | 86 | auto result_column_ptr = data_type()->create_column(); | 84 | 86 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 86 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 3 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 3 | then_columns, rows_count); | 113 | 83 | } else { | 114 | 83 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 83 | then_columns, rows_count); | 116 | 83 | } | 117 | 86 | return result_column_ptr; | 118 | 86 | } |
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 | 82 | 36 | size_t rows_count) const { | 83 | 36 | auto result_column_ptr = data_type()->create_column(); | 84 | 36 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 36 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 36 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 36 | then_columns, rows_count); | 113 | 36 | } else { | 114 | 0 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 0 | then_columns, rows_count); | 116 | 0 | } | 117 | 36 | return result_column_ptr; | 118 | 36 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE6EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 168 | size_t rows_count) const { | 83 | 168 | auto result_column_ptr = data_type()->create_column(); | 84 | 168 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 168 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 27 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 27 | then_columns, rows_count); | 113 | 141 | } else { | 114 | 141 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 141 | then_columns, rows_count); | 116 | 141 | } | 117 | 168 | return result_column_ptr; | 118 | 168 | } |
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 | 82 | 26 | size_t rows_count) const { | 83 | 26 | auto result_column_ptr = data_type()->create_column(); | 84 | 26 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 26 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 1 | then_columns, rows_count); | 113 | 25 | } else { | 114 | 25 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 25 | then_columns, rows_count); | 116 | 25 | } | 117 | 26 | return result_column_ptr; | 118 | 26 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 29 | size_t rows_count) const { | 83 | 29 | auto result_column_ptr = data_type()->create_column(); | 84 | 29 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 29 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 4 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 4 | then_columns, rows_count); | 113 | 25 | } else { | 114 | 25 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 25 | then_columns, rows_count); | 116 | 25 | } | 117 | 29 | return result_column_ptr; | 118 | 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 | 82 | 1 | size_t rows_count) const { | 83 | 1 | auto result_column_ptr = data_type()->create_column(); | 84 | 1 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 1 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 1 | then_columns, rows_count); | 113 | 1 | } else { | 114 | 0 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 0 | then_columns, rows_count); | 116 | 0 | } | 117 | 1 | return result_column_ptr; | 118 | 1 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 1 | size_t rows_count) const { | 83 | 1 | auto result_column_ptr = data_type()->create_column(); | 84 | 1 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 1 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 1 | then_columns, rows_count); | 113 | 1 | } else { | 114 | 0 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 0 | then_columns, rows_count); | 116 | 0 | } | 117 | 1 | return result_column_ptr; | 118 | 1 | } |
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 | 82 | 1.44k | size_t rows_count) const { | 83 | 1.44k | auto result_column_ptr = data_type()->create_column(); | 84 | 1.44k | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 1.44k | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 1.44k | if (data_type()->is_nullable()) { | 103 | 1.36k | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 1.36k | then_columns, rows_count); | 105 | 1.36k | } else { | 106 | 85 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 85 | then_columns, rows_count); | 108 | 85 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 1.44k | return result_column_ptr; | 118 | 1.44k | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_15ColumnVarbinaryEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Line | Count | Source | 82 | 2 | size_t rows_count) const { | 83 | 2 | auto result_column_ptr = data_type()->create_column(); | 84 | 2 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 2 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 2 | if (data_type()->is_nullable()) { | 103 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 1 | then_columns, rows_count); | 105 | 1 | } else { | 106 | 1 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 1 | then_columns, rows_count); | 108 | 1 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 2 | return result_column_ptr; | 118 | 2 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE11EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 20 | size_t rows_count) const { | 83 | 20 | auto result_column_ptr = data_type()->create_column(); | 84 | 20 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 20 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 20 | } else { | 114 | 20 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 20 | then_columns, rows_count); | 116 | 20 | } | 117 | 20 | return result_column_ptr; | 118 | 20 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 18 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm Line | Count | Source | 82 | 18 | size_t rows_count) const { | 83 | 18 | auto result_column_ptr = data_type()->create_column(); | 84 | 18 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | | if (data_type()->is_nullable()) { | 103 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | | then_columns, rows_count); | 105 | | } else { | 106 | | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | | then_columns, rows_count); | 108 | | } | 109 | 18 | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | 0 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | 0 | then_columns, rows_count); | 113 | 18 | } else { | 114 | 18 | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | 18 | then_columns, rows_count); | 116 | 18 | } | 117 | 18 | return result_column_ptr; | 118 | 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 | 82 | 9 | size_t rows_count) const { | 83 | 9 | auto result_column_ptr = data_type()->create_column(); | 84 | 9 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 9 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 9 | if (data_type()->is_nullable()) { | 103 | 9 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 9 | then_columns, rows_count); | 105 | 9 | } else { | 106 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 0 | then_columns, rows_count); | 108 | 0 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 9 | return result_column_ptr; | 118 | 9 | } |
_ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_13ColumnSpatialEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Line | Count | Source | 82 | 12 | size_t rows_count) const { | 83 | 12 | auto result_column_ptr = data_type()->create_column(); | 84 | 12 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 12 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 12 | if (data_type()->is_nullable()) { | 103 | 10 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 10 | then_columns, rows_count); | 105 | 10 | } else { | 106 | 2 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 2 | then_columns, rows_count); | 108 | 2 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 12 | return result_column_ptr; | 118 | 12 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_12ColumnVectorILNS_13PrimitiveTypeE36EEEEENS_3COWINS_7IColumnEE13immutable_ptrIS6_EEPKT_RSt6vectorIS9_SaIS9_EEm _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_11ColumnArrayEEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Line | Count | Source | 82 | 1 | size_t rows_count) const { | 83 | 1 | auto result_column_ptr = data_type()->create_column(); | 84 | 1 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 1 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 1 | if (data_type()->is_nullable()) { | 103 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 1 | then_columns, rows_count); | 105 | 1 | } else { | 106 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 0 | then_columns, rows_count); | 108 | 0 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 1 | return result_column_ptr; | 118 | 1 | } |
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 | 82 | 5 | size_t rows_count) const { | 83 | 5 | auto result_column_ptr = data_type()->create_column(); | 84 | 5 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 5 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 5 | if (data_type()->is_nullable()) { | 103 | 5 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 5 | then_columns, rows_count); | 105 | 5 | } else { | 106 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 0 | then_columns, rows_count); | 108 | 0 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 5 | return result_column_ptr; | 118 | 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 _ZNK5doris9VCaseExpr27_execute_update_result_implIhNS_15ColumnVariantV2EEENS_3COWINS_7IColumnEE13immutable_ptrIS4_EEPKT_RSt6vectorIS7_SaIS7_EEm Line | Count | Source | 82 | 1 | size_t rows_count) const { | 83 | 1 | auto result_column_ptr = data_type()->create_column(); | 84 | 1 | result_column_ptr->reserve(rows_count); | 85 | | // Spatial StringViews require insert_from to copy WKB into the result's arena; | 86 | | // the fixed-width SIMD path would copy only the views. | 87 | | if constexpr (std::is_same_v<ColumnType, ColumnString> || | 88 | | std::is_same_v<ColumnType, ColumnVarbinary> || | 89 | | std::is_same_v<ColumnType, ColumnBitmap> || | 90 | | std::is_same_v<ColumnType, ColumnArray> || | 91 | | std::is_same_v<ColumnType, ColumnMap> || | 92 | | std::is_same_v<ColumnType, ColumnStruct> || | 93 | | std::is_same_v<ColumnType, ColumnSpatial> || | 94 | | std::is_same_v<ColumnType, ColumnVariantV2> || | 95 | | std::is_same_v<ColumnType, ColumnHLL> || | 96 | | std::is_same_v<ColumnType, ColumnQuantileState> || | 97 | | std::is_same_v<ColumnType, ColumnIPv4> || | 98 | | std::is_same_v<ColumnType, ColumnIPv6> || | 99 | 1 | std::is_same_v<ColumnType, ColumnUUID>) { | 100 | | // result_column and all then_column is not nullable. | 101 | | // can't simd when type is string. | 102 | 1 | if (data_type()->is_nullable()) { | 103 | 1 | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 104 | 1 | then_columns, rows_count); | 105 | 1 | } else { | 106 | 0 | update_result_normal<IndexType, ColumnType, false>(result_column_ptr, then_idx, | 107 | 0 | then_columns, rows_count); | 108 | 0 | } | 109 | | } else if (data_type()->is_nullable()) { | 110 | | // result_column and all then_column is nullable. | 111 | | update_result_normal<IndexType, ColumnType, true>(result_column_ptr, then_idx, | 112 | | then_columns, rows_count); | 113 | | } else { | 114 | | update_result_auto_simd<IndexType, ColumnType>(result_column_ptr, then_idx, | 115 | | then_columns, rows_count); | 116 | | } | 117 | 1 | return result_column_ptr; | 118 | 1 | } |
|
119 | | |
120 | | template <typename IndexType> |
121 | | ColumnPtr _execute_update_result(const IndexType* then_idx, |
122 | | std::vector<ColumnPtr>& then_columns, |
123 | 1.79k | size_t rows_count) const { |
124 | 1.79k | #define CASE_TYPE(ptype, coltype) \ |
125 | 1.79k | case PrimitiveType::ptype: \ |
126 | 1.78k | return _execute_update_result_impl<IndexType, coltype>(then_idx, then_columns, rows_count); |
127 | | |
128 | 1.79k | switch (data_type()->get_primitive_type()) { |
129 | 0 | CASE_TYPE(TYPE_BOOLEAN, ColumnUInt8) |
130 | 86 | CASE_TYPE(TYPE_TINYINT, ColumnInt8) |
131 | 0 | CASE_TYPE(TYPE_SMALLINT, ColumnInt16) |
132 | 36 | CASE_TYPE(TYPE_INT, ColumnInt32) |
133 | 168 | CASE_TYPE(TYPE_BIGINT, ColumnInt64) |
134 | 0 | CASE_TYPE(TYPE_LARGEINT, ColumnInt128) |
135 | 8 | CASE_TYPE(TYPE_FLOAT, ColumnFloat32) |
136 | 11 | CASE_TYPE(TYPE_DOUBLE, ColumnFloat64) |
137 | 0 | CASE_TYPE(TYPE_DECIMAL32, ColumnDecimal32) |
138 | 1 | CASE_TYPE(TYPE_DECIMAL64, ColumnDecimal64) |
139 | 1 | CASE_TYPE(TYPE_DECIMAL256, ColumnDecimal256) |
140 | 0 | CASE_TYPE(TYPE_DECIMAL128I, ColumnDecimal128V3) |
141 | 0 | CASE_TYPE(TYPE_DECIMALV2, ColumnDecimal128V2) |
142 | 30 | CASE_TYPE(TYPE_STRING, ColumnString) |
143 | 0 | CASE_TYPE(TYPE_CHAR, ColumnString) |
144 | 1.41k | CASE_TYPE(TYPE_VARCHAR, ColumnString) |
145 | 0 | CASE_TYPE(TYPE_JSONB, ColumnString) |
146 | 2 | CASE_TYPE(TYPE_VARBINARY, ColumnVarbinary) |
147 | 0 | CASE_TYPE(TYPE_DATE, ColumnDate) |
148 | 0 | CASE_TYPE(TYPE_DATETIME, ColumnDateTime) |
149 | 2 | CASE_TYPE(TYPE_DATEV2, ColumnDateV2) |
150 | 0 | CASE_TYPE(TYPE_DATETIMEV2, ColumnDateTimeV2) |
151 | 0 | CASE_TYPE(TYPE_TIMESTAMP_NS, ColumnTimeStampNs) |
152 | 0 | CASE_TYPE(TYPE_TIMESTAMPTZ, ColumnTimeStampTz) |
153 | 0 | CASE_TYPE(TYPE_IPV6, ColumnIPv6) |
154 | 9 | CASE_TYPE(TYPE_UUID, ColumnUUID) |
155 | 6 | CASE_TYPE(TYPE_GEOMETRY, ColumnSpatial) |
156 | 6 | CASE_TYPE(TYPE_GEOGRAPHY, ColumnSpatial) |
157 | 0 | CASE_TYPE(TYPE_IPV4, ColumnIPv4) |
158 | 1 | CASE_TYPE(TYPE_ARRAY, ColumnArray) |
159 | 0 | CASE_TYPE(TYPE_MAP, ColumnMap) |
160 | 0 | CASE_TYPE(TYPE_STRUCT, ColumnStruct) |
161 | 5 | CASE_TYPE(TYPE_BITMAP, ColumnBitmap) |
162 | 0 | CASE_TYPE(TYPE_HLL, ColumnHLL) |
163 | 0 | CASE_TYPE(TYPE_QUANTILE_STATE, ColumnQuantileState) |
164 | 1 | case PrimitiveType::TYPE_VARIANT: { |
165 | 1 | const IDataType* variant_type = remove_nullable(data_type()).get(); |
166 | 1 | DORIS_CHECK(dynamic_cast<const DataTypeVariantV2*>(variant_type) != nullptr); |
167 | 1 | return _execute_update_result_impl<IndexType, ColumnVariantV2>(then_idx, then_columns, |
168 | 1 | rows_count); |
169 | 0 | } |
170 | 0 | default: |
171 | 0 | throw Exception(ErrorCode::NOT_IMPLEMENTED_ERROR, "argument_type {} not supported", |
172 | 0 | data_type()->get_name()); |
173 | 1.79k | } |
174 | 1.79k | #undef CASE_TYPE |
175 | 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 | 123 | 1.79k | size_t rows_count) const { | 124 | 1.79k | #define CASE_TYPE(ptype, coltype) \ | 125 | 1.79k | case PrimitiveType::ptype: \ | 126 | 1.79k | return _execute_update_result_impl<IndexType, coltype>(then_idx, then_columns, rows_count); | 127 | | | 128 | 1.79k | switch (data_type()->get_primitive_type()) { | 129 | 0 | CASE_TYPE(TYPE_BOOLEAN, ColumnUInt8) | 130 | 86 | CASE_TYPE(TYPE_TINYINT, ColumnInt8) | 131 | 0 | CASE_TYPE(TYPE_SMALLINT, ColumnInt16) | 132 | 36 | CASE_TYPE(TYPE_INT, ColumnInt32) | 133 | 168 | CASE_TYPE(TYPE_BIGINT, ColumnInt64) | 134 | 0 | CASE_TYPE(TYPE_LARGEINT, ColumnInt128) | 135 | 8 | CASE_TYPE(TYPE_FLOAT, ColumnFloat32) | 136 | 11 | CASE_TYPE(TYPE_DOUBLE, ColumnFloat64) | 137 | 0 | CASE_TYPE(TYPE_DECIMAL32, ColumnDecimal32) | 138 | 1 | CASE_TYPE(TYPE_DECIMAL64, ColumnDecimal64) | 139 | 1 | CASE_TYPE(TYPE_DECIMAL256, ColumnDecimal256) | 140 | 0 | CASE_TYPE(TYPE_DECIMAL128I, ColumnDecimal128V3) | 141 | 0 | CASE_TYPE(TYPE_DECIMALV2, ColumnDecimal128V2) | 142 | 30 | CASE_TYPE(TYPE_STRING, ColumnString) | 143 | 0 | CASE_TYPE(TYPE_CHAR, ColumnString) | 144 | 1.41k | CASE_TYPE(TYPE_VARCHAR, ColumnString) | 145 | 0 | CASE_TYPE(TYPE_JSONB, ColumnString) | 146 | 2 | CASE_TYPE(TYPE_VARBINARY, ColumnVarbinary) | 147 | 0 | CASE_TYPE(TYPE_DATE, ColumnDate) | 148 | 0 | CASE_TYPE(TYPE_DATETIME, ColumnDateTime) | 149 | 2 | CASE_TYPE(TYPE_DATEV2, ColumnDateV2) | 150 | 0 | CASE_TYPE(TYPE_DATETIMEV2, ColumnDateTimeV2) | 151 | 0 | CASE_TYPE(TYPE_TIMESTAMP_NS, ColumnTimeStampNs) | 152 | 0 | CASE_TYPE(TYPE_TIMESTAMPTZ, ColumnTimeStampTz) | 153 | 0 | CASE_TYPE(TYPE_IPV6, ColumnIPv6) | 154 | 9 | CASE_TYPE(TYPE_UUID, ColumnUUID) | 155 | 6 | CASE_TYPE(TYPE_GEOMETRY, ColumnSpatial) | 156 | 6 | CASE_TYPE(TYPE_GEOGRAPHY, ColumnSpatial) | 157 | 0 | CASE_TYPE(TYPE_IPV4, ColumnIPv4) | 158 | 1 | CASE_TYPE(TYPE_ARRAY, ColumnArray) | 159 | 0 | CASE_TYPE(TYPE_MAP, ColumnMap) | 160 | 0 | CASE_TYPE(TYPE_STRUCT, ColumnStruct) | 161 | 5 | CASE_TYPE(TYPE_BITMAP, ColumnBitmap) | 162 | 0 | CASE_TYPE(TYPE_HLL, ColumnHLL) | 163 | 0 | CASE_TYPE(TYPE_QUANTILE_STATE, ColumnQuantileState) | 164 | 1 | case PrimitiveType::TYPE_VARIANT: { | 165 | 1 | const IDataType* variant_type = remove_nullable(data_type()).get(); | 166 | 1 | DORIS_CHECK(dynamic_cast<const DataTypeVariantV2*>(variant_type) != nullptr); | 167 | 1 | return _execute_update_result_impl<IndexType, ColumnVariantV2>(then_idx, then_columns, | 168 | 1 | rows_count); | 169 | 0 | } | 170 | 0 | default: | 171 | 0 | throw Exception(ErrorCode::NOT_IMPLEMENTED_ERROR, "argument_type {} not supported", | 172 | 0 | data_type()->get_name()); | 173 | 1.79k | } | 174 | 1.79k | #undef CASE_TYPE | 175 | 1.79k | } |
|
176 | | |
177 | | template <typename IndexType, typename ColumnType, bool then_null> |
178 | | void update_result_normal(MutableColumnPtr& result_column_ptr, |
179 | | const IndexType* __restrict then_idx, |
180 | 1.55k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
181 | 1.55k | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); |
182 | 1.55k | std::vector<uint8_t> is_consts(then_columns.size()); |
183 | 1.55k | std::vector<uint8_t> is_nullable(then_columns.size()); |
184 | 5.06k | for (size_t i = 0; i < then_columns.size(); i++) { |
185 | 3.51k | if (!then_columns[i]) { |
186 | 39 | continue; |
187 | 39 | } |
188 | 3.47k | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); |
189 | 3.47k | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); |
190 | 3.47k | } |
191 | | |
192 | 1.55k | auto* raw_result_column = result_column_ptr.get(); |
193 | 371k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
194 | 369k | if (!_has_else_expr && !then_idx[row_idx]) { |
195 | 15 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) |
196 | 15 | ->insert_default(); |
197 | 15 | continue; |
198 | 15 | } |
199 | 369k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; |
200 | 369k | if constexpr (then_null) { |
201 | 138k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( |
202 | 138k | result_column_ptr.get()); |
203 | 138k | if (is_nullable[then_idx[row_idx]]) { |
204 | 117k | nullable->insert_from_with_type<ColumnType>( |
205 | 117k | *raw_then_columns[then_idx[row_idx]], target); |
206 | 117k | } else { |
207 | 21.2k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( |
208 | 21.2k | nullable->get_nested_column_ptr().get()); |
209 | 21.2k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); |
210 | 21.2k | nullable->push_false_to_nullmap(1); |
211 | 21.2k | } |
212 | 231k | } else { |
213 | 231k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) |
214 | 231k | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); |
215 | 231k | } |
216 | 369k | } |
217 | 1.55k | } 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_15ColumnVarbinaryELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_15ColumnVarbinaryELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_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_13ColumnSpatialELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalItNS_13ColumnSpatialELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_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 | 180 | 3 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 3 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 3 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 3 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 8 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 5 | if (!then_columns[i]) { | 186 | 2 | continue; | 187 | 2 | } | 188 | 3 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 3 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 3 | } | 191 | | | 192 | 3 | auto* raw_result_column = result_column_ptr.get(); | 193 | 7 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 4 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 4 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 4 | if constexpr (then_null) { | 201 | 4 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 4 | result_column_ptr.get()); | 203 | 4 | if (is_nullable[then_idx[row_idx]]) { | 204 | 1 | nullable->insert_from_with_type<ColumnType>( | 205 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 3 | } else { | 207 | 3 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 3 | nullable->get_nested_column_ptr().get()); | 209 | 3 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 3 | nullable->push_false_to_nullmap(1); | 211 | 3 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 4 | } | 217 | 3 | } |
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 | 180 | 36 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 36 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 36 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 36 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 85 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 49 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 49 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 49 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 49 | } | 191 | | | 192 | 36 | auto* raw_result_column = result_column_ptr.get(); | 193 | 84 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 48 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 48 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 48 | if constexpr (then_null) { | 201 | 48 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 48 | result_column_ptr.get()); | 203 | 48 | if (is_nullable[then_idx[row_idx]]) { | 204 | 48 | nullable->insert_from_with_type<ColumnType>( | 205 | 48 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 48 | } else { | 207 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 0 | nullable->get_nested_column_ptr().get()); | 209 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 0 | nullable->push_false_to_nullmap(1); | 211 | 0 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 48 | } | 217 | 36 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE6EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 180 | 27 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 27 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 27 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 27 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 90 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 63 | if (!then_columns[i]) { | 186 | 13 | continue; | 187 | 13 | } | 188 | 50 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 50 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 50 | } | 191 | | | 192 | 27 | auto* raw_result_column = result_column_ptr.get(); | 193 | 100k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 100k | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 100k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 100k | if constexpr (then_null) { | 201 | 100k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 100k | result_column_ptr.get()); | 203 | 100k | if (is_nullable[then_idx[row_idx]]) { | 204 | 100k | nullable->insert_from_with_type<ColumnType>( | 205 | 100k | *raw_then_columns[then_idx[row_idx]], target); | 206 | 100k | } else { | 207 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 0 | nullable->get_nested_column_ptr().get()); | 209 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 0 | nullable->push_false_to_nullmap(1); | 211 | 0 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 100k | } | 217 | 27 | } |
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 | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 4 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 3 | if (!then_columns[i]) { | 186 | 1 | continue; | 187 | 1 | } | 188 | 2 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 2 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 2 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 4 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 3 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 1 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 1 | ->insert_default(); | 197 | 1 | continue; | 198 | 1 | } | 199 | 2 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 2 | if constexpr (then_null) { | 201 | 2 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 2 | result_column_ptr.get()); | 203 | 2 | if (is_nullable[then_idx[row_idx]]) { | 204 | 0 | nullable->insert_from_with_type<ColumnType>( | 205 | 0 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 2 | } else { | 207 | 2 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 2 | nullable->get_nested_column_ptr().get()); | 209 | 2 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 2 | nullable->push_false_to_nullmap(1); | 211 | 2 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 2 | } | 217 | 1 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 180 | 4 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 4 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 4 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 4 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 15 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 11 | if (!then_columns[i]) { | 186 | 1 | continue; | 187 | 1 | } | 188 | 10 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 10 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 10 | } | 191 | | | 192 | 4 | auto* raw_result_column = result_column_ptr.get(); | 193 | 17 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 13 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 1 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 1 | ->insert_default(); | 197 | 1 | continue; | 198 | 1 | } | 199 | 12 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 12 | if constexpr (then_null) { | 201 | 12 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 12 | result_column_ptr.get()); | 203 | 12 | if (is_nullable[then_idx[row_idx]]) { | 204 | 7 | nullable->insert_from_with_type<ColumnType>( | 205 | 7 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 7 | } else { | 207 | 5 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 5 | nullable->get_nested_column_ptr().get()); | 209 | 5 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 5 | nullable->push_false_to_nullmap(1); | 211 | 5 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 12 | } | 217 | 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 | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 2 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 1 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 1 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 1 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 1 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 2 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 1 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 1 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 1 | if constexpr (then_null) { | 201 | 1 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 1 | result_column_ptr.get()); | 203 | 1 | if (is_nullable[then_idx[row_idx]]) { | 204 | 1 | nullable->insert_from_with_type<ColumnType>( | 205 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 1 | } else { | 207 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 0 | nullable->get_nested_column_ptr().get()); | 209 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 0 | nullable->push_false_to_nullmap(1); | 211 | 0 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 1 | } | 217 | 1 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnDecimalILNS_13PrimitiveTypeE35EEELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 5 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 4 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 4 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 4 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 4 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 4 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 3 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 3 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 3 | if constexpr (then_null) { | 201 | 3 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 3 | result_column_ptr.get()); | 203 | 3 | if (is_nullable[then_idx[row_idx]]) { | 204 | 3 | nullable->insert_from_with_type<ColumnType>( | 205 | 3 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 3 | } else { | 207 | 0 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 0 | nullable->get_nested_column_ptr().get()); | 209 | 0 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 0 | nullable->push_false_to_nullmap(1); | 211 | 0 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 3 | } | 217 | 1 | } |
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 | 180 | 1.36k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1.36k | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1.36k | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1.36k | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 4.43k | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 3.07k | if (!then_columns[i]) { | 186 | 21 | continue; | 187 | 21 | } | 188 | 3.05k | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 3.05k | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 3.05k | } | 191 | | | 192 | 1.36k | auto* raw_result_column = result_column_ptr.get(); | 193 | 6.72k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 5.36k | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 11 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 11 | ->insert_default(); | 197 | 11 | continue; | 198 | 11 | } | 199 | 5.35k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 5.35k | if constexpr (then_null) { | 201 | 5.35k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 5.35k | result_column_ptr.get()); | 203 | 5.35k | if (is_nullable[then_idx[row_idx]]) { | 204 | 519 | nullable->insert_from_with_type<ColumnType>( | 205 | 519 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 4.83k | } else { | 207 | 4.83k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 4.83k | nullable->get_nested_column_ptr().get()); | 209 | 4.83k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 4.83k | nullable->push_false_to_nullmap(1); | 211 | 4.83k | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 5.35k | } | 217 | 1.36k | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_9ColumnStrIjEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS5_EEPKT_RSt6vectorINS6_13immutable_ptrIS5_EESaISF_EEm Line | Count | Source | 180 | 86 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 86 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 86 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 86 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 299 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 213 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 213 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 213 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 213 | } | 191 | | | 192 | 86 | auto* raw_result_column = result_column_ptr.get(); | 193 | 231k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 231k | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 231k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | | if constexpr (then_null) { | 201 | | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | | result_column_ptr.get()); | 203 | | if (is_nullable[then_idx[row_idx]]) { | 204 | | nullable->insert_from_with_type<ColumnType>( | 205 | | *raw_then_columns[then_idx[row_idx]], target); | 206 | | } else { | 207 | | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | | nullable->get_nested_column_ptr().get()); | 209 | | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | | nullable->push_false_to_nullmap(1); | 211 | | } | 212 | 231k | } else { | 213 | 231k | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | 231k | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | 231k | } | 216 | 231k | } | 217 | 86 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVarbinaryELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 4 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 3 | if (!then_columns[i]) { | 186 | 1 | continue; | 187 | 1 | } | 188 | 2 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 2 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 2 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 7 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 6 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 2 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 2 | ->insert_default(); | 197 | 2 | continue; | 198 | 2 | } | 199 | 4 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 4 | if constexpr (then_null) { | 201 | 4 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 4 | result_column_ptr.get()); | 203 | 4 | if (is_nullable[then_idx[row_idx]]) { | 204 | 3 | nullable->insert_from_with_type<ColumnType>( | 205 | 3 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 3 | } else { | 207 | 1 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 1 | nullable->get_nested_column_ptr().get()); | 209 | 1 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 1 | nullable->push_false_to_nullmap(1); | 211 | 1 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 4 | } | 217 | 1 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVarbinaryELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 4 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 3 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 3 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 3 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 3 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 7 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 6 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 6 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | | if constexpr (then_null) { | 201 | | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | | result_column_ptr.get()); | 203 | | if (is_nullable[then_idx[row_idx]]) { | 204 | | nullable->insert_from_with_type<ColumnType>( | 205 | | *raw_then_columns[then_idx[row_idx]], target); | 206 | | } else { | 207 | | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | | nullable->get_nested_column_ptr().get()); | 209 | | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | | nullable->push_false_to_nullmap(1); | 211 | | } | 212 | 6 | } else { | 213 | 6 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | 6 | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | 6 | } | 216 | 6 | } | 217 | 1 | } |
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 | 180 | 9 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 9 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 9 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 9 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 40 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 31 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 31 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 31 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 31 | } | 191 | | | 192 | 9 | auto* raw_result_column = result_column_ptr.get(); | 193 | 32.7k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 32.7k | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 32.7k | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 32.7k | if constexpr (then_null) { | 201 | 32.7k | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 32.7k | result_column_ptr.get()); | 203 | 32.7k | if (is_nullable[then_idx[row_idx]]) { | 204 | 16.3k | nullable->insert_from_with_type<ColumnType>( | 205 | 16.3k | *raw_then_columns[then_idx[row_idx]], target); | 206 | 16.3k | } else { | 207 | 16.3k | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 16.3k | nullable->get_nested_column_ptr().get()); | 209 | 16.3k | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 16.3k | nullable->push_false_to_nullmap(1); | 211 | 16.3k | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 32.7k | } | 217 | 9 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_12ColumnVectorILNS_13PrimitiveTypeE44EEELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm _ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnSpatialELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 10 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 10 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 10 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 10 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 40 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 30 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 30 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 30 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 30 | } | 191 | | | 192 | 10 | auto* raw_result_column = result_column_ptr.get(); | 193 | 70 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 60 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 60 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 60 | if constexpr (then_null) { | 201 | 60 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 60 | result_column_ptr.get()); | 203 | 60 | if (is_nullable[then_idx[row_idx]]) { | 204 | 44 | nullable->insert_from_with_type<ColumnType>( | 205 | 44 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 44 | } else { | 207 | 16 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 16 | nullable->get_nested_column_ptr().get()); | 209 | 16 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 16 | nullable->push_false_to_nullmap(1); | 211 | 16 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 60 | } | 217 | 10 | } |
_ZNK5doris9VCaseExpr20update_result_normalIhNS_13ColumnSpatialELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 2 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 2 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 2 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 2 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 8 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 6 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 6 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 6 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 6 | } | 191 | | | 192 | 2 | auto* raw_result_column = result_column_ptr.get(); | 193 | 14 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 12 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 12 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | | if constexpr (then_null) { | 201 | | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | | result_column_ptr.get()); | 203 | | if (is_nullable[then_idx[row_idx]]) { | 204 | | nullable->insert_from_with_type<ColumnType>( | 205 | | *raw_then_columns[then_idx[row_idx]], target); | 206 | | } else { | 207 | | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | | nullable->get_nested_column_ptr().get()); | 209 | | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | | nullable->push_false_to_nullmap(1); | 211 | | } | 212 | 12 | } else { | 213 | 12 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | 12 | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | 12 | } | 216 | 12 | } | 217 | 2 | } |
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 _ZNK5doris9VCaseExpr20update_result_normalIhNS_11ColumnArrayELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 4 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 3 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 3 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 3 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 3 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 4 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 3 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 3 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 3 | if constexpr (then_null) { | 201 | 3 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 3 | result_column_ptr.get()); | 203 | 3 | if (is_nullable[then_idx[row_idx]]) { | 204 | 1 | nullable->insert_from_with_type<ColumnType>( | 205 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 2 | } else { | 207 | 2 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 2 | nullable->get_nested_column_ptr().get()); | 209 | 2 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 2 | nullable->push_false_to_nullmap(1); | 211 | 2 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 3 | } | 217 | 1 | } |
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 | 180 | 5 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 5 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 5 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 5 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 12 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 7 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 7 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 7 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 7 | } | 191 | | | 192 | 5 | auto* raw_result_column = result_column_ptr.get(); | 193 | 11 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 6 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 6 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 6 | if constexpr (then_null) { | 201 | 6 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 6 | result_column_ptr.get()); | 203 | 6 | if (is_nullable[then_idx[row_idx]]) { | 204 | 4 | nullable->insert_from_with_type<ColumnType>( | 205 | 4 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 4 | } else { | 207 | 2 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 2 | nullable->get_nested_column_ptr().get()); | 209 | 2 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 2 | nullable->push_false_to_nullmap(1); | 211 | 2 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 6 | } | 217 | 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 _ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVariantV2ELb1EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm Line | Count | Source | 180 | 1 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 181 | 1 | std::vector<ColumnPtr> raw_then_columns(then_columns.size()); | 182 | 1 | std::vector<uint8_t> is_consts(then_columns.size()); | 183 | 1 | std::vector<uint8_t> is_nullable(then_columns.size()); | 184 | 5 | for (size_t i = 0; i < then_columns.size(); i++) { | 185 | 4 | if (!then_columns[i]) { | 186 | 0 | continue; | 187 | 0 | } | 188 | 4 | std::tie(raw_then_columns[i], is_consts[i]) = unpack_if_const(then_columns[i]); | 189 | 4 | is_nullable[i] = is_column_nullable(*raw_then_columns[i]); | 190 | 4 | } | 191 | | | 192 | 1 | auto* raw_result_column = result_column_ptr.get(); | 193 | 5 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 194 | 4 | if (!_has_else_expr && !then_idx[row_idx]) { | 195 | 0 | assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>(raw_result_column) | 196 | 0 | ->insert_default(); | 197 | 0 | continue; | 198 | 0 | } | 199 | 4 | size_t target = is_consts[then_idx[row_idx]] ? 0 : row_idx; | 200 | 4 | if constexpr (then_null) { | 201 | 4 | auto* nullable = assert_cast<ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 202 | 4 | result_column_ptr.get()); | 203 | 4 | if (is_nullable[then_idx[row_idx]]) { | 204 | 1 | nullable->insert_from_with_type<ColumnType>( | 205 | 1 | *raw_then_columns[then_idx[row_idx]], target); | 206 | 3 | } else { | 207 | 3 | auto* nested = assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>( | 208 | 3 | nullable->get_nested_column_ptr().get()); | 209 | 3 | nested->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 210 | 3 | nullable->push_false_to_nullmap(1); | 211 | 3 | } | 212 | | } else { | 213 | | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 214 | | ->insert_from(*raw_then_columns[then_idx[row_idx]], target); | 215 | | } | 216 | 4 | } | 217 | 1 | } |
Unexecuted instantiation: _ZNK5doris9VCaseExpr20update_result_normalIhNS_15ColumnVariantV2ELb0EEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS4_EEPKT_RSt6vectorINS5_13immutable_ptrIS4_EESaISE_EEm |
218 | | |
219 | | template <typename IndexType, typename ColumnType> |
220 | | void update_result_auto_simd(MutableColumnPtr& result_column_ptr, |
221 | | const IndexType* __restrict then_idx, |
222 | 528 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
223 | 10.8k | for (auto& then_ptr : then_columns) { |
224 | 10.8k | then_ptr = then_ptr->convert_to_full_column_if_const(); |
225 | 10.8k | } |
226 | | |
227 | 528 | result_column_ptr->resize(rows_count); |
228 | 528 | auto* __restrict result_raw_data = |
229 | 528 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) |
230 | 528 | ->get_data() |
231 | 528 | .data(); |
232 | | |
233 | | // set default value |
234 | 505k | for (int i = 0; i < rows_count; i++) { |
235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || |
236 | | std::is_same_v<ColumnType, ColumnDateTime> || |
237 | | std::is_same_v<ColumnType, ColumnDateV2> || |
238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || |
239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || |
240 | 297k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { |
241 | 297k | result_raw_data[i] = ColumnType::default_value(); |
242 | 297k | } else { |
243 | 207k | result_raw_data[i] = {}; |
244 | 207k | } |
245 | 504k | } |
246 | | |
247 | 11.4k | for (IndexType i = 0; i < then_columns.size(); i++) { |
248 | 10.8k | if (!then_columns[i]) { |
249 | 0 | continue; |
250 | 0 | } |
251 | 10.8k | const auto* __restrict column_raw_data = |
252 | 10.8k | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( |
253 | 10.8k | then_columns[i].get()) |
254 | 10.8k | ->get_data() |
255 | 10.8k | .data(); |
256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || |
257 | | std::is_same_v<ColumnType, ColumnFloat64> || |
258 | | std::is_same_v<ColumnType, ColumnDate> || |
259 | | std::is_same_v<ColumnType, ColumnDateTime> || |
260 | | std::is_same_v<ColumnType, ColumnDateV2> || |
261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || |
262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || |
263 | 10.5k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { |
264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. |
265 | | // Conditional stores also let the compiler vectorize without loading from a |
266 | | // selected source/destination pointer, as a ternary assignment can do. |
267 | 35.9M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { |
268 | 35.9M | if (then_idx[row_idx] == i) { |
269 | 404k | result_raw_data[row_idx] = column_raw_data[row_idx]; |
270 | 404k | } |
271 | 35.9M | } |
272 | 10.5k | } else { |
273 | 300k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
274 | 300k | result_raw_data[row_idx] += |
275 | 300k | typename ColumnType::value_type(then_idx[row_idx] == i) * |
276 | 300k | column_raw_data[row_idx]; |
277 | 300k | } |
278 | 353 | } |
279 | 10.8k | } |
280 | 528 | } 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 | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 24.7k | } else { | 243 | 24.7k | result_raw_data[i] = {}; | 244 | 24.7k | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 24.7k | } else { | 243 | 24.7k | result_raw_data[i] = {}; | 244 | 24.7k | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 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 | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdItNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 658 | for (auto& then_ptr : then_columns) { | 224 | 658 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 658 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 676 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 658 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 658 | const auto* __restrict column_raw_data = | 252 | 658 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 658 | then_columns[i].get()) | 254 | 658 | ->get_data() | 255 | 658 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 658 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 658 | } | 280 | 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 | 222 | 83 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 170 | for (auto& then_ptr : then_columns) { | 224 | 170 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 170 | } | 226 | | | 227 | 83 | result_column_ptr->resize(rows_count); | 228 | 83 | auto* __restrict result_raw_data = | 229 | 83 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 83 | ->get_data() | 231 | 83 | .data(); | 232 | | | 233 | | // set default value | 234 | 171 | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 88 | } else { | 243 | 88 | result_raw_data[i] = {}; | 244 | 88 | } | 245 | 88 | } | 246 | | | 247 | 253 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 170 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 170 | const auto* __restrict column_raw_data = | 252 | 170 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 170 | then_columns[i].get()) | 254 | 170 | ->get_data() | 255 | 170 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | | if (then_idx[row_idx] == i) { | 269 | | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | | } | 271 | | } | 272 | 170 | } else { | 273 | 348 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | 178 | result_raw_data[row_idx] += | 275 | 178 | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | 178 | column_raw_data[row_idx]; | 277 | 178 | } | 278 | 170 | } | 279 | 170 | } | 280 | 83 | } |
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 | 222 | 141 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 183 | for (auto& then_ptr : then_columns) { | 224 | 183 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 183 | } | 226 | | | 227 | 141 | result_column_ptr->resize(rows_count); | 228 | 141 | auto* __restrict result_raw_data = | 229 | 141 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 141 | ->get_data() | 231 | 141 | .data(); | 232 | | | 233 | | // set default value | 234 | 100k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 100k | } else { | 243 | 100k | result_raw_data[i] = {}; | 244 | 100k | } | 245 | 100k | } | 246 | | | 247 | 324 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 183 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 183 | const auto* __restrict column_raw_data = | 252 | 183 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 183 | then_columns[i].get()) | 254 | 183 | ->get_data() | 255 | 183 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | | if (then_idx[row_idx] == i) { | 269 | | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | | } | 271 | | } | 272 | 183 | } else { | 273 | 300k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | 300k | result_raw_data[row_idx] += | 275 | 300k | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | 300k | column_raw_data[row_idx]; | 277 | 300k | } | 278 | 183 | } | 279 | 183 | } | 280 | 141 | } |
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 | 222 | 25 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 675 | for (auto& then_ptr : then_columns) { | 224 | 675 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 675 | } | 226 | | | 227 | 25 | result_column_ptr->resize(rows_count); | 228 | 25 | auto* __restrict result_raw_data = | 229 | 25 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 25 | ->get_data() | 231 | 25 | .data(); | 232 | | | 233 | | // set default value | 234 | 28.9k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 28.8k | } else { | 243 | 28.8k | result_raw_data[i] = {}; | 244 | 28.8k | } | 245 | 28.8k | } | 246 | | | 247 | 700 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 675 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 675 | const auto* __restrict column_raw_data = | 252 | 675 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 675 | then_columns[i].get()) | 254 | 675 | ->get_data() | 255 | 675 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 675 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 28.8k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 28.8k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 675 | } | 280 | 25 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE9EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 25 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 675 | for (auto& then_ptr : then_columns) { | 224 | 675 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 675 | } | 226 | | | 227 | 25 | result_column_ptr->resize(rows_count); | 228 | 25 | auto* __restrict result_raw_data = | 229 | 25 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 25 | ->get_data() | 231 | 25 | .data(); | 232 | | | 233 | | // set default value | 234 | 28.9k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | | result_raw_data[i] = ColumnType::default_value(); | 242 | 28.8k | } else { | 243 | 28.8k | result_raw_data[i] = {}; | 244 | 28.8k | } | 245 | 28.8k | } | 246 | | | 247 | 700 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 675 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 675 | const auto* __restrict column_raw_data = | 252 | 675 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 675 | then_columns[i].get()) | 254 | 675 | ->get_data() | 255 | 675 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 675 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.25M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.25M | if (then_idx[row_idx] == i) { | 269 | 28.8k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 28.8k | } | 271 | 2.25M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 675 | } | 280 | 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 | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 654 | for (auto& then_ptr : then_columns) { | 224 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 654 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 654 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 654 | const auto* __restrict column_raw_data = | 252 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 654 | then_columns[i].get()) | 254 | 654 | ->get_data() | 255 | 654 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 654 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE12EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 654 | for (auto& then_ptr : then_columns) { | 224 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 654 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 654 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 654 | const auto* __restrict column_raw_data = | 252 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 654 | then_columns[i].get()) | 254 | 654 | ->get_data() | 255 | 654 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 654 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE25EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 20 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 660 | for (auto& then_ptr : then_columns) { | 224 | 660 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 660 | } | 226 | | | 227 | 20 | result_column_ptr->resize(rows_count); | 228 | 20 | auto* __restrict result_raw_data = | 229 | 20 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 20 | ->get_data() | 231 | 20 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 680 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 660 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 660 | const auto* __restrict column_raw_data = | 252 | 660 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 660 | then_columns[i].get()) | 254 | 660 | ->get_data() | 255 | 660 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 660 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 660 | } | 280 | 20 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE26EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 654 | for (auto& then_ptr : then_columns) { | 224 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 654 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 654 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 654 | const auto* __restrict column_raw_data = | 252 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 654 | then_columns[i].get()) | 254 | 654 | ->get_data() | 255 | 654 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 654 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE43EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 654 | for (auto& then_ptr : then_columns) { | 224 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 654 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 654 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 654 | const auto* __restrict column_raw_data = | 252 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 654 | then_columns[i].get()) | 254 | 654 | ->get_data() | 255 | 654 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 654 | } | 280 | 18 | } |
_ZNK5doris9VCaseExpr23update_result_auto_simdIhNS_12ColumnVectorILNS_13PrimitiveTypeE42EEEEEvRNS_3COWINS_7IColumnEE11mutable_ptrIS6_EEPKT_RSt6vectorINS7_13immutable_ptrIS6_EESaISG_EEm Line | Count | Source | 222 | 18 | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 223 | 654 | for (auto& then_ptr : then_columns) { | 224 | 654 | then_ptr = then_ptr->convert_to_full_column_if_const(); | 225 | 654 | } | 226 | | | 227 | 18 | result_column_ptr->resize(rows_count); | 228 | 18 | auto* __restrict result_raw_data = | 229 | 18 | assert_cast<ColumnType*, TypeCheckOnRelease::DISABLE>(result_column_ptr.get()) | 230 | 18 | ->get_data() | 231 | 18 | .data(); | 232 | | | 233 | | // set default value | 234 | 24.7k | for (int i = 0; i < rows_count; i++) { | 235 | | if constexpr (std::is_same_v<ColumnType, ColumnDate> || | 236 | | std::is_same_v<ColumnType, ColumnDateTime> || | 237 | | std::is_same_v<ColumnType, ColumnDateV2> || | 238 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 239 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 240 | 24.7k | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 241 | 24.7k | result_raw_data[i] = ColumnType::default_value(); | 242 | | } else { | 243 | | result_raw_data[i] = {}; | 244 | | } | 245 | 24.7k | } | 246 | | | 247 | 672 | for (IndexType i = 0; i < then_columns.size(); i++) { | 248 | 654 | if (!then_columns[i]) { | 249 | 0 | continue; | 250 | 0 | } | 251 | 654 | const auto* __restrict column_raw_data = | 252 | 654 | assert_cast<const ColumnType*, TypeCheckOnRelease::DISABLE>( | 253 | 654 | then_columns[i].get()) | 254 | 654 | ->get_data() | 255 | 654 | .data(); | 256 | | if constexpr (std::is_same_v<ColumnType, ColumnFloat32> || | 257 | | std::is_same_v<ColumnType, ColumnFloat64> || | 258 | | std::is_same_v<ColumnType, ColumnDate> || | 259 | | std::is_same_v<ColumnType, ColumnDateTime> || | 260 | | std::is_same_v<ColumnType, ColumnDateV2> || | 261 | | std::is_same_v<ColumnType, ColumnDateTimeV2> || | 262 | | std::is_same_v<ColumnType, ColumnTimeStampNs> || | 263 | 654 | std::is_same_v<ColumnType, ColumnTimeStampTz>) { | 264 | | // Arithmetic masking propagates unselected NaN/Infinity and loses signed zero. | 265 | | // Conditional stores also let the compiler vectorize without loading from a | 266 | | // selected source/destination pointer, as a ternary assignment can do. | 267 | 2.24M | for (size_t row_idx = 0; row_idx < rows_count; row_idx++) { | 268 | 2.23M | if (then_idx[row_idx] == i) { | 269 | 24.7k | result_raw_data[row_idx] = column_raw_data[row_idx]; | 270 | 24.7k | } | 271 | 2.23M | } | 272 | | } else { | 273 | | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 274 | | result_raw_data[row_idx] += | 275 | | typename ColumnType::value_type(then_idx[row_idx] == i) * | 276 | | column_raw_data[row_idx]; | 277 | | } | 278 | | } | 279 | 654 | } | 280 | 18 | } |
|
281 | | |
282 | | template <typename IndexType> |
283 | | ColumnPtr _execute_impl(const std::vector<ColumnPtr>& when_columns, |
284 | 1.78k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { |
285 | 1.78k | std::vector<IndexType> then_idx(rows_count, 0); |
286 | 1.78k | IndexType* __restrict then_idx_ptr = then_idx.data(); |
287 | 3.85k | for (IndexType i = 0; i < when_columns.size(); i++) { |
288 | 2.10k | IndexType column_idx = i + 1; |
289 | 2.10k | auto [raw_when_column, is_consts] = unpack_if_const(when_columns[i]); |
290 | | |
291 | 2.10k | if (is_consts) { |
292 | 32 | if (raw_when_column->get_bool(0)) { |
293 | 997 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
294 | 965 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx]) * column_idx; |
295 | 965 | } |
296 | 32 | break; |
297 | 32 | } |
298 | 0 | continue; |
299 | 32 | } |
300 | | |
301 | 2.06k | if (is_column_nullable(*raw_when_column)) { |
302 | 1.97k | const auto* column_nullable_ptr = |
303 | 1.97k | assert_cast<const ColumnNullable*, TypeCheckOnRelease::DISABLE>( |
304 | 1.97k | raw_when_column.get()); |
305 | 1.97k | const auto* __restrict cond_raw_data = |
306 | 1.97k | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( |
307 | 1.97k | column_nullable_ptr->get_nested_column_ptr().get()) |
308 | 1.97k | ->get_data() |
309 | 1.97k | .data(); |
310 | 1.97k | if (!column_nullable_ptr->has_null()) { |
311 | 790k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
312 | 788k | then_idx_ptr[row_idx] |= |
313 | 788k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; |
314 | 788k | } |
315 | 1.92k | continue; |
316 | 1.92k | } |
317 | 55 | const auto* __restrict cond_raw_nullmap = |
318 | 55 | column_nullable_ptr->get_null_map_column_ptr()->get_data().data(); |
319 | 200k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
320 | 200k | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx] * cond_raw_data[row_idx] * |
321 | 200k | !cond_raw_nullmap[row_idx]) * |
322 | 200k | column_idx; |
323 | 200k | } |
324 | 93 | } else { |
325 | 93 | const auto* __restrict cond_raw_data = |
326 | 93 | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( |
327 | 93 | raw_when_column.get()) |
328 | 93 | ->get_data() |
329 | 93 | .data(); |
330 | 16.7k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { |
331 | 16.6k | then_idx_ptr[row_idx] |= |
332 | 16.6k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; |
333 | 16.6k | } |
334 | 93 | } |
335 | 2.06k | } |
336 | | |
337 | 1.78k | return _execute_update_result<IndexType>(then_idx_ptr, then_columns, rows_count); |
338 | 1.78k | } 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 | 284 | 1.78k | std::vector<ColumnPtr>& then_columns, size_t rows_count) const { | 285 | 1.78k | std::vector<IndexType> then_idx(rows_count, 0); | 286 | 1.78k | IndexType* __restrict then_idx_ptr = then_idx.data(); | 287 | 3.85k | for (IndexType i = 0; i < when_columns.size(); i++) { | 288 | 2.10k | IndexType column_idx = i + 1; | 289 | 2.10k | auto [raw_when_column, is_consts] = unpack_if_const(when_columns[i]); | 290 | | | 291 | 2.10k | if (is_consts) { | 292 | 32 | if (raw_when_column->get_bool(0)) { | 293 | 997 | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 294 | 965 | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx]) * column_idx; | 295 | 965 | } | 296 | 32 | break; | 297 | 32 | } | 298 | 0 | continue; | 299 | 32 | } | 300 | | | 301 | 2.06k | if (is_column_nullable(*raw_when_column)) { | 302 | 1.97k | const auto* column_nullable_ptr = | 303 | 1.97k | assert_cast<const ColumnNullable*, TypeCheckOnRelease::DISABLE>( | 304 | 1.97k | raw_when_column.get()); | 305 | 1.97k | const auto* __restrict cond_raw_data = | 306 | 1.97k | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( | 307 | 1.97k | column_nullable_ptr->get_nested_column_ptr().get()) | 308 | 1.97k | ->get_data() | 309 | 1.97k | .data(); | 310 | 1.97k | if (!column_nullable_ptr->has_null()) { | 311 | 790k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 312 | 788k | then_idx_ptr[row_idx] |= | 313 | 788k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; | 314 | 788k | } | 315 | 1.92k | continue; | 316 | 1.92k | } | 317 | 55 | const auto* __restrict cond_raw_nullmap = | 318 | 55 | column_nullable_ptr->get_null_map_column_ptr()->get_data().data(); | 319 | 200k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 320 | 200k | then_idx_ptr[row_idx] |= (!then_idx_ptr[row_idx] * cond_raw_data[row_idx] * | 321 | 200k | !cond_raw_nullmap[row_idx]) * | 322 | 200k | column_idx; | 323 | 200k | } | 324 | 93 | } else { | 325 | 93 | const auto* __restrict cond_raw_data = | 326 | 93 | assert_cast<const ColumnUInt8*, TypeCheckOnRelease::DISABLE>( | 327 | 93 | raw_when_column.get()) | 328 | 93 | ->get_data() | 329 | 93 | .data(); | 330 | 16.7k | for (int row_idx = 0; row_idx < rows_count; row_idx++) { | 331 | 16.6k | then_idx_ptr[row_idx] |= | 332 | 16.6k | (!then_idx_ptr[row_idx]) * cond_raw_data[row_idx] * column_idx; | 333 | 16.6k | } | 334 | 93 | } | 335 | 2.06k | } | 336 | | | 337 | 1.78k | return _execute_update_result<IndexType>(then_idx_ptr, then_columns, rows_count); | 338 | 1.78k | } |
|
339 | | |
340 | | bool _has_else_expr; |
341 | | |
342 | | inline static const std::string FUNCTION_NAME = "case"; |
343 | | inline static const std::string EXPR_NAME = "vcase expr"; |
344 | | }; |
345 | | } // namespace doris |