Coverage Report

Created: 2026-10-17 05:15

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