Coverage Report

Created: 2026-06-04 13:02

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
be/src/cloud/pb_convert.cpp
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
#include "cloud/pb_convert.h"
19
20
#include <gen_cpp/olap_file.pb.h>
21
22
#include <utility>
23
24
#include "common/logging.h"
25
26
namespace doris::cloud {
27
28
0
RowsetMetaCloudPB doris_rowset_meta_to_cloud(const RowsetMetaPB& in) {
29
0
    RowsetMetaCloudPB out;
30
0
    doris_rowset_meta_to_cloud(&out, in);
31
0
    return out;
32
0
}
33
34
60.8k
RowsetMetaCloudPB doris_rowset_meta_to_cloud(RowsetMetaPB&& in) {
35
60.8k
    RowsetMetaCloudPB out;
36
60.8k
    doris_rowset_meta_to_cloud(&out, std::move(in));
37
60.8k
    return out;
38
60.8k
}
39
40
5
void doris_rowset_meta_to_cloud(RowsetMetaCloudPB* out, const RowsetMetaPB& in) {
41
    // ATTN: please keep the set order aligned with the definition of proto `TabletSchemaCloudPB`.
42
5
    out->set_rowset_id(in.rowset_id());
43
5
    out->set_partition_id(in.partition_id());
44
5
    out->set_tablet_id(in.tablet_id());
45
5
    out->set_txn_id(in.txn_id());
46
5
    out->set_tablet_schema_hash(in.tablet_schema_hash());
47
5
    out->set_rowset_type(in.rowset_type());
48
5
    out->set_rowset_state(in.rowset_state());
49
5
    out->set_start_version(in.start_version());
50
5
    out->set_end_version(in.end_version());
51
5
    out->set_version_hash(in.version_hash());
52
5
    out->set_num_rows(in.num_rows());
53
5
    out->set_total_disk_size(in.total_disk_size());
54
5
    out->set_data_disk_size(in.data_disk_size());
55
5
    out->set_index_disk_size(in.index_disk_size());
56
5
    out->mutable_zone_maps()->CopyFrom(in.zone_maps());
57
5
    if (in.has_delete_predicate()) {
58
1
        out->mutable_delete_predicate()->CopyFrom(in.delete_predicate());
59
1
    }
60
5
    out->set_empty(in.empty());
61
5
    if (in.has_load_id()) {
62
1
        out->mutable_load_id()->CopyFrom(in.load_id());
63
1
    }
64
5
    out->set_delete_flag(in.delete_flag());
65
5
    out->set_creation_time(in.creation_time());
66
5
    if (in.has_tablet_uid()) {
67
1
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
68
1
    }
69
5
    out->set_num_segments(in.num_segments());
70
5
    out->set_rowset_id_v2(in.rowset_id_v2());
71
5
    out->set_resource_id(in.resource_id());
72
5
    out->set_newest_write_timestamp(in.newest_write_timestamp());
73
5
    out->mutable_segments_key_bounds()->CopyFrom(in.segments_key_bounds());
74
5
    if (in.has_tablet_schema()) {
75
1
        doris_tablet_schema_to_cloud(out->mutable_tablet_schema(), in.tablet_schema());
76
1
    }
77
5
    if (in.has_schema_dict_key_list()) {
78
1
        out->mutable_schema_dict_key_list()->CopyFrom(in.schema_dict_key_list());
79
1
    }
80
5
    out->set_txn_expiration(in.txn_expiration());
81
5
    out->set_segments_overlap_pb(in.segments_overlap_pb());
82
5
    if (in.has_segments_key_bounds_truncated()) {
83
1
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
84
1
    }
85
5
    if (in.has_segments_key_bounds_aggregated()) {
86
1
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
87
1
    }
88
5
    out->mutable_num_segment_rows()->CopyFrom(in.num_segment_rows());
89
5
    out->mutable_segments_file_size()->CopyFrom(in.segments_file_size());
90
5
    out->set_index_id(in.index_id());
91
5
    if (in.has_schema_version()) {
92
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
93
1
        out->set_schema_version(in.schema_version());
94
1
    }
95
5
    out->set_enable_segments_file_size(in.enable_segments_file_size());
96
5
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
97
5
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
98
5
    out->set_compaction_level(in.compaction_level());
99
5
    out->mutable_inverted_index_file_info()->CopyFrom(in.inverted_index_file_info());
100
5
    out->set_source_rowset_id(in.source_rowset_id());
101
5
    out->set_source_tablet_id(in.source_tablet_id());
102
5
    if (in.has___split_schema()) {
103
1
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
104
1
    }
105
5
    if (in.has_visible_ts_ms()) {
106
1
        out->set_visible_ts_ms(in.visible_ts_ms());
107
1
    }
108
5
    if (in.has_reference_instance_id()) {
109
1
        out->set_reference_instance_id(in.reference_instance_id());
110
1
    }
111
5
    auto* slice_locations = out->mutable_packed_slice_locations();
112
5
    slice_locations->clear();
113
5
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
114
5
    if (in.has_is_recycled()) {
115
1
        out->set_is_recycled(in.is_recycled());
116
1
    }
117
5
    if (in.has_job_id()) {
118
1
        out->set_job_id(in.job_id());
119
1
    }
120
5
    if (in.has_commit_tso()) {
121
1
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
122
1
    }
123
5
    if (in.has_is_row_binlog()) {
124
1
        out->set_is_row_binlog(in.is_row_binlog());
125
1
    }
126
5
    if (in.has_db_id()) {
127
1
        out->set_db_id(in.db_id());
128
1
    }
129
5
    if (in.has_table_id()) {
130
1
        out->set_table_id(in.table_id());
131
1
    }
132
5
}
133
134
207k
void doris_rowset_meta_to_cloud(RowsetMetaCloudPB* out, RowsetMetaPB&& in) {
135
    // ATTN: please keep the set order aligned with the definition of proto `TabletSchemaCloudPB`.
136
207k
    out->set_rowset_id(in.rowset_id());
137
207k
    out->set_partition_id(in.partition_id());
138
207k
    out->set_tablet_id(in.tablet_id());
139
207k
    out->set_txn_id(in.txn_id());
140
207k
    out->set_tablet_schema_hash(in.tablet_schema_hash());
141
207k
    out->set_rowset_type(in.rowset_type());
142
207k
    out->set_rowset_state(in.rowset_state());
143
207k
    out->set_start_version(in.start_version());
144
207k
    out->set_end_version(in.end_version());
145
207k
    out->set_version_hash(in.version_hash());
146
207k
    out->set_num_rows(in.num_rows());
147
207k
    out->set_total_disk_size(in.total_disk_size());
148
207k
    out->set_data_disk_size(in.data_disk_size());
149
207k
    out->set_index_disk_size(in.index_disk_size());
150
207k
    out->mutable_zone_maps()->Swap(in.mutable_zone_maps());
151
207k
    if (in.has_delete_predicate()) {
152
6.50k
        out->mutable_delete_predicate()->Swap(in.mutable_delete_predicate());
153
6.50k
    }
154
207k
    out->set_empty(in.empty());
155
207k
    if (in.has_load_id()) {
156
164k
        out->mutable_load_id()->CopyFrom(in.load_id());
157
164k
    }
158
207k
    out->set_delete_flag(in.delete_flag());
159
207k
    out->set_creation_time(in.creation_time());
160
207k
    if (in.has_tablet_uid()) {
161
32.2k
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
162
32.2k
    }
163
207k
    out->set_num_segments(in.num_segments());
164
207k
    out->set_rowset_id_v2(in.rowset_id_v2());
165
207k
    out->set_resource_id(in.resource_id());
166
207k
    out->set_newest_write_timestamp(in.newest_write_timestamp());
167
207k
    out->mutable_segments_key_bounds()->Swap(in.mutable_segments_key_bounds());
168
207k
    if (in.has_tablet_schema()) {
169
72.6k
        doris_tablet_schema_to_cloud(out->mutable_tablet_schema(),
170
72.6k
                                     std::move(*in.mutable_tablet_schema()));
171
72.6k
    }
172
207k
    if (in.has_schema_dict_key_list()) {
173
47
        out->mutable_schema_dict_key_list()->Swap(in.mutable_schema_dict_key_list());
174
47
    }
175
207k
    out->set_txn_expiration(in.txn_expiration());
176
207k
    out->set_segments_overlap_pb(in.segments_overlap_pb());
177
207k
    if (in.has_segments_key_bounds_truncated()) {
178
103k
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
179
103k
    }
180
207k
    if (in.has_segments_key_bounds_aggregated()) {
181
103k
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
182
103k
    }
183
207k
    out->mutable_num_segment_rows()->Swap(in.mutable_num_segment_rows());
184
207k
    out->mutable_segments_file_size()->Swap(in.mutable_segments_file_size());
185
207k
    out->set_index_id(in.index_id());
186
207k
    if (in.has_schema_version()) {
187
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
188
205k
        out->set_schema_version(in.schema_version());
189
205k
    }
190
207k
    out->set_enable_segments_file_size(in.enable_segments_file_size());
191
207k
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
192
207k
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
193
207k
    out->set_compaction_level(in.compaction_level());
194
207k
    out->mutable_inverted_index_file_info()->Swap(in.mutable_inverted_index_file_info());
195
207k
    out->set_source_rowset_id(in.source_rowset_id());
196
207k
    out->set_source_tablet_id(in.source_tablet_id());
197
198
207k
    if (in.has___split_schema()) {
199
2
        out->mutable___split_schema()->Swap(in.mutable___split_schema());
200
2
    }
201
207k
    if (in.has_visible_ts_ms()) {
202
36.9k
        out->set_visible_ts_ms(in.visible_ts_ms());
203
36.9k
    }
204
207k
    if (in.has_reference_instance_id()) {
205
2
        out->set_reference_instance_id(in.reference_instance_id());
206
2
    }
207
207k
    auto* slice_locations = out->mutable_packed_slice_locations();
208
207k
    slice_locations->clear();
209
207k
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
210
207k
    if (in.has_is_recycled()) {
211
2
        out->set_is_recycled(in.is_recycled());
212
2
    }
213
207k
    if (in.has_job_id()) {
214
173k
        out->set_job_id(in.job_id());
215
173k
    }
216
207k
    if (in.has_commit_tso()) {
217
11.5k
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
218
11.5k
    }
219
207k
    if (in.has_is_row_binlog()) {
220
2
        out->set_is_row_binlog(in.is_row_binlog());
221
2
    }
222
207k
    if (in.has_db_id()) {
223
173k
        out->set_db_id(in.db_id());
224
173k
    }
225
207k
    if (in.has_table_id()) {
226
173k
        out->set_table_id(in.table_id());
227
173k
    }
228
207k
}
229
230
120k
RowsetMetaPB cloud_rowset_meta_to_doris(const RowsetMetaCloudPB& in) {
231
120k
    RowsetMetaPB out;
232
120k
    cloud_rowset_meta_to_doris(&out, in);
233
120k
    return out;
234
120k
}
235
236
2
RowsetMetaPB cloud_rowset_meta_to_doris(RowsetMetaCloudPB&& in) {
237
2
    RowsetMetaPB out;
238
2
    cloud_rowset_meta_to_doris(&out, std::move(in));
239
2
    return out;
240
2
}
241
242
121k
void cloud_rowset_meta_to_doris(RowsetMetaPB* out, const RowsetMetaCloudPB& in) {
243
    // ATTN: please keep the set order aligned with the definition of proto `TabletSchemaCloudPB`.
244
121k
    out->set_rowset_id(in.rowset_id());
245
121k
    out->set_partition_id(in.partition_id());
246
121k
    out->set_tablet_id(in.tablet_id());
247
121k
    out->set_txn_id(in.txn_id());
248
121k
    out->set_tablet_schema_hash(in.tablet_schema_hash());
249
121k
    out->set_rowset_type(in.rowset_type());
250
121k
    out->set_rowset_state(in.rowset_state());
251
121k
    out->set_start_version(in.start_version());
252
121k
    out->set_end_version(in.end_version());
253
121k
    out->set_version_hash(in.version_hash());
254
121k
    out->set_num_rows(in.num_rows());
255
121k
    out->set_total_disk_size(in.total_disk_size());
256
121k
    out->set_data_disk_size(in.data_disk_size());
257
121k
    out->set_index_disk_size(in.index_disk_size());
258
121k
    out->mutable_zone_maps()->CopyFrom(in.zone_maps());
259
121k
    if (in.has_delete_predicate()) {
260
68
        out->mutable_delete_predicate()->CopyFrom(in.delete_predicate());
261
68
    }
262
121k
    out->set_empty(in.empty());
263
121k
    if (in.has_load_id()) {
264
5.09k
        out->mutable_load_id()->CopyFrom(in.load_id());
265
5.09k
    }
266
121k
    out->set_delete_flag(in.delete_flag());
267
121k
    out->set_creation_time(in.creation_time());
268
121k
    if (in.has_tablet_uid()) {
269
1
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
270
1
    }
271
121k
    out->set_num_segments(in.num_segments());
272
121k
    out->set_rowset_id_v2(in.rowset_id_v2());
273
121k
    out->set_resource_id(in.resource_id());
274
121k
    out->set_newest_write_timestamp(in.newest_write_timestamp());
275
121k
    out->mutable_segments_key_bounds()->CopyFrom(in.segments_key_bounds());
276
121k
    if (in.has_tablet_schema()) {
277
120k
        cloud_tablet_schema_to_doris(out->mutable_tablet_schema(), in.tablet_schema());
278
120k
    }
279
121k
    if (in.has_schema_dict_key_list()) {
280
786
        out->mutable_schema_dict_key_list()->CopyFrom(in.schema_dict_key_list());
281
786
    }
282
121k
    out->set_txn_expiration(in.txn_expiration());
283
121k
    out->set_segments_overlap_pb(in.segments_overlap_pb());
284
121k
    if (in.has_segments_key_bounds_truncated()) {
285
5.83k
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
286
5.83k
    }
287
121k
    if (in.has_segments_key_bounds_aggregated()) {
288
5.83k
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
289
5.83k
    }
290
121k
    out->mutable_num_segment_rows()->CopyFrom(in.num_segment_rows());
291
121k
    out->mutable_segments_file_size()->CopyFrom(in.segments_file_size());
292
121k
    out->set_index_id(in.index_id());
293
121k
    if (in.has_schema_version()) {
294
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
295
120k
        out->set_schema_version(in.schema_version());
296
120k
    }
297
121k
    out->set_enable_segments_file_size(in.enable_segments_file_size());
298
121k
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
299
121k
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
300
121k
    out->set_compaction_level(in.compaction_level());
301
121k
    out->mutable_inverted_index_file_info()->CopyFrom(in.inverted_index_file_info());
302
121k
    out->set_source_rowset_id(in.source_rowset_id());
303
121k
    out->set_source_tablet_id(in.source_tablet_id());
304
121k
    if (in.has___split_schema()) {
305
1
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
306
1
    }
307
121k
    if (in.has_visible_ts_ms()) {
308
5.83k
        out->set_visible_ts_ms(in.visible_ts_ms());
309
5.83k
    }
310
121k
    if (in.has_reference_instance_id()) {
311
1
        out->set_reference_instance_id(in.reference_instance_id());
312
1
    }
313
121k
    auto* slice_locations = out->mutable_packed_slice_locations();
314
121k
    slice_locations->clear();
315
121k
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
316
121k
    if (in.has_is_recycled()) {
317
1
        out->set_is_recycled(in.is_recycled());
318
1
    }
319
121k
    if (in.has_job_id()) {
320
5.83k
        out->set_job_id(in.job_id());
321
5.83k
    }
322
121k
    if (in.has_commit_tso()) {
323
666
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
324
666
    }
325
121k
    if (in.has_is_row_binlog()) {
326
1
        out->set_is_row_binlog(in.is_row_binlog());
327
1
    }
328
121k
    if (in.has_db_id()) {
329
5.83k
        out->set_db_id(in.db_id());
330
5.83k
    }
331
121k
    if (in.has_table_id()) {
332
5.83k
        out->set_table_id(in.table_id());
333
5.83k
    }
334
121k
}
335
336
6
void cloud_rowset_meta_to_doris(RowsetMetaPB* out, RowsetMetaCloudPB&& in) {
337
    // ATTN: please keep the set order aligned with the definition of proto `TabletSchemaCloudPB`.
338
6
    out->set_rowset_id(in.rowset_id());
339
6
    out->set_partition_id(in.partition_id());
340
6
    out->set_tablet_id(in.tablet_id());
341
6
    out->set_txn_id(in.txn_id());
342
6
    out->set_tablet_schema_hash(in.tablet_schema_hash());
343
6
    out->set_rowset_type(in.rowset_type());
344
6
    out->set_rowset_state(in.rowset_state());
345
6
    out->set_start_version(in.start_version());
346
6
    out->set_end_version(in.end_version());
347
6
    out->set_version_hash(in.version_hash());
348
6
    out->set_num_rows(in.num_rows());
349
6
    out->set_total_disk_size(in.total_disk_size());
350
6
    out->set_data_disk_size(in.data_disk_size());
351
6
    out->set_index_disk_size(in.index_disk_size());
352
6
    out->mutable_zone_maps()->Swap(in.mutable_zone_maps());
353
6
    if (in.has_delete_predicate()) {
354
2
        out->mutable_delete_predicate()->Swap(in.mutable_delete_predicate());
355
2
    }
356
6
    out->set_empty(in.empty());
357
6
    if (in.has_load_id()) {
358
2
        out->mutable_load_id()->CopyFrom(in.load_id());
359
2
    }
360
6
    out->set_delete_flag(in.delete_flag());
361
6
    out->set_creation_time(in.creation_time());
362
6
    if (in.has_tablet_uid()) {
363
2
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
364
2
    }
365
6
    out->set_num_segments(in.num_segments());
366
6
    out->set_rowset_id_v2(in.rowset_id_v2());
367
6
    out->set_resource_id(in.resource_id());
368
6
    out->set_newest_write_timestamp(in.newest_write_timestamp());
369
6
    out->mutable_segments_key_bounds()->Swap(in.mutable_segments_key_bounds());
370
6
    if (in.has_tablet_schema()) {
371
2
        cloud_tablet_schema_to_doris(out->mutable_tablet_schema(),
372
2
                                     std::move(*in.mutable_tablet_schema()));
373
2
    }
374
6
    if (in.has_schema_dict_key_list()) {
375
2
        out->mutable_schema_dict_key_list()->Swap(in.mutable_schema_dict_key_list());
376
2
    }
377
6
    out->set_txn_expiration(in.txn_expiration());
378
6
    out->set_segments_overlap_pb(in.segments_overlap_pb());
379
6
    if (in.has_segments_key_bounds_truncated()) {
380
2
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
381
2
    }
382
6
    if (in.has_segments_key_bounds_aggregated()) {
383
2
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
384
2
    }
385
6
    out->mutable_num_segment_rows()->Swap(in.mutable_num_segment_rows());
386
6
    out->mutable_segments_file_size()->Swap(in.mutable_segments_file_size());
387
6
    out->set_index_id(in.index_id());
388
6
    if (in.has_schema_version()) {
389
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
390
2
        out->set_schema_version(in.schema_version());
391
2
    }
392
6
    out->set_enable_segments_file_size(in.enable_segments_file_size());
393
6
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
394
6
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
395
6
    out->set_compaction_level(in.compaction_level());
396
6
    out->mutable_inverted_index_file_info()->Swap(in.mutable_inverted_index_file_info());
397
6
    out->set_source_rowset_id(in.source_rowset_id());
398
6
    out->set_source_tablet_id(in.source_tablet_id());
399
6
    if (in.has___split_schema()) {
400
2
        out->mutable___split_schema()->Swap(in.mutable___split_schema());
401
2
    }
402
6
    if (in.has_visible_ts_ms()) {
403
2
        out->set_visible_ts_ms(in.visible_ts_ms());
404
2
    }
405
6
    if (in.has_reference_instance_id()) {
406
2
        out->set_reference_instance_id(in.reference_instance_id());
407
2
    }
408
6
    auto* slice_locations = out->mutable_packed_slice_locations();
409
6
    slice_locations->clear();
410
6
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
411
6
    if (in.has_is_recycled()) {
412
2
        out->set_is_recycled(in.is_recycled());
413
2
    }
414
6
    if (in.has_job_id()) {
415
2
        out->set_job_id(in.job_id());
416
2
    }
417
6
    if (in.has_commit_tso()) {
418
2
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
419
2
    }
420
6
    if (in.has_is_row_binlog()) {
421
2
        out->set_is_row_binlog(in.is_row_binlog());
422
2
    }
423
6
    if (in.has_db_id()) {
424
2
        out->set_db_id(in.db_id());
425
2
    }
426
6
    if (in.has_table_id()) {
427
2
        out->set_table_id(in.table_id());
428
2
    }
429
6
}
430
431
0
TabletSchemaCloudPB doris_tablet_schema_to_cloud(const TabletSchemaPB& in) {
432
0
    TabletSchemaCloudPB out;
433
0
    doris_tablet_schema_to_cloud(&out, in);
434
0
    return out;
435
0
}
436
437
2
TabletSchemaCloudPB doris_tablet_schema_to_cloud(TabletSchemaPB&& in) {
438
    // ATTN: please keep the set order aligned with the definition of proto.
439
2
    TabletSchemaCloudPB out;
440
2
    doris_tablet_schema_to_cloud(&out, std::move(in));
441
2
    return out;
442
2
}
443
444
4
void doris_tablet_schema_to_cloud(TabletSchemaCloudPB* out, const TabletSchemaPB& in) {
445
    // ATTN: please keep the set order aligned with the definition of proto.
446
4
    out->set_keys_type(in.keys_type());
447
4
    out->mutable_column()->CopyFrom(in.column());
448
4
    out->set_num_short_key_columns(in.num_short_key_columns());
449
4
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
450
4
    out->set_compress_kind(in.compress_kind());
451
4
    out->set_bf_fpp(in.bf_fpp());
452
4
    out->set_next_column_unique_id(in.next_column_unique_id());
453
4
    out->set_delete_sign_idx(in.delete_sign_idx());
454
4
    out->set_sequence_col_idx(in.sequence_col_idx());
455
4
    out->set_sort_type(in.sort_type());
456
4
    out->set_sort_col_num(in.sort_col_num());
457
4
    out->set_compression_type(in.compression_type());
458
4
    out->set_schema_version(in.schema_version());
459
4
    out->set_disable_auto_compaction(in.disable_auto_compaction());
460
4
    out->mutable_index()->CopyFrom(in.index());
461
4
    out->set_version_col_idx(in.version_col_idx());
462
4
    out->set_store_row_column(in.store_row_column());
463
4
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
464
4
    out->mutable_cluster_key_uids()->CopyFrom(in.cluster_key_uids());
465
4
    out->set_is_dynamic_schema(in.is_dynamic_schema());
466
4
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
467
4
    out->mutable_row_store_column_unique_ids()->CopyFrom(in.row_store_column_unique_ids());
468
4
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
469
4
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
470
4
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
471
4
    out->set_storage_page_size(in.storage_page_size());
472
4
    out->set_storage_dict_page_size(in.storage_dict_page_size());
473
4
    out->set_is_in_memory(in.is_in_memory());
474
4
    out->set_row_store_page_size(in.row_store_page_size());
475
4
    if (in.has_integer_type_default_use_plain_encoding()) {
476
4
        out->set_integer_type_default_use_plain_encoding(
477
4
                in.integer_type_default_use_plain_encoding());
478
4
    }
479
4
    if (in.has_binary_plain_encoding_default_impl()) {
480
4
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
481
4
    }
482
4
    if (in.has_storage_format()) {
483
4
        out->set_storage_format(in.storage_format());
484
4
    }
485
4
    if (in.has_seq_map()) {
486
4
        out->mutable_seq_map()->CopyFrom(in.seq_map());
487
4
    }
488
489
4
    if (in.has___split_schema()) {
490
4
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
491
4
    }
492
4
}
493
494
72.7k
void doris_tablet_schema_to_cloud(TabletSchemaCloudPB* out, TabletSchemaPB&& in) {
495
72.7k
    out->set_keys_type(in.keys_type());
496
72.7k
    out->mutable_column()->Swap(in.mutable_column());
497
72.7k
    out->set_num_short_key_columns(in.num_short_key_columns());
498
72.7k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
499
72.7k
    out->set_compress_kind(in.compress_kind());
500
72.7k
    out->set_bf_fpp(in.bf_fpp());
501
72.7k
    out->set_next_column_unique_id(in.next_column_unique_id());
502
72.7k
    out->set_delete_sign_idx(in.delete_sign_idx());
503
72.7k
    out->set_sequence_col_idx(in.sequence_col_idx());
504
72.7k
    out->set_sort_type(in.sort_type());
505
72.7k
    out->set_sort_col_num(in.sort_col_num());
506
72.7k
    out->set_compression_type(in.compression_type());
507
72.7k
    out->set_schema_version(in.schema_version());
508
72.7k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
509
72.7k
    out->mutable_index()->Swap(in.mutable_index());
510
72.7k
    out->set_version_col_idx(in.version_col_idx());
511
72.7k
    out->set_store_row_column(in.store_row_column());
512
72.7k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
513
72.7k
    out->mutable_cluster_key_uids()->Swap(in.mutable_cluster_key_uids());
514
72.7k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
515
72.7k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
516
72.7k
    out->mutable_row_store_column_unique_ids()->Swap(in.mutable_row_store_column_unique_ids());
517
72.7k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
518
72.7k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
519
72.7k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
520
72.7k
    out->set_storage_page_size(in.storage_page_size());
521
72.7k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
522
72.7k
    out->set_is_in_memory(in.is_in_memory());
523
72.7k
    out->set_row_store_page_size(in.row_store_page_size());
524
72.7k
    if (in.has_integer_type_default_use_plain_encoding()) {
525
38.1k
        out->set_integer_type_default_use_plain_encoding(
526
38.1k
                in.integer_type_default_use_plain_encoding());
527
38.1k
    }
528
72.7k
    if (in.has_binary_plain_encoding_default_impl()) {
529
38.2k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
530
38.2k
    }
531
72.7k
    if (in.has_storage_format()) {
532
72.1k
        out->set_storage_format(in.storage_format());
533
72.1k
    }
534
72.7k
    if (in.has_seq_map()) {
535
71.1k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
536
71.1k
    }
537
538
72.7k
    if (in.has___split_schema()) {
539
6
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
540
6
    }
541
72.7k
}
542
543
0
TabletSchemaPB cloud_tablet_schema_to_doris(const TabletSchemaCloudPB& in) {
544
0
    TabletSchemaPB out;
545
0
    cloud_tablet_schema_to_doris(&out, in);
546
0
    return out;
547
0
}
548
549
2
TabletSchemaPB cloud_tablet_schema_to_doris(TabletSchemaCloudPB&& in) {
550
2
    TabletSchemaPB out;
551
2
    cloud_tablet_schema_to_doris(&out, std::move(in));
552
2
    return out;
553
2
}
554
555
120k
void cloud_tablet_schema_to_doris(TabletSchemaPB* out, const TabletSchemaCloudPB& in) {
556
    // ATTN: please keep the set order aligned with the definition of proto.
557
120k
    out->set_keys_type(in.keys_type());
558
120k
    out->mutable_column()->CopyFrom(in.column());
559
120k
    out->set_num_short_key_columns(in.num_short_key_columns());
560
120k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
561
120k
    out->set_compress_kind(in.compress_kind());
562
120k
    out->set_bf_fpp(in.bf_fpp());
563
120k
    out->set_next_column_unique_id(in.next_column_unique_id());
564
120k
    out->set_delete_sign_idx(in.delete_sign_idx());
565
120k
    out->set_sequence_col_idx(in.sequence_col_idx());
566
120k
    out->set_sort_type(in.sort_type());
567
120k
    out->set_sort_col_num(in.sort_col_num());
568
120k
    out->set_compression_type(in.compression_type());
569
120k
    out->set_schema_version(in.schema_version());
570
120k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
571
120k
    out->mutable_index()->CopyFrom(in.index());
572
120k
    out->set_version_col_idx(in.version_col_idx());
573
120k
    out->set_store_row_column(in.store_row_column());
574
120k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
575
120k
    out->mutable_cluster_key_uids()->CopyFrom(in.cluster_key_uids());
576
120k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
577
120k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
578
120k
    out->mutable_row_store_column_unique_ids()->CopyFrom(in.row_store_column_unique_ids());
579
120k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
580
120k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
581
120k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
582
120k
    out->set_storage_page_size(in.storage_page_size());
583
120k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
584
120k
    out->set_is_in_memory(in.is_in_memory());
585
120k
    out->set_row_store_page_size(in.row_store_page_size());
586
120k
    if (in.has_integer_type_default_use_plain_encoding()) {
587
60.7k
        out->set_integer_type_default_use_plain_encoding(
588
60.7k
                in.integer_type_default_use_plain_encoding());
589
60.7k
    }
590
120k
    if (in.has_binary_plain_encoding_default_impl()) {
591
60.8k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
592
60.8k
    }
593
120k
    if (in.has_storage_format()) {
594
120k
        out->set_storage_format(in.storage_format());
595
120k
    }
596
120k
    if (in.has_seq_map()) {
597
120k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
598
120k
    }
599
600
120k
    if (in.has___split_schema()) {
601
4
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
602
4
    }
603
120k
}
604
605
374k
void cloud_tablet_schema_to_doris(TabletSchemaPB* out, TabletSchemaCloudPB&& in) {
606
    // ATTN: please keep the set order aligned with the definition of proto.
607
374k
    out->set_keys_type(in.keys_type());
608
374k
    out->mutable_column()->Swap(in.mutable_column());
609
374k
    out->set_num_short_key_columns(in.num_short_key_columns());
610
374k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
611
374k
    out->set_compress_kind(in.compress_kind());
612
374k
    out->set_bf_fpp(in.bf_fpp());
613
374k
    out->set_next_column_unique_id(in.next_column_unique_id());
614
374k
    out->set_delete_sign_idx(in.delete_sign_idx());
615
374k
    out->set_sequence_col_idx(in.sequence_col_idx());
616
374k
    out->set_sort_type(in.sort_type());
617
374k
    out->set_sort_col_num(in.sort_col_num());
618
374k
    out->set_compression_type(in.compression_type());
619
374k
    out->set_schema_version(in.schema_version());
620
374k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
621
374k
    out->mutable_index()->Swap(in.mutable_index());
622
374k
    out->set_version_col_idx(in.version_col_idx());
623
374k
    out->set_store_row_column(in.store_row_column());
624
374k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
625
374k
    out->mutable_cluster_key_uids()->Swap(in.mutable_cluster_key_uids());
626
374k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
627
374k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
628
374k
    out->mutable_row_store_column_unique_ids()->Swap(in.mutable_row_store_column_unique_ids());
629
374k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
630
374k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
631
374k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
632
374k
    out->set_storage_page_size(in.storage_page_size());
633
374k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
634
374k
    out->set_is_in_memory(in.is_in_memory());
635
374k
    out->set_row_store_page_size(in.row_store_page_size());
636
374k
    if (in.has_integer_type_default_use_plain_encoding()) {
637
178k
        out->set_integer_type_default_use_plain_encoding(
638
178k
                in.integer_type_default_use_plain_encoding());
639
178k
    }
640
374k
    if (in.has_binary_plain_encoding_default_impl()) {
641
178k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
642
178k
    }
643
374k
    if (in.has_storage_format()) {
644
374k
        out->set_storage_format(in.storage_format());
645
374k
    }
646
374k
    if (in.has_seq_map()) {
647
373k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
648
373k
    }
649
650
374k
    if (in.has___split_schema()) {
651
6
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
652
6
    }
653
374k
}
654
655
0
TabletMetaCloudPB doris_tablet_meta_to_cloud(const TabletMetaPB& in) {
656
0
    TabletMetaCloudPB out;
657
0
    doris_tablet_meta_to_cloud(&out, in);
658
0
    return out;
659
0
}
660
661
1
TabletMetaCloudPB doris_tablet_meta_to_cloud(TabletMetaPB&& in) {
662
1
    TabletMetaCloudPB out;
663
1
    doris_tablet_meta_to_cloud(&out, std::move(in));
664
1
    return out;
665
1
}
666
667
1
void doris_tablet_meta_to_cloud(TabletMetaCloudPB* out, const TabletMetaPB& in) {
668
    // ATTN: please keep the set order aligned with the definition of proto.
669
1
    out->set_table_id(in.table_id());
670
1
    out->set_partition_id(in.partition_id());
671
1
    out->set_tablet_id(in.tablet_id());
672
1
    out->set_schema_hash(in.schema_hash());
673
1
    out->set_shard_id(in.shard_id());
674
1
    out->set_creation_time(in.creation_time());
675
1
    out->set_cumulative_layer_point(in.cumulative_layer_point());
676
1
    out->set_tablet_state(in.tablet_state());
677
1
    if (in.has_schema()) {
678
1
        doris_tablet_schema_to_cloud(out->mutable_schema(), in.schema());
679
1
    }
680
1
    if (in.rs_metas_size()) {
681
1
        out->mutable_rs_metas()->Reserve(in.rs_metas_size());
682
1
        for (const auto& rs_meta : in.rs_metas()) {
683
1
            doris_rowset_meta_to_cloud(out->add_rs_metas(), rs_meta);
684
1
        }
685
1
    }
686
    // ATTN: inc_rs_metas are deprecated, here is for conversion check
687
1
    if (in.inc_rs_metas_size()) {
688
1
        out->mutable_inc_rs_metas()->Reserve(in.inc_rs_metas_size());
689
1
        for (const auto& rs_meta : in.inc_rs_metas()) {
690
1
            doris_rowset_meta_to_cloud(out->add_inc_rs_metas(), rs_meta);
691
1
        }
692
1
    }
693
1
    if (in.has_alter_task()) {
694
1
        out->mutable_alter_task()->CopyFrom(in.alter_task());
695
1
    }
696
1
    out->set_in_restore_mode(in.in_restore_mode());
697
1
    out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
698
1
    out->set_end_rowset_id(in.end_rowset_id());
699
1
    out->set_preferred_rowset_type(in.preferred_rowset_type());
700
1
    out->set_tablet_type(in.tablet_type());
701
1
    if (in.stale_rs_metas_size()) {
702
1
        out->mutable_stale_rs_metas()->Reserve(in.stale_rs_metas_size());
703
1
        for (const auto& rs_meta : in.stale_rs_metas()) {
704
1
            doris_rowset_meta_to_cloud(out->add_stale_rs_metas(), rs_meta);
705
1
        }
706
1
    }
707
1
    out->set_replica_id(in.replica_id());
708
1
    if (in.has_delete_bitmap()) {
709
1
        out->mutable_delete_bitmap()->CopyFrom(in.delete_bitmap());
710
1
    }
711
1
    out->set_enable_unique_key_merge_on_write(in.enable_unique_key_merge_on_write());
712
1
    out->set_storage_policy_id(in.storage_policy_id());
713
1
    out->mutable_cooldown_meta_id()->CopyFrom(in.cooldown_meta_id());
714
1
    if (in.has_binlog_config()) {
715
1
        out->mutable_binlog_config()->CopyFrom(in.binlog_config());
716
1
    }
717
1
    if (in.has_row_binlog_schema()) {
718
1
        doris_tablet_schema_to_cloud(out->mutable_row_binlog_schema(), in.row_binlog_schema());
719
1
    }
720
1
    if (in.row_binlog_rs_metas_size()) {
721
1
        out->mutable_row_binlog_rs_metas()->Reserve(in.row_binlog_rs_metas_size());
722
1
        for (const auto& rs_meta : in.row_binlog_rs_metas()) {
723
1
            doris_rowset_meta_to_cloud(out->add_row_binlog_rs_metas(), rs_meta);
724
1
        }
725
1
    }
726
1
    if (in.has_row_binlog_schema_hash()) {
727
1
        out->set_row_binlog_schema_hash(in.row_binlog_schema_hash());
728
1
    }
729
1
    out->set_compaction_policy(in.compaction_policy());
730
1
    out->set_time_series_compaction_goal_size_mbytes(in.time_series_compaction_goal_size_mbytes());
731
1
    out->set_time_series_compaction_file_count_threshold(
732
1
            in.time_series_compaction_file_count_threshold());
733
1
    out->set_time_series_compaction_time_threshold_seconds(
734
1
            in.time_series_compaction_time_threshold_seconds());
735
1
    out->set_time_series_compaction_empty_rowsets_threshold(
736
1
            in.time_series_compaction_empty_rowsets_threshold());
737
1
    out->set_time_series_compaction_level_threshold(in.time_series_compaction_level_threshold());
738
1
    out->set_vertical_compaction_num_columns_per_group(
739
1
            in.vertical_compaction_num_columns_per_group());
740
1
    out->set_index_id(in.index_id());
741
1
    out->set_is_in_memory(in.is_in_memory());
742
1
    out->set_is_persistent(in.is_persistent());
743
1
    out->set_table_name(in.table_name());
744
1
    out->set_ttl_seconds(in.ttl_seconds());
745
1
    if (in.has_schema_version()) {
746
1
        out->set_schema_version(in.schema_version());
747
1
    }
748
1
    if (in.has_encryption_algorithm()) {
749
1
        out->set_encryption_algorithm(in.encryption_algorithm());
750
1
    }
751
1
}
752
753
1
void doris_tablet_meta_to_cloud(TabletMetaCloudPB* out, TabletMetaPB&& in) {
754
    // ATTN: please keep the set order aligned with the definition of proto.
755
1
    out->set_table_id(in.table_id());
756
1
    out->set_partition_id(in.partition_id());
757
1
    out->set_tablet_id(in.tablet_id());
758
1
    out->set_schema_hash(in.schema_hash());
759
1
    out->set_shard_id(in.shard_id());
760
1
    out->set_creation_time(in.creation_time());
761
1
    out->set_cumulative_layer_point(in.cumulative_layer_point());
762
1
    out->set_tablet_state(in.tablet_state());
763
1
    if (in.has_schema()) {
764
1
        doris_tablet_schema_to_cloud(out->mutable_schema(), std::move(*in.mutable_schema()));
765
1
    }
766
1
    if (in.rs_metas_size()) {
767
1
        int32_t rs_metas_size = in.rs_metas_size();
768
1
        out->mutable_rs_metas()->Reserve(rs_metas_size);
769
2
        for (int i = 0; i < rs_metas_size; ++i) {
770
1
            doris_rowset_meta_to_cloud(out->add_rs_metas(), std::move(*in.mutable_rs_metas(i)));
771
1
        }
772
1
    }
773
    // ATTN: inc_rs_metas are deprecated, here is for conversion check
774
1
    if (in.inc_rs_metas_size()) {
775
1
        int rs_metas_size = in.inc_rs_metas_size();
776
1
        out->mutable_inc_rs_metas()->Reserve(rs_metas_size);
777
2
        for (int i = 0; i < rs_metas_size; ++i) {
778
1
            doris_rowset_meta_to_cloud(out->add_inc_rs_metas(),
779
1
                                       std::move(*in.mutable_inc_rs_metas(i)));
780
1
        }
781
1
    }
782
1
    if (in.has_alter_task()) {
783
1
        out->mutable_alter_task()->Swap(in.mutable_alter_task());
784
1
    }
785
1
    out->set_in_restore_mode(in.in_restore_mode());
786
1
    out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
787
1
    out->set_end_rowset_id(in.end_rowset_id());
788
1
    out->set_preferred_rowset_type(in.preferred_rowset_type());
789
1
    out->set_tablet_type(in.tablet_type());
790
1
    if (in.stale_rs_metas_size()) {
791
1
        int rs_metas_size = in.stale_rs_metas_size();
792
1
        out->mutable_stale_rs_metas()->Reserve(rs_metas_size);
793
2
        for (int i = 0; i < rs_metas_size; i++) {
794
1
            doris_rowset_meta_to_cloud(out->add_stale_rs_metas(),
795
1
                                       std::move(*in.mutable_stale_rs_metas(i)));
796
1
        }
797
1
    }
798
1
    out->set_replica_id(in.replica_id());
799
1
    if (in.has_delete_bitmap()) {
800
1
        out->mutable_delete_bitmap()->Swap(in.mutable_delete_bitmap());
801
1
    }
802
1
    out->set_enable_unique_key_merge_on_write(in.enable_unique_key_merge_on_write());
803
1
    out->set_storage_policy_id(in.storage_policy_id());
804
1
    out->mutable_cooldown_meta_id()->CopyFrom(in.cooldown_meta_id());
805
1
    if (in.has_binlog_config()) {
806
1
        out->mutable_binlog_config()->Swap(in.mutable_binlog_config());
807
1
    }
808
1
    if (in.has_row_binlog_schema()) {
809
1
        doris_tablet_schema_to_cloud(out->mutable_row_binlog_schema(),
810
1
                                     std::move(*in.mutable_row_binlog_schema()));
811
1
    }
812
1
    if (in.row_binlog_rs_metas_size()) {
813
1
        int row_binlog_rs_metas_size = in.row_binlog_rs_metas_size();
814
1
        out->mutable_row_binlog_rs_metas()->Reserve(row_binlog_rs_metas_size);
815
2
        for (int i = 0; i < row_binlog_rs_metas_size; ++i) {
816
1
            doris_rowset_meta_to_cloud(out->add_row_binlog_rs_metas(),
817
1
                                       std::move(*in.mutable_row_binlog_rs_metas(i)));
818
1
        }
819
1
    }
820
1
    if (in.has_row_binlog_schema_hash()) {
821
1
        out->set_row_binlog_schema_hash(in.row_binlog_schema_hash());
822
1
    }
823
1
    out->set_compaction_policy(in.compaction_policy());
824
1
    out->set_time_series_compaction_goal_size_mbytes(in.time_series_compaction_goal_size_mbytes());
825
1
    out->set_time_series_compaction_file_count_threshold(
826
1
            in.time_series_compaction_file_count_threshold());
827
1
    out->set_time_series_compaction_time_threshold_seconds(
828
1
            in.time_series_compaction_time_threshold_seconds());
829
1
    out->set_time_series_compaction_empty_rowsets_threshold(
830
1
            in.time_series_compaction_empty_rowsets_threshold());
831
1
    out->set_time_series_compaction_level_threshold(in.time_series_compaction_level_threshold());
832
1
    out->set_vertical_compaction_num_columns_per_group(
833
1
            in.vertical_compaction_num_columns_per_group());
834
1
    out->set_index_id(in.index_id());
835
1
    out->set_is_in_memory(in.is_in_memory());
836
1
    out->set_is_persistent(in.is_persistent());
837
1
    out->set_table_name(in.table_name());
838
1
    out->set_ttl_seconds(in.ttl_seconds());
839
1
    if (in.has_schema_version()) {
840
1
        out->set_schema_version(in.schema_version());
841
1
    }
842
1
    if (in.has_encryption_algorithm()) {
843
1
        out->set_encryption_algorithm(in.encryption_algorithm());
844
1
    }
845
1
}
846
847
0
TabletMetaPB cloud_tablet_meta_to_doris(const TabletMetaCloudPB& in) {
848
0
    TabletMetaPB out;
849
0
    cloud_tablet_meta_to_doris(&out, in);
850
0
    return out;
851
0
}
852
853
374k
TabletMetaPB cloud_tablet_meta_to_doris(TabletMetaCloudPB&& in) {
854
374k
    TabletMetaPB out;
855
374k
    cloud_tablet_meta_to_doris(&out, std::move(in));
856
374k
    return out;
857
374k
}
858
859
1
void cloud_tablet_meta_to_doris(TabletMetaPB* out, const TabletMetaCloudPB& in) {
860
    // ATTN: please keep the set order aligned with the definition of proto.
861
1
    out->set_table_id(in.table_id());
862
1
    out->set_partition_id(in.partition_id());
863
1
    out->set_tablet_id(in.tablet_id());
864
1
    out->set_schema_hash(in.schema_hash());
865
1
    out->set_shard_id(in.shard_id());
866
1
    out->set_creation_time(in.creation_time());
867
1
    out->set_cumulative_layer_point(in.cumulative_layer_point());
868
1
    out->set_tablet_state(in.tablet_state());
869
1
    if (in.has_schema()) {
870
1
        cloud_tablet_schema_to_doris(out->mutable_schema(), in.schema());
871
1
    }
872
1
    if (in.rs_metas_size()) {
873
1
        out->mutable_rs_metas()->Reserve(in.rs_metas_size());
874
1
        for (const auto& rs_meta : in.rs_metas()) {
875
1
            cloud_rowset_meta_to_doris(out->add_rs_metas(), rs_meta);
876
1
        }
877
1
    }
878
    // ATTN: inc_rs_metas are deprecated, here is for conversion check
879
1
    if (in.inc_rs_metas_size()) {
880
1
        out->mutable_inc_rs_metas()->Reserve(in.inc_rs_metas_size());
881
1
        for (const auto& rs_meta : in.inc_rs_metas()) {
882
1
            cloud_rowset_meta_to_doris(out->add_inc_rs_metas(), rs_meta);
883
1
        }
884
1
    }
885
1
    if (in.has_alter_task()) {
886
1
        out->mutable_alter_task()->CopyFrom(in.alter_task());
887
1
    }
888
1
    out->set_in_restore_mode(in.in_restore_mode());
889
1
    out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
890
1
    out->set_end_rowset_id(in.end_rowset_id());
891
1
    out->set_preferred_rowset_type(in.preferred_rowset_type());
892
1
    out->set_tablet_type(in.tablet_type());
893
1
    if (in.stale_rs_metas_size()) {
894
1
        out->mutable_stale_rs_metas()->Reserve(in.stale_rs_metas_size());
895
1
        for (const auto& rs_meta : in.stale_rs_metas()) {
896
1
            cloud_rowset_meta_to_doris(out->add_stale_rs_metas(), rs_meta);
897
1
        }
898
1
    }
899
1
    out->set_replica_id(in.replica_id());
900
1
    if (in.has_delete_bitmap()) {
901
1
        out->mutable_delete_bitmap()->CopyFrom(in.delete_bitmap());
902
1
    }
903
1
    out->set_enable_unique_key_merge_on_write(in.enable_unique_key_merge_on_write());
904
1
    out->set_storage_policy_id(in.storage_policy_id());
905
1
    out->mutable_cooldown_meta_id()->CopyFrom(in.cooldown_meta_id());
906
1
    if (in.has_binlog_config()) {
907
1
        out->mutable_binlog_config()->CopyFrom(in.binlog_config());
908
1
    }
909
1
    if (in.has_row_binlog_schema()) {
910
1
        cloud_tablet_schema_to_doris(out->mutable_row_binlog_schema(), in.row_binlog_schema());
911
1
    }
912
1
    if (in.row_binlog_rs_metas_size()) {
913
1
        out->mutable_row_binlog_rs_metas()->Reserve(in.row_binlog_rs_metas_size());
914
1
        for (const auto& rs_meta : in.row_binlog_rs_metas()) {
915
1
            cloud_rowset_meta_to_doris(out->add_row_binlog_rs_metas(), rs_meta);
916
1
        }
917
1
    }
918
1
    if (in.has_row_binlog_schema_hash()) {
919
1
        out->set_row_binlog_schema_hash(in.row_binlog_schema_hash());
920
1
    }
921
1
    out->set_compaction_policy(in.compaction_policy());
922
1
    out->set_time_series_compaction_goal_size_mbytes(in.time_series_compaction_goal_size_mbytes());
923
1
    out->set_time_series_compaction_file_count_threshold(
924
1
            in.time_series_compaction_file_count_threshold());
925
1
    out->set_time_series_compaction_time_threshold_seconds(
926
1
            in.time_series_compaction_time_threshold_seconds());
927
1
    out->set_time_series_compaction_empty_rowsets_threshold(
928
1
            in.time_series_compaction_empty_rowsets_threshold());
929
1
    out->set_time_series_compaction_level_threshold(in.time_series_compaction_level_threshold());
930
1
    out->set_vertical_compaction_num_columns_per_group(
931
1
            in.vertical_compaction_num_columns_per_group());
932
1
    out->set_index_id(in.index_id());
933
1
    out->set_is_in_memory(in.is_in_memory());
934
1
    out->set_is_persistent(in.is_persistent());
935
1
    out->set_table_name(in.table_name());
936
1
    out->set_ttl_seconds(in.ttl_seconds());
937
1
    if (in.has_schema_version()) {
938
1
        out->set_schema_version(in.schema_version());
939
1
    }
940
1
    if (in.has_encryption_algorithm()) {
941
1
        out->set_encryption_algorithm(in.encryption_algorithm());
942
1
    }
943
1
}
944
945
374k
void cloud_tablet_meta_to_doris(TabletMetaPB* out, TabletMetaCloudPB&& in) {
946
    // ATTN: please keep the set order aligned with the definition of proto.
947
374k
    out->set_table_id(in.table_id());
948
374k
    out->set_partition_id(in.partition_id());
949
374k
    out->set_tablet_id(in.tablet_id());
950
374k
    out->set_schema_hash(in.schema_hash());
951
374k
    out->set_shard_id(in.shard_id());
952
374k
    out->set_creation_time(in.creation_time());
953
374k
    out->set_cumulative_layer_point(in.cumulative_layer_point());
954
374k
    out->set_tablet_state(in.tablet_state());
955
374k
    if (in.has_schema()) {
956
373k
        cloud_tablet_schema_to_doris(out->mutable_schema(), std::move(*in.mutable_schema()));
957
373k
    }
958
374k
    if (in.rs_metas_size()) {
959
1
        int rs_metas_size = in.rs_metas_size();
960
1
        out->mutable_rs_metas()->Reserve(rs_metas_size);
961
2
        for (int i = 0; i < rs_metas_size; ++i) {
962
1
            cloud_rowset_meta_to_doris(out->add_rs_metas(), std::move(*in.mutable_rs_metas(i)));
963
1
        }
964
1
    }
965
    // ATTN: inc_rs_metas are deprecated, here is for conversion check
966
374k
    if (in.inc_rs_metas_size()) {
967
1
        int rs_metas_size = in.inc_rs_metas_size();
968
1
        out->mutable_inc_rs_metas()->Reserve(rs_metas_size);
969
2
        for (int i = 0; i < rs_metas_size; i++) {
970
1
            cloud_rowset_meta_to_doris(out->add_inc_rs_metas(),
971
1
                                       std::move(*in.mutable_inc_rs_metas(i)));
972
1
        }
973
1
    }
974
374k
    if (in.has_alter_task()) {
975
1
        out->mutable_alter_task()->Swap(in.mutable_alter_task());
976
1
    }
977
374k
    out->set_in_restore_mode(in.in_restore_mode());
978
374k
    out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
979
374k
    out->set_end_rowset_id(in.end_rowset_id());
980
374k
    out->set_preferred_rowset_type(in.preferred_rowset_type());
981
374k
    out->set_tablet_type(in.tablet_type());
982
374k
    if (in.stale_rs_metas_size()) {
983
1
        int rs_metas_size = in.stale_rs_metas_size();
984
1
        out->mutable_stale_rs_metas()->Reserve(rs_metas_size);
985
2
        for (int i = 0; i < rs_metas_size; i++) {
986
1
            cloud_rowset_meta_to_doris(out->add_stale_rs_metas(),
987
1
                                       std::move(*in.mutable_stale_rs_metas(i)));
988
1
        }
989
1
    }
990
374k
    out->set_replica_id(in.replica_id());
991
374k
    if (in.has_delete_bitmap()) {
992
1
        out->mutable_delete_bitmap()->Swap(in.mutable_delete_bitmap());
993
1
    }
994
374k
    out->set_enable_unique_key_merge_on_write(in.enable_unique_key_merge_on_write());
995
374k
    out->set_storage_policy_id(in.storage_policy_id());
996
374k
    out->mutable_cooldown_meta_id()->CopyFrom(in.cooldown_meta_id());
997
374k
    if (in.has_binlog_config()) {
998
1
        out->mutable_binlog_config()->Swap(in.mutable_binlog_config());
999
1
    }
1000
374k
    if (in.has_row_binlog_schema()) {
1001
1
        cloud_tablet_schema_to_doris(out->mutable_row_binlog_schema(),
1002
1
                                     std::move(*in.mutable_row_binlog_schema()));
1003
1
    }
1004
374k
    if (in.row_binlog_rs_metas_size()) {
1005
1
        int row_binlog_rs_metas_size = in.row_binlog_rs_metas_size();
1006
1
        out->mutable_row_binlog_rs_metas()->Reserve(row_binlog_rs_metas_size);
1007
2
        for (int i = 0; i < row_binlog_rs_metas_size; ++i) {
1008
1
            cloud_rowset_meta_to_doris(out->add_row_binlog_rs_metas(),
1009
1
                                       std::move(*in.mutable_row_binlog_rs_metas(i)));
1010
1
        }
1011
1
    }
1012
374k
    if (in.has_row_binlog_schema_hash()) {
1013
1
        out->set_row_binlog_schema_hash(in.row_binlog_schema_hash());
1014
1
    }
1015
374k
    out->set_compaction_policy(in.compaction_policy());
1016
374k
    out->set_time_series_compaction_goal_size_mbytes(in.time_series_compaction_goal_size_mbytes());
1017
374k
    out->set_time_series_compaction_file_count_threshold(
1018
374k
            in.time_series_compaction_file_count_threshold());
1019
374k
    out->set_time_series_compaction_time_threshold_seconds(
1020
374k
            in.time_series_compaction_time_threshold_seconds());
1021
374k
    out->set_time_series_compaction_empty_rowsets_threshold(
1022
374k
            in.time_series_compaction_empty_rowsets_threshold());
1023
374k
    out->set_time_series_compaction_level_threshold(in.time_series_compaction_level_threshold());
1024
374k
    out->set_vertical_compaction_num_columns_per_group(
1025
374k
            in.vertical_compaction_num_columns_per_group());
1026
374k
    out->set_index_id(in.index_id());
1027
374k
    out->set_is_in_memory(in.is_in_memory());
1028
374k
    out->set_is_persistent(in.is_persistent());
1029
374k
    out->set_table_name(in.table_name());
1030
374k
    out->set_ttl_seconds(in.ttl_seconds());
1031
374k
    if (in.has_schema_version()) {
1032
374k
        out->set_schema_version(in.schema_version());
1033
374k
    }
1034
374k
    if (in.has_encryption_algorithm()) {
1035
374k
        out->set_encryption_algorithm(in.encryption_algorithm());
1036
374k
    }
1037
374k
}
1038
1039
} // namespace doris::cloud