be/src/storage/field.h

Source
// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you under the Apache License, Version 2.0 (the
// "License"); you may not use this file except in compliance
// with the License.  You may obtain a copy of the License at
//
//   http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
// KIND, either express or implied.  See the License for the
// specific language governing permissions and limitations
// under the License.

#pragma once

#include <cstddef>
#include <sstream>
#include <string>

#include "core/arena.h"
#include "core/value/map_value.h"
#include "runtime/collection_value.h"
#include "storage/key_coder.h"
#include "storage/olap_common.h"
#include "storage/olap_define.h"
#include "storage/tablet/tablet_schema.h"
#include "storage/types.h"
#include "storage/utils.h"
#include "util/hash_util.hpp"
#include "util/json/path_in_data.h"
#include "util/slice.h"

namespace doris {
#include "common/compile_check_begin.h"
// A Field is used to represent a column in memory format.
// User can use this class to access or deal with column data in memory.
class StorageField {
public:
    StorageField(const TabletColumn& column)
            : _type_info(get_type_info(&column)),
              _desc(column),
              _length(column.length()),
              _key_coder(get_key_coder(column.type())),
              _name(column.name()),
              _index_size(column.index_length()),
              _is_nullable(column.is_nullable()),
              _unique_id(column.unique_id()),
              _parent_unique_id(column.parent_unique_id()),
              _is_extracted_column(column.is_extracted_column()),
              _path(column.path_info_ptr()) {}

    virtual ~StorageField() = default;

    size_t size() const { return _type_info->size(); }
    size_t length() const { return _length; }
    size_t field_size() const { return size() + 1; }
    size_t index_size() const { return _index_size; }
    int32_t unique_id() const { return _unique_id; }
    int32_t parent_unique_id() const { return _parent_unique_id; }
    bool is_extracted_column() const { return _is_extracted_column; }
    const std::string& name() const { return _name; }
    const PathInDataPtr& path() const { return _path; }

    virtual void set_to_max(char* buf) const { return _type_info->set_to_max(buf); }

    virtual void set_to_min(char* buf) const { return _type_info->set_to_min(buf); }

    virtual StorageField* clone() const {
        auto* local = new StorageField(_desc);
        this->clone(local);
        return local;
    }

    FieldType type() const { return _type_info->type(); }
    const TypeInfo* type_info() const { return _type_info.get(); }
    bool is_nullable() const { return _is_nullable; }

    // similar to `full_encode_ascending`, but only encode part (the first `index_size` bytes) of the value.
    // only applicable to string type
    void encode_ascending(const void* value, std::string* buf) const {
        _key_coder->encode_ascending(value, _index_size, buf);
    }

    // encode the provided `value` into `buf`.
    void full_encode_ascending(const void* value, std::string* buf) const {
        _key_coder->full_encode_ascending(value, buf);
    }
    void add_sub_field(std::unique_ptr<StorageField> sub_field) {
        _sub_fields.emplace_back(std::move(sub_field));
    }
    StorageField* get_sub_field(size_t i) const { return _sub_fields[i].get(); }
    size_t get_sub_field_count() const { return _sub_fields.size(); }

    void set_precision(int32_t precision) { _precision = precision; }
    void set_scale(int32_t scale) { _scale = scale; }
    int32_t get_precision() const { return _precision; }
    int32_t get_scale() const { return _scale; }
    const TabletColumn& get_desc() const { return _desc; }

    int32_t get_unique_id() const {
        return is_extracted_column() ? parent_unique_id() : unique_id();
    }

protected:
    TypeInfoPtr _type_info;
    TabletColumn _desc;
    // unit : byte
    // except for strings, other types have fixed lengths
    // Note that, the struct type itself has fixed length, but due to
    // its number of subfields is a variable, so the actual length of
    // a struct field is not fixed.
    size_t _length;

    void clone(StorageField* other) const {
        other->_type_info = clone_type_info(this->_type_info.get());
        other->_key_coder = this->_key_coder;
        other->_name = this->_name;
        other->_index_size = this->_index_size;
        other->_is_nullable = this->_is_nullable;
        other->_sub_fields.clear();
        other->_precision = this->_precision;
        other->_scale = this->_scale;
        other->_unique_id = this->_unique_id;
        other->_parent_unique_id = this->_parent_unique_id;
        other->_is_extracted_column = this->_is_extracted_column;
        for (const auto& f : _sub_fields) {
            StorageField* item = f->clone();
            other->add_sub_field(std::unique_ptr<StorageField>(item));
        }
    }

private:
    // maximum length of Field, unit : bytes
    // usually equal to length, except for variable-length strings
    const KeyCoder* _key_coder;
    std::string _name;
    size_t _index_size;
    bool _is_nullable;
    std::vector<std::unique_ptr<StorageField>> _sub_fields;
    int32_t _precision;
    int32_t _scale;
    int32_t _unique_id;
    int32_t _parent_unique_id;
    bool _is_extracted_column = false;
    PathInDataPtr _path;
};

class MapField : public StorageField {
public:
    MapField(const TabletColumn& column) : StorageField(column) {}
};

class StructField : public StorageField {
public:
    StructField(const TabletColumn& column) : StorageField(column) {}
};

class ArrayField : public StorageField {
public:
    ArrayField(const TabletColumn& column) : StorageField(column) {}
};

class CharField : public StorageField {
public:
    CharField(const TabletColumn& column) : StorageField(column) {}

    CharField* clone() const override {
        auto* local = new CharField(_desc);
        StorageField::clone(local);
        return local;
    }

    void set_to_max(char* ch) const override {
        auto slice = reinterpret_cast<Slice*>(ch);
        slice->size = _length;
        memset(slice->data, 0xFF, slice->size);
    }
};

class VarcharField : public StorageField {
public:
    VarcharField(const TabletColumn& column) : StorageField(column) {}

    VarcharField* clone() const override {
        auto* local = new VarcharField(_desc);
        StorageField::clone(local);
        return local;
    }

    void set_to_max(char* ch) const override {
        auto slice = reinterpret_cast<Slice*>(ch);
        slice->size = _length - OLAP_VARCHAR_MAX_BYTES;
        memset(slice->data, 0xFF, slice->size);
    }
};
class StringField : public StorageField {
public:
    StringField(const TabletColumn& column) : StorageField(column) {}

    StringField* clone() const override {
        auto* local = new StringField(_desc);
        StorageField::clone(local);
        return local;
    }

    void set_to_max(char* ch) const override {
        auto slice = reinterpret_cast<Slice*>(ch);
        memset(slice->data, 0xFF, slice->size);
    }
};

class BitmapAggField : public StorageField {
public:
    BitmapAggField(const TabletColumn& column) : StorageField(column) {}

    BitmapAggField* clone() const override {
        auto* local = new BitmapAggField(_desc);
        StorageField::clone(local);
        return local;
    }
};

class QuantileStateAggField : public StorageField {
public:
    QuantileStateAggField(const TabletColumn& column) : StorageField(column) {}

    QuantileStateAggField* clone() const override {
        auto* local = new QuantileStateAggField(_desc);
        StorageField::clone(local);
        return local;
    }
};

class AggStateField : public StorageField {
public:
    AggStateField(const TabletColumn& column) : StorageField(column) {}

    AggStateField* clone() const override {
        auto* local = new AggStateField(_desc);
        StorageField::clone(local);
        return local;
    }
};

class HllAggField : public StorageField {
public:
    HllAggField(const TabletColumn& column) : StorageField(column) {}

    HllAggField* clone() const override {
        auto* local = new HllAggField(_desc);
        StorageField::clone(local);
        return local;
    }
};

class StorageFieldFactory {
public:
    static StorageField* create(const TabletColumn& column) {
        // for key column
        if (column.is_key()) {
            switch (column.type()) {
            case FieldType::OLAP_FIELD_TYPE_CHAR:
                return new CharField(column);
            case FieldType::OLAP_FIELD_TYPE_VARCHAR:
            case FieldType::OLAP_FIELD_TYPE_STRING:
                return new StringField(column);
            case FieldType::OLAP_FIELD_TYPE_STRUCT: {
                auto* local = new StructField(column);
                for (uint32_t i = 0; i < column.get_subtype_count(); i++) {
                    std::unique_ptr<StorageField> sub_field(
                            StorageFieldFactory::create(column.get_sub_column(i)));
                    local->add_sub_field(std::move(sub_field));
                }
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_ARRAY: {
                std::unique_ptr<StorageField> item_field(
                        StorageFieldFactory::create(column.get_sub_column(0)));
                auto* local = new ArrayField(column);
                local->add_sub_field(std::move(item_field));
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_MAP: {
                std::unique_ptr<StorageField> key_field(
                        StorageFieldFactory::create(column.get_sub_column(0)));
                std::unique_ptr<StorageField> val_field(
                        StorageFieldFactory::create(column.get_sub_column(1)));
                auto* local = new MapField(column);
                local->add_sub_field(std::move(key_field));
                local->add_sub_field(std::move(val_field));
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_DECIMAL:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL32:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL64:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL128I:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL256:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_TIMESTAMPTZ:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DATETIMEV2: {
                StorageField* field = new StorageField(column);
                field->set_precision(column.precision());
                field->set_scale(column.frac());
                return field;
            }
            default:
                return new StorageField(column);
            }
        }

        // for value column
        switch (column.aggregation()) {
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_NONE:
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_SUM:
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_MIN:
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_MAX:
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_REPLACE:
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_REPLACE_IF_NOT_NULL:
            switch (column.type()) {
            case FieldType::OLAP_FIELD_TYPE_CHAR:
                return new CharField(column);
            case FieldType::OLAP_FIELD_TYPE_VARCHAR:
                return new VarcharField(column);
            case FieldType::OLAP_FIELD_TYPE_STRING:
                return new StringField(column);
            case FieldType::OLAP_FIELD_TYPE_STRUCT: {
                auto* local = new StructField(column);
                for (uint32_t i = 0; i < column.get_subtype_count(); i++) {
                    std::unique_ptr<StorageField> sub_field(
                            StorageFieldFactory::create(column.get_sub_column(i)));
                    local->add_sub_field(std::move(sub_field));
                }
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_ARRAY: {
                std::unique_ptr<StorageField> item_field(
                        StorageFieldFactory::create(column.get_sub_column(0)));
                auto* local = new ArrayField(column);
                local->add_sub_field(std::move(item_field));
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_MAP: {
                DCHECK(column.get_subtype_count() == 2);
                auto* local = new MapField(column);
                std::unique_ptr<StorageField> key_field(
                        StorageFieldFactory::create(column.get_sub_column(0)));
                std::unique_ptr<StorageField> value_field(
                        StorageFieldFactory::create(column.get_sub_column(1)));
                local->add_sub_field(std::move(key_field));
                local->add_sub_field(std::move(value_field));
                return local;
            }
            case FieldType::OLAP_FIELD_TYPE_DECIMAL:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL32:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL64:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL128I:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DECIMAL256:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_TIMESTAMPTZ:
                [[fallthrough]];
            case FieldType::OLAP_FIELD_TYPE_DATETIMEV2: {
                StorageField* field = new StorageField(column);
                field->set_precision(column.precision());
                field->set_scale(column.frac());
                return field;
            }
            default:
                return new StorageField(column);
            }
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_HLL_UNION:
            return new HllAggField(column);
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_BITMAP_UNION:
            return new BitmapAggField(column);
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_QUANTILE_UNION:
            return new QuantileStateAggField(column);
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_GENERIC:
            return new AggStateField(column);
        case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_UNKNOWN:
            CHECK(false) << ", value column no agg type";
            return nullptr;
        }
        return nullptr;
    }

    static StorageField* create_by_type(const FieldType& type) {
        TabletColumn column(FieldAggregationMethod::OLAP_FIELD_AGGREGATION_NONE, type);
        return create(column);
    }
};
#include "common/compile_check_end.h"
} // namespace doris

Coverage Report

Created: 2026-03-27 21:20

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 <cstddef>
21		#include <sstream>
22		#include <string>
23
24		#include "core/arena.h"
25		#include "core/value/map_value.h"
26		#include "runtime/collection_value.h"
27		#include "storage/key_coder.h"
28		#include "storage/olap_common.h"
29		#include "storage/olap_define.h"
30		#include "storage/tablet/tablet_schema.h"
31		#include "storage/types.h"
32		#include "storage/utils.h"
33		#include "util/hash_util.hpp"
34		#include "util/json/path_in_data.h"
35		#include "util/slice.h"
36
37		namespace doris {
38		#include "common/compile_check_begin.h"
39		// A Field is used to represent a column in memory format.
40		// User can use this class to access or deal with column data in memory.
41		class StorageField {
42		public:
43		StorageField(const TabletColumn& column)
44	106M	: _type_info(get_type_info(&column)),
45	106M	_desc(column),
46	106M	_length(column.length()),
47	106M	_key_coder(get_key_coder(column.type())),
48	106M	_name(column.name()),
49	106M	_index_size(column.index_length()),
50	106M	_is_nullable(column.is_nullable()),
51	106M	_unique_id(column.unique_id()),
52	106M	_parent_unique_id(column.parent_unique_id()),
53	106M	_is_extracted_column(column.is_extracted_column()),
54	106M	_path(column.path_info_ptr()) {}
55
56	111M	virtual ~StorageField() = default;
57
58	5.50M	size_t size() const { return _type_info->size(); }
59	1.22k	size_t length() const { return _length; }
60	0	size_t field_size() const { return size() + 1; }
61	0	size_t index_size() const { return _index_size; }
62	56.7M	int32_t unique_id() const { return _unique_id; }
63	59.0k	int32_t parent_unique_id() const { return _parent_unique_id; }
64	55.0M	bool is_extracted_column() const { return _is_extracted_column; }
65	84.5M	const std::string& name() const { return _name; }
66	0	const PathInDataPtr& path() const { return _path; }
67
68	0	virtual void set_to_max(char* buf) const { return _type_info->set_to_max(buf); }
69
70	2	virtual void set_to_min(char* buf) const { return _type_info->set_to_min(buf); }
71
72	3.25M	virtual StorageField* clone() const {
73	3.25M	auto* local = new StorageField(_desc);
74	3.25M	this->clone(local);
75	3.25M	return local;
76	3.25M	}
77
78	77.2M	FieldType type() const { return _type_info->type(); }
79	45.9k	const TypeInfo* type_info() const { return _type_info.get(); }
80	62.9M	bool is_nullable() const { return _is_nullable; }
81
82		// similar to `full_encode_ascending`, but only encode part (the first `index_size` bytes) of the value.
83		// only applicable to string type
84	720k	void encode_ascending(const void* value, std::string* buf) const {
85	720k	_key_coder->encode_ascending(value, _index_size, buf);
86	720k	}
87
88		// encode the provided `value` into `buf`.
89	12.5M	void full_encode_ascending(const void* value, std::string* buf) const {
90	12.5M	_key_coder->full_encode_ascending(value, buf);
91	12.5M	}
92	803k	void add_sub_field(std::unique_ptr<StorageField> sub_field) {
93	803k	_sub_fields.emplace_back(std::move(sub_field));
94	803k	}
95	140k	StorageField* get_sub_field(size_t i) const { return _sub_fields[i].get(); }
96	44.7k	size_t get_sub_field_count() const { return _sub_fields.size(); }
97
98	6.70M	void set_precision(int32_t precision) { _precision = precision; }
99	6.70M	void set_scale(int32_t scale) { _scale = scale; }
100	0	int32_t get_precision() const { return _precision; }
101	25.0M	int32_t get_scale() const { return _scale; }
102	100M	const TabletColumn& get_desc() const { return _desc; }
103
104	27.5M	int32_t get_unique_id() const {
105	27.5M	return is_extracted_column() ? parent_unique_id() : unique_id();
106	27.5M	}
107
108		protected:
109		TypeInfoPtr _type_info;
110		TabletColumn _desc;
111		// unit : byte
112		// except for strings, other types have fixed lengths
113		// Note that, the struct type itself has fixed length, but due to
114		// its number of subfields is a variable, so the actual length of
115		// a struct field is not fixed.
116		size_t _length;
117
118	8.68M	void clone(StorageField* other) const {
119	8.68M	other->_type_info = clone_type_info(this->_type_info.get());
120	8.68M	other->_key_coder = this->_key_coder;
121	8.68M	other->_name = this->_name;
122	8.68M	other->_index_size = this->_index_size;
123	8.68M	other->_is_nullable = this->_is_nullable;
124	8.68M	other->_sub_fields.clear();
125	8.68M	other->_precision = this->_precision;
126	8.68M	other->_scale = this->_scale;
127	8.68M	other->_unique_id = this->_unique_id;
128	8.68M	other->_parent_unique_id = this->_parent_unique_id;
129	8.68M	other->_is_extracted_column = this->_is_extracted_column;
130	8.68M	for (const auto& f : _sub_fields) {
131	0	StorageField* item = f->clone();
132	0	other->add_sub_field(std::unique_ptr<StorageField>(item));
133	0	}
134	8.68M	}
135
136		private:
137		// maximum length of Field, unit : bytes
138		// usually equal to length, except for variable-length strings
139		const KeyCoder* _key_coder;
140		std::string _name;
141		size_t _index_size;
142		bool _is_nullable;
143		std::vector<std::unique_ptr<StorageField>> _sub_fields;
144		int32_t _precision;
145		int32_t _scale;
146		int32_t _unique_id;
147		int32_t _parent_unique_id;
148		bool _is_extracted_column = false;
149		PathInDataPtr _path;
150		};
151
152		class MapField : public StorageField {
153		public:
154	110k	MapField(const TabletColumn& column) : StorageField(column) {}
155		};
156
157		class StructField : public StorageField {
158		public:
159	56.4k	StructField(const TabletColumn& column) : StorageField(column) {}
160		};
161
162		class ArrayField : public StorageField {
163		public:
164	393k	ArrayField(const TabletColumn& column) : StorageField(column) {}
165		};
166
167		class CharField : public StorageField {
168		public:
169	262k	CharField(const TabletColumn& column) : StorageField(column) {}
170
171	1.90k	CharField* clone() const override {
172	1.90k	auto* local = new CharField(_desc);
173	1.90k	StorageField::clone(local);
174	1.90k	return local;
175	1.90k	}
176
177	0	void set_to_max(char* ch) const override {
178	0	auto slice = reinterpret_cast<Slice*>(ch);
179	0	slice->size = _length;
180	0	memset(slice->data, 0xFF, slice->size);
181	0	}
182		};
183
184		class VarcharField : public StorageField {
185		public:
186	10.9M	VarcharField(const TabletColumn& column) : StorageField(column) {}
187
188	0	VarcharField* clone() const override {
189	0	auto* local = new VarcharField(_desc);
190	0	StorageField::clone(local);
191	0	return local;
192	0	}
193
194	2	void set_to_max(char* ch) const override {
195	2	auto slice = reinterpret_cast<Slice*>(ch);
196	2	slice->size = _length - OLAP_VARCHAR_MAX_BYTES;
197	2	memset(slice->data, 0xFF, slice->size);
198	2	}
199		};
200		class StringField : public StorageField {
201		public:
202	55.7M	StringField(const TabletColumn& column) : StorageField(column) {}
203
204	5.42M	StringField* clone() const override {
205	5.42M	auto* local = new StringField(_desc);
206	5.42M	StorageField::clone(local);
207	5.42M	return local;
208	5.42M	}
209
210	0	void set_to_max(char* ch) const override {
211	0	auto slice = reinterpret_cast<Slice*>(ch);
212	0	memset(slice->data, 0xFF, slice->size);
213	0	}
214		};
215
216		class BitmapAggField : public StorageField {
217		public:
218	26.0k	BitmapAggField(const TabletColumn& column) : StorageField(column) {}
219
220	0	BitmapAggField* clone() const override {
221	0	auto* local = new BitmapAggField(_desc);
222	0	StorageField::clone(local);
223	0	return local;
224	0	}
225		};
226
227		class QuantileStateAggField : public StorageField {
228		public:
229	10.7k	QuantileStateAggField(const TabletColumn& column) : StorageField(column) {}
230
231	0	QuantileStateAggField* clone() const override {
232	0	auto* local = new QuantileStateAggField(_desc);
233	0	StorageField::clone(local);
234	0	return local;
235	0	}
236		};
237
238		class AggStateField : public StorageField {
239		public:
240	6.54k	AggStateField(const TabletColumn& column) : StorageField(column) {}
241
242	0	AggStateField* clone() const override {
243	0	auto* local = new AggStateField(_desc);
244	0	StorageField::clone(local);
245	0	return local;
246	0	}
247		};
248
249		class HllAggField : public StorageField {
250		public:
251	15.9k	HllAggField(const TabletColumn& column) : StorageField(column) {}
252
253	0	HllAggField* clone() const override {
254	0	auto* local = new HllAggField(_desc);
255	0	StorageField::clone(local);
256	0	return local;
257	0	}
258		};
259
260		class StorageFieldFactory {
261		public:
262	103M	static StorageField* create(const TabletColumn& column) {
263		// for key column
264	103M	if (column.is_key()) {
265	49.7M	switch (column.type()) {
266	42.2k	case FieldType::OLAP_FIELD_TYPE_CHAR:
267	42.2k	return new CharField(column);
268	46.2M	case FieldType::OLAP_FIELD_TYPE_VARCHAR:
269	46.2M	case FieldType::OLAP_FIELD_TYPE_STRING:
270	46.2M	return new StringField(column);
271	0	case FieldType::OLAP_FIELD_TYPE_STRUCT: {
272	0	auto* local = new StructField(column);
273	0	for (uint32_t i = 0; i < column.get_subtype_count(); i++) {
274	0	std::unique_ptr<StorageField> sub_field(
275	0	StorageFieldFactory::create(column.get_sub_column(i)));
276	0	local->add_sub_field(std::move(sub_field));
277	0	}
278	0	return local;
279	46.2M	}
280	0	case FieldType::OLAP_FIELD_TYPE_ARRAY: {
281	0	std::unique_ptr<StorageField> item_field(
282	0	StorageFieldFactory::create(column.get_sub_column(0)));
283	0	auto* local = new ArrayField(column);
284	0	local->add_sub_field(std::move(item_field));
285	0	return local;
286	46.2M	}
287	0	case FieldType::OLAP_FIELD_TYPE_MAP: {
288	0	std::unique_ptr<StorageField> key_field(
289	0	StorageFieldFactory::create(column.get_sub_column(0)));
290	0	std::unique_ptr<StorageField> val_field(
291	0	StorageFieldFactory::create(column.get_sub_column(1)));
292	0	auto* local = new MapField(column);
293	0	local->add_sub_field(std::move(key_field));
294	0	local->add_sub_field(std::move(val_field));
295	0	return local;
296	46.2M	}
297	718	case FieldType::OLAP_FIELD_TYPE_DECIMAL:
298	718	[[fallthrough]];
299	41.5k	case FieldType::OLAP_FIELD_TYPE_DECIMAL32:
300	41.5k	[[fallthrough]];
301	51.3k	case FieldType::OLAP_FIELD_TYPE_DECIMAL64:
302	51.3k	[[fallthrough]];
303	97.4k	case FieldType::OLAP_FIELD_TYPE_DECIMAL128I:
304	97.4k	[[fallthrough]];
305	102k	case FieldType::OLAP_FIELD_TYPE_DECIMAL256:
306	102k	[[fallthrough]];
307	175k	case FieldType::OLAP_FIELD_TYPE_TIMESTAMPTZ:
308	175k	[[fallthrough]];
309	307k	case FieldType::OLAP_FIELD_TYPE_DATETIMEV2: {
310	307k	StorageField* field = new StorageField(column);
311	307k	field->set_precision(column.precision());
312	307k	field->set_scale(column.frac());
313	307k	return field;
314	175k	}
315	3.15M	default:
316	3.15M	return new StorageField(column);
317	49.7M	}
318	49.7M	}
319
320		// for value column
321	53.9M	switch (column.aggregation()) {
322	52.9M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_NONE:
323	53.2M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_SUM:
324	53.2M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_MIN:
325	53.3M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_MAX:
326	53.7M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_REPLACE:
327	53.8M	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_REPLACE_IF_NOT_NULL:
328	53.8M	switch (column.type()) {
329	219k	case FieldType::OLAP_FIELD_TYPE_CHAR:
330	219k	return new CharField(column);
331	11.0M	case FieldType::OLAP_FIELD_TYPE_VARCHAR:
332	11.0M	return new VarcharField(column);
333	5.86M	case FieldType::OLAP_FIELD_TYPE_STRING:
334	5.86M	return new StringField(column);
335	57.0k	case FieldType::OLAP_FIELD_TYPE_STRUCT: {
336	57.0k	auto* local = new StructField(column);
337	239k	for (uint32_t i = 0; i < column.get_subtype_count(); i++) {
338	182k	std::unique_ptr<StorageField> sub_field(
339	182k	StorageFieldFactory::create(column.get_sub_column(i)));
340	182k	local->add_sub_field(std::move(sub_field));
341	182k	}
342	57.0k	return local;
343	0	}
344	398k	case FieldType::OLAP_FIELD_TYPE_ARRAY: {
345	398k	std::unique_ptr<StorageField> item_field(
346	398k	StorageFieldFactory::create(column.get_sub_column(0)));
347	398k	auto* local = new ArrayField(column);
348	398k	local->add_sub_field(std::move(item_field));
349	398k	return local;
350	0	}
351	111k	case FieldType::OLAP_FIELD_TYPE_MAP: {
352	111k	DCHECK(column.get_subtype_count() == 2);
353	111k	auto* local = new MapField(column);
354	111k	std::unique_ptr<StorageField> key_field(
355	111k	StorageFieldFactory::create(column.get_sub_column(0)));
356	111k	std::unique_ptr<StorageField> value_field(
357	111k	StorageFieldFactory::create(column.get_sub_column(1)));
358	111k	local->add_sub_field(std::move(key_field));
359	111k	local->add_sub_field(std::move(value_field));
360	111k	return local;
361	0	}
362	6.17k	case FieldType::OLAP_FIELD_TYPE_DECIMAL:
363	6.17k	[[fallthrough]];
364	88.2k	case FieldType::OLAP_FIELD_TYPE_DECIMAL32:
365	88.2k	[[fallthrough]];
366	394k	case FieldType::OLAP_FIELD_TYPE_DECIMAL64:
367	394k	[[fallthrough]];
368	618k	case FieldType::OLAP_FIELD_TYPE_DECIMAL128I:
369	618k	[[fallthrough]];
370	628k	case FieldType::OLAP_FIELD_TYPE_DECIMAL256:
371	628k	[[fallthrough]];
372	768k	case FieldType::OLAP_FIELD_TYPE_TIMESTAMPTZ:
373	768k	[[fallthrough]];
374	6.39M	case FieldType::OLAP_FIELD_TYPE_DATETIMEV2: {
375	6.39M	StorageField* field = new StorageField(column);
376	6.39M	field->set_precision(column.precision());
377	6.39M	field->set_scale(column.frac());
378	6.39M	return field;
379	768k	}
380	29.9M	default:
381	29.9M	return new StorageField(column);
382	53.8M	}
383	16.0k	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_HLL_UNION:
384	16.0k	return new HllAggField(column);
385	26.1k	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_BITMAP_UNION:
386	26.1k	return new BitmapAggField(column);
387	10.7k	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_QUANTILE_UNION:
388	10.7k	return new QuantileStateAggField(column);
389	6.57k	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_GENERIC:
390	6.57k	return new AggStateField(column);
391	0	case FieldAggregationMethod::OLAP_FIELD_AGGREGATION_UNKNOWN:
392	0	CHECK(false) << ", value column no agg type";
393	0	return nullptr;
394	53.9M	}
395	0	return nullptr;
396	53.9M	}
397
398		static StorageField* create_by_type(const FieldType& type) {
399		TabletColumn column(FieldAggregationMethod::OLAP_FIELD_AGGREGATION_NONE, type);
400		return create(column);
401		}
402		};
403		#include "common/compile_check_end.h"
404		} // namespace doris