Coverage Report

Created: 2026-06-10 06:10

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
56.8k
RowsetMetaCloudPB doris_rowset_meta_to_cloud(RowsetMetaPB&& in) {
35
56.8k
    RowsetMetaCloudPB out;
36
56.8k
    doris_rowset_meta_to_cloud(&out, std::move(in));
37
56.8k
    return out;
38
56.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
443k
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
443k
    out->set_rowset_id(in.rowset_id());
137
443k
    out->set_partition_id(in.partition_id());
138
443k
    out->set_tablet_id(in.tablet_id());
139
443k
    out->set_txn_id(in.txn_id());
140
443k
    out->set_tablet_schema_hash(in.tablet_schema_hash());
141
443k
    out->set_rowset_type(in.rowset_type());
142
443k
    out->set_rowset_state(in.rowset_state());
143
443k
    out->set_start_version(in.start_version());
144
443k
    out->set_end_version(in.end_version());
145
443k
    out->set_version_hash(in.version_hash());
146
443k
    out->set_num_rows(in.num_rows());
147
443k
    out->set_total_disk_size(in.total_disk_size());
148
443k
    out->set_data_disk_size(in.data_disk_size());
149
443k
    out->set_index_disk_size(in.index_disk_size());
150
443k
    out->mutable_zone_maps()->Swap(in.mutable_zone_maps());
151
443k
    if (in.has_delete_predicate()) {
152
6.34k
        out->mutable_delete_predicate()->Swap(in.mutable_delete_predicate());
153
6.34k
    }
154
443k
    out->set_empty(in.empty());
155
443k
    if (in.has_load_id()) {
156
397k
        out->mutable_load_id()->CopyFrom(in.load_id());
157
397k
    }
158
443k
    out->set_delete_flag(in.delete_flag());
159
443k
    out->set_creation_time(in.creation_time());
160
443k
    if (in.has_tablet_uid()) {
161
545
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
162
545
    }
163
443k
    out->set_num_segments(in.num_segments());
164
443k
    out->set_rowset_id_v2(in.rowset_id_v2());
165
443k
    out->set_resource_id(in.resource_id());
166
443k
    out->set_newest_write_timestamp(in.newest_write_timestamp());
167
443k
    out->mutable_segments_key_bounds()->Swap(in.mutable_segments_key_bounds());
168
443k
    if (in.has_tablet_schema()) {
169
190k
        doris_tablet_schema_to_cloud(out->mutable_tablet_schema(),
170
190k
                                     std::move(*in.mutable_tablet_schema()));
171
190k
    }
172
443k
    if (in.has_schema_dict_key_list()) {
173
44
        out->mutable_schema_dict_key_list()->Swap(in.mutable_schema_dict_key_list());
174
44
    }
175
443k
    out->set_txn_expiration(in.txn_expiration());
176
443k
    out->set_segments_overlap_pb(in.segments_overlap_pb());
177
443k
    if (in.has_segments_key_bounds_truncated()) {
178
246k
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
179
246k
    }
180
443k
    if (in.has_segments_key_bounds_aggregated()) {
181
248k
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
182
248k
    }
183
443k
    out->mutable_num_segment_rows()->Swap(in.mutable_num_segment_rows());
184
443k
    out->mutable_segments_file_size()->Swap(in.mutable_segments_file_size());
185
443k
    out->set_index_id(in.index_id());
186
443k
    if (in.has_schema_version()) {
187
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
188
438k
        out->set_schema_version(in.schema_version());
189
438k
    }
190
443k
    out->set_enable_segments_file_size(in.enable_segments_file_size());
191
443k
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
192
443k
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
193
443k
    out->set_compaction_level(in.compaction_level());
194
443k
    out->mutable_inverted_index_file_info()->Swap(in.mutable_inverted_index_file_info());
195
443k
    out->set_source_rowset_id(in.source_rowset_id());
196
443k
    out->set_source_tablet_id(in.source_tablet_id());
197
198
443k
    if (in.has___split_schema()) {
199
2
        out->mutable___split_schema()->Swap(in.mutable___split_schema());
200
2
    }
201
443k
    if (in.has_visible_ts_ms()) {
202
47.9k
        out->set_visible_ts_ms(in.visible_ts_ms());
203
47.9k
    }
204
443k
    if (in.has_reference_instance_id()) {
205
2
        out->set_reference_instance_id(in.reference_instance_id());
206
2
    }
207
443k
    auto* slice_locations = out->mutable_packed_slice_locations();
208
443k
    slice_locations->clear();
209
443k
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
210
443k
    if (in.has_is_recycled()) {
211
2
        out->set_is_recycled(in.is_recycled());
212
2
    }
213
443k
    if (in.has_job_id()) {
214
437k
        out->set_job_id(in.job_id());
215
437k
    }
216
443k
    if (in.has_commit_tso()) {
217
11.1k
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
218
11.1k
    }
219
443k
    if (in.has_is_row_binlog()) {
220
2
        out->set_is_row_binlog(in.is_row_binlog());
221
2
    }
222
443k
    if (in.has_db_id()) {
223
436k
        out->set_db_id(in.db_id());
224
436k
    }
225
443k
    if (in.has_table_id()) {
226
437k
        out->set_table_id(in.table_id());
227
437k
    }
228
443k
}
229
230
136k
RowsetMetaPB cloud_rowset_meta_to_doris(const RowsetMetaCloudPB& in) {
231
136k
    RowsetMetaPB out;
232
136k
    cloud_rowset_meta_to_doris(&out, in);
233
136k
    return out;
234
136k
}
235
236
8
RowsetMetaPB cloud_rowset_meta_to_doris(RowsetMetaCloudPB&& in) {
237
8
    RowsetMetaPB out;
238
8
    cloud_rowset_meta_to_doris(&out, std::move(in));
239
8
    return out;
240
8
}
241
242
136k
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
136k
    out->set_rowset_id(in.rowset_id());
245
136k
    out->set_partition_id(in.partition_id());
246
136k
    out->set_tablet_id(in.tablet_id());
247
136k
    out->set_txn_id(in.txn_id());
248
136k
    out->set_tablet_schema_hash(in.tablet_schema_hash());
249
136k
    out->set_rowset_type(in.rowset_type());
250
136k
    out->set_rowset_state(in.rowset_state());
251
136k
    out->set_start_version(in.start_version());
252
136k
    out->set_end_version(in.end_version());
253
136k
    out->set_version_hash(in.version_hash());
254
136k
    out->set_num_rows(in.num_rows());
255
136k
    out->set_total_disk_size(in.total_disk_size());
256
136k
    out->set_data_disk_size(in.data_disk_size());
257
136k
    out->set_index_disk_size(in.index_disk_size());
258
136k
    out->mutable_zone_maps()->CopyFrom(in.zone_maps());
259
136k
    if (in.has_delete_predicate()) {
260
96
        out->mutable_delete_predicate()->CopyFrom(in.delete_predicate());
261
96
    }
262
136k
    out->set_empty(in.empty());
263
136k
    if (in.has_load_id()) {
264
13.4k
        out->mutable_load_id()->CopyFrom(in.load_id());
265
13.4k
    }
266
136k
    out->set_delete_flag(in.delete_flag());
267
136k
    out->set_creation_time(in.creation_time());
268
136k
    if (in.has_tablet_uid()) {
269
1
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
270
1
    }
271
136k
    out->set_num_segments(in.num_segments());
272
136k
    out->set_rowset_id_v2(in.rowset_id_v2());
273
136k
    out->set_resource_id(in.resource_id());
274
136k
    out->set_newest_write_timestamp(in.newest_write_timestamp());
275
136k
    out->mutable_segments_key_bounds()->CopyFrom(in.segments_key_bounds());
276
136k
    if (in.has_tablet_schema()) {
277
135k
        cloud_tablet_schema_to_doris(out->mutable_tablet_schema(), in.tablet_schema());
278
135k
    }
279
136k
    if (in.has_schema_dict_key_list()) {
280
1.16k
        out->mutable_schema_dict_key_list()->CopyFrom(in.schema_dict_key_list());
281
1.16k
    }
282
136k
    out->set_txn_expiration(in.txn_expiration());
283
136k
    out->set_segments_overlap_pb(in.segments_overlap_pb());
284
136k
    if (in.has_segments_key_bounds_truncated()) {
285
14.2k
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
286
14.2k
    }
287
136k
    if (in.has_segments_key_bounds_aggregated()) {
288
14.2k
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
289
14.2k
    }
290
136k
    out->mutable_num_segment_rows()->CopyFrom(in.num_segment_rows());
291
136k
    out->mutable_segments_file_size()->CopyFrom(in.segments_file_size());
292
136k
    out->set_index_id(in.index_id());
293
136k
    if (in.has_schema_version()) {
294
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
295
135k
        out->set_schema_version(in.schema_version());
296
135k
    }
297
136k
    out->set_enable_segments_file_size(in.enable_segments_file_size());
298
136k
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
299
136k
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
300
136k
    out->set_compaction_level(in.compaction_level());
301
136k
    out->mutable_inverted_index_file_info()->CopyFrom(in.inverted_index_file_info());
302
136k
    out->set_source_rowset_id(in.source_rowset_id());
303
136k
    out->set_source_tablet_id(in.source_tablet_id());
304
136k
    if (in.has___split_schema()) {
305
1
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
306
1
    }
307
136k
    if (in.has_visible_ts_ms()) {
308
14.2k
        out->set_visible_ts_ms(in.visible_ts_ms());
309
14.2k
    }
310
136k
    if (in.has_reference_instance_id()) {
311
1
        out->set_reference_instance_id(in.reference_instance_id());
312
1
    }
313
136k
    auto* slice_locations = out->mutable_packed_slice_locations();
314
136k
    slice_locations->clear();
315
136k
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
316
136k
    if (in.has_is_recycled()) {
317
1
        out->set_is_recycled(in.is_recycled());
318
1
    }
319
136k
    if (in.has_job_id()) {
320
14.2k
        out->set_job_id(in.job_id());
321
14.2k
    }
322
136k
    if (in.has_commit_tso()) {
323
695
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
324
695
    }
325
136k
    if (in.has_is_row_binlog()) {
326
1
        out->set_is_row_binlog(in.is_row_binlog());
327
1
    }
328
136k
    if (in.has_db_id()) {
329
14.2k
        out->set_db_id(in.db_id());
330
14.2k
    }
331
136k
    if (in.has_table_id()) {
332
14.2k
        out->set_table_id(in.table_id());
333
14.2k
    }
334
136k
}
335
336
12
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
12
    out->set_rowset_id(in.rowset_id());
339
12
    out->set_partition_id(in.partition_id());
340
12
    out->set_tablet_id(in.tablet_id());
341
12
    out->set_txn_id(in.txn_id());
342
12
    out->set_tablet_schema_hash(in.tablet_schema_hash());
343
12
    out->set_rowset_type(in.rowset_type());
344
12
    out->set_rowset_state(in.rowset_state());
345
12
    out->set_start_version(in.start_version());
346
12
    out->set_end_version(in.end_version());
347
12
    out->set_version_hash(in.version_hash());
348
12
    out->set_num_rows(in.num_rows());
349
12
    out->set_total_disk_size(in.total_disk_size());
350
12
    out->set_data_disk_size(in.data_disk_size());
351
12
    out->set_index_disk_size(in.index_disk_size());
352
12
    out->mutable_zone_maps()->Swap(in.mutable_zone_maps());
353
12
    if (in.has_delete_predicate()) {
354
2
        out->mutable_delete_predicate()->Swap(in.mutable_delete_predicate());
355
2
    }
356
12
    out->set_empty(in.empty());
357
12
    if (in.has_load_id()) {
358
2
        out->mutable_load_id()->CopyFrom(in.load_id());
359
2
    }
360
12
    out->set_delete_flag(in.delete_flag());
361
12
    out->set_creation_time(in.creation_time());
362
12
    if (in.has_tablet_uid()) {
363
2
        out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
364
2
    }
365
12
    out->set_num_segments(in.num_segments());
366
12
    out->set_rowset_id_v2(in.rowset_id_v2());
367
12
    out->set_resource_id(in.resource_id());
368
12
    out->set_newest_write_timestamp(in.newest_write_timestamp());
369
12
    out->mutable_segments_key_bounds()->Swap(in.mutable_segments_key_bounds());
370
12
    if (in.has_tablet_schema()) {
371
8
        cloud_tablet_schema_to_doris(out->mutable_tablet_schema(),
372
8
                                     std::move(*in.mutable_tablet_schema()));
373
8
    }
374
12
    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
12
    out->set_txn_expiration(in.txn_expiration());
378
12
    out->set_segments_overlap_pb(in.segments_overlap_pb());
379
12
    if (in.has_segments_key_bounds_truncated()) {
380
8
        out->set_segments_key_bounds_truncated(in.segments_key_bounds_truncated());
381
8
    }
382
12
    if (in.has_segments_key_bounds_aggregated()) {
383
8
        out->set_segments_key_bounds_aggregated(in.segments_key_bounds_aggregated());
384
8
    }
385
12
    out->mutable_num_segment_rows()->Swap(in.mutable_num_segment_rows());
386
12
    out->mutable_segments_file_size()->Swap(in.mutable_segments_file_size());
387
12
    out->set_index_id(in.index_id());
388
12
    if (in.has_schema_version()) {
389
        // See cloud/src/meta-service/meta_service_schema.cpp for details.
390
8
        out->set_schema_version(in.schema_version());
391
8
    }
392
12
    out->set_enable_segments_file_size(in.enable_segments_file_size());
393
12
    out->set_has_variant_type_in_schema(in.has_variant_type_in_schema());
394
12
    out->set_enable_inverted_index_file_info(in.enable_inverted_index_file_info());
395
12
    out->set_compaction_level(in.compaction_level());
396
12
    out->mutable_inverted_index_file_info()->Swap(in.mutable_inverted_index_file_info());
397
12
    out->set_source_rowset_id(in.source_rowset_id());
398
12
    out->set_source_tablet_id(in.source_tablet_id());
399
12
    if (in.has___split_schema()) {
400
2
        out->mutable___split_schema()->Swap(in.mutable___split_schema());
401
2
    }
402
12
    if (in.has_visible_ts_ms()) {
403
2
        out->set_visible_ts_ms(in.visible_ts_ms());
404
2
    }
405
12
    if (in.has_reference_instance_id()) {
406
2
        out->set_reference_instance_id(in.reference_instance_id());
407
2
    }
408
12
    auto* slice_locations = out->mutable_packed_slice_locations();
409
12
    slice_locations->clear();
410
12
    slice_locations->insert(in.packed_slice_locations().begin(), in.packed_slice_locations().end());
411
12
    if (in.has_is_recycled()) {
412
2
        out->set_is_recycled(in.is_recycled());
413
2
    }
414
12
    if (in.has_job_id()) {
415
8
        out->set_job_id(in.job_id());
416
8
    }
417
12
    if (in.has_commit_tso()) {
418
2
        out->mutable_commit_tso()->CopyFrom(in.commit_tso());
419
2
    }
420
12
    if (in.has_is_row_binlog()) {
421
2
        out->set_is_row_binlog(in.is_row_binlog());
422
2
    }
423
12
    if (in.has_db_id()) {
424
8
        out->set_db_id(in.db_id());
425
8
    }
426
12
    if (in.has_table_id()) {
427
8
        out->set_table_id(in.table_id());
428
8
    }
429
12
}
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
190k
void doris_tablet_schema_to_cloud(TabletSchemaCloudPB* out, TabletSchemaPB&& in) {
495
190k
    out->set_keys_type(in.keys_type());
496
190k
    out->mutable_column()->Swap(in.mutable_column());
497
190k
    out->set_num_short_key_columns(in.num_short_key_columns());
498
190k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
499
190k
    out->set_compress_kind(in.compress_kind());
500
190k
    out->set_bf_fpp(in.bf_fpp());
501
190k
    out->set_next_column_unique_id(in.next_column_unique_id());
502
190k
    out->set_delete_sign_idx(in.delete_sign_idx());
503
190k
    out->set_sequence_col_idx(in.sequence_col_idx());
504
190k
    out->set_sort_type(in.sort_type());
505
190k
    out->set_sort_col_num(in.sort_col_num());
506
190k
    out->set_compression_type(in.compression_type());
507
190k
    out->set_schema_version(in.schema_version());
508
190k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
509
190k
    out->mutable_index()->Swap(in.mutable_index());
510
190k
    out->set_version_col_idx(in.version_col_idx());
511
190k
    out->set_store_row_column(in.store_row_column());
512
190k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
513
190k
    out->mutable_cluster_key_uids()->Swap(in.mutable_cluster_key_uids());
514
190k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
515
190k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
516
190k
    out->mutable_row_store_column_unique_ids()->Swap(in.mutable_row_store_column_unique_ids());
517
190k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
518
190k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
519
190k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
520
190k
    out->set_storage_page_size(in.storage_page_size());
521
190k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
522
190k
    out->set_is_in_memory(in.is_in_memory());
523
190k
    out->set_row_store_page_size(in.row_store_page_size());
524
190k
    if (in.has_integer_type_default_use_plain_encoding()) {
525
102k
        out->set_integer_type_default_use_plain_encoding(
526
102k
                in.integer_type_default_use_plain_encoding());
527
102k
    }
528
190k
    if (in.has_binary_plain_encoding_default_impl()) {
529
103k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
530
103k
    }
531
190k
    if (in.has_storage_format()) {
532
188k
        out->set_storage_format(in.storage_format());
533
188k
    }
534
190k
    if (in.has_seq_map()) {
535
185k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
536
185k
    }
537
538
190k
    if (in.has___split_schema()) {
539
6
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
540
6
    }
541
190k
}
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
136k
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
136k
    out->set_keys_type(in.keys_type());
558
136k
    out->mutable_column()->CopyFrom(in.column());
559
136k
    out->set_num_short_key_columns(in.num_short_key_columns());
560
136k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
561
136k
    out->set_compress_kind(in.compress_kind());
562
136k
    out->set_bf_fpp(in.bf_fpp());
563
136k
    out->set_next_column_unique_id(in.next_column_unique_id());
564
136k
    out->set_delete_sign_idx(in.delete_sign_idx());
565
136k
    out->set_sequence_col_idx(in.sequence_col_idx());
566
136k
    out->set_sort_type(in.sort_type());
567
136k
    out->set_sort_col_num(in.sort_col_num());
568
136k
    out->set_compression_type(in.compression_type());
569
136k
    out->set_schema_version(in.schema_version());
570
136k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
571
136k
    out->mutable_index()->CopyFrom(in.index());
572
136k
    out->set_version_col_idx(in.version_col_idx());
573
136k
    out->set_store_row_column(in.store_row_column());
574
136k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
575
136k
    out->mutable_cluster_key_uids()->CopyFrom(in.cluster_key_uids());
576
136k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
577
136k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
578
136k
    out->mutable_row_store_column_unique_ids()->CopyFrom(in.row_store_column_unique_ids());
579
136k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
580
136k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
581
136k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
582
136k
    out->set_storage_page_size(in.storage_page_size());
583
136k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
584
136k
    out->set_is_in_memory(in.is_in_memory());
585
136k
    out->set_row_store_page_size(in.row_store_page_size());
586
136k
    if (in.has_integer_type_default_use_plain_encoding()) {
587
62.4k
        out->set_integer_type_default_use_plain_encoding(
588
62.4k
                in.integer_type_default_use_plain_encoding());
589
62.4k
    }
590
136k
    if (in.has_binary_plain_encoding_default_impl()) {
591
62.6k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
592
62.6k
    }
593
136k
    if (in.has_storage_format()) {
594
136k
        out->set_storage_format(in.storage_format());
595
136k
    }
596
136k
    if (in.has_seq_map()) {
597
135k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
598
135k
    }
599
600
136k
    if (in.has___split_schema()) {
601
4
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
602
4
    }
603
136k
}
604
605
329k
void cloud_tablet_schema_to_doris(TabletSchemaPB* out, TabletSchemaCloudPB&& in) {
606
    // ATTN: please keep the set order aligned with the definition of proto.
607
329k
    out->set_keys_type(in.keys_type());
608
329k
    out->mutable_column()->Swap(in.mutable_column());
609
329k
    out->set_num_short_key_columns(in.num_short_key_columns());
610
329k
    out->set_num_rows_per_row_block(in.num_rows_per_row_block());
611
329k
    out->set_compress_kind(in.compress_kind());
612
329k
    out->set_bf_fpp(in.bf_fpp());
613
329k
    out->set_next_column_unique_id(in.next_column_unique_id());
614
329k
    out->set_delete_sign_idx(in.delete_sign_idx());
615
329k
    out->set_sequence_col_idx(in.sequence_col_idx());
616
329k
    out->set_sort_type(in.sort_type());
617
329k
    out->set_sort_col_num(in.sort_col_num());
618
329k
    out->set_compression_type(in.compression_type());
619
329k
    out->set_schema_version(in.schema_version());
620
329k
    out->set_disable_auto_compaction(in.disable_auto_compaction());
621
329k
    out->mutable_index()->Swap(in.mutable_index());
622
329k
    out->set_version_col_idx(in.version_col_idx());
623
329k
    out->set_store_row_column(in.store_row_column());
624
329k
    out->set_skip_write_index_on_load(in.skip_write_index_on_load());
625
329k
    out->mutable_cluster_key_uids()->Swap(in.mutable_cluster_key_uids());
626
329k
    out->set_is_dynamic_schema(in.is_dynamic_schema());
627
329k
    out->set_is_external_segment_column_meta_used(in.is_external_segment_column_meta_used());
628
329k
    out->mutable_row_store_column_unique_ids()->Swap(in.mutable_row_store_column_unique_ids());
629
329k
    out->set_inverted_index_storage_format(in.inverted_index_storage_format());
630
329k
    out->set_enable_variant_flatten_nested(in.enable_variant_flatten_nested());
631
329k
    out->set_skip_bitmap_col_idx(in.skip_bitmap_col_idx());
632
329k
    out->set_storage_page_size(in.storage_page_size());
633
329k
    out->set_storage_dict_page_size(in.storage_dict_page_size());
634
329k
    out->set_is_in_memory(in.is_in_memory());
635
329k
    out->set_row_store_page_size(in.row_store_page_size());
636
329k
    if (in.has_integer_type_default_use_plain_encoding()) {
637
148k
        out->set_integer_type_default_use_plain_encoding(
638
148k
                in.integer_type_default_use_plain_encoding());
639
148k
    }
640
329k
    if (in.has_binary_plain_encoding_default_impl()) {
641
148k
        out->set_binary_plain_encoding_default_impl(in.binary_plain_encoding_default_impl());
642
148k
    }
643
329k
    if (in.has_storage_format()) {
644
328k
        out->set_storage_format(in.storage_format());
645
328k
    }
646
329k
    if (in.has_seq_map()) {
647
327k
        out->mutable_seq_map()->CopyFrom(in.seq_map());
648
327k
    }
649
650
329k
    if (in.has___split_schema()) {
651
6
        out->mutable___split_schema()->CopyFrom(in.__split_schema());
652
6
    }
653
329k
}
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
329k
TabletMetaPB cloud_tablet_meta_to_doris(TabletMetaCloudPB&& in) {
854
329k
    TabletMetaPB out;
855
329k
    cloud_tablet_meta_to_doris(&out, std::move(in));
856
329k
    return out;
857
329k
}
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
329k
void cloud_tablet_meta_to_doris(TabletMetaPB* out, TabletMetaCloudPB&& in) {
946
    // ATTN: please keep the set order aligned with the definition of proto.
947
329k
    out->set_table_id(in.table_id());
948
329k
    out->set_partition_id(in.partition_id());
949
329k
    out->set_tablet_id(in.tablet_id());
950
329k
    out->set_schema_hash(in.schema_hash());
951
329k
    out->set_shard_id(in.shard_id());
952
329k
    out->set_creation_time(in.creation_time());
953
329k
    out->set_cumulative_layer_point(in.cumulative_layer_point());
954
329k
    out->set_tablet_state(in.tablet_state());
955
329k
    if (in.has_schema()) {
956
328k
        cloud_tablet_schema_to_doris(out->mutable_schema(), std::move(*in.mutable_schema()));
957
328k
    }
958
329k
    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
329k
    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
329k
    if (in.has_alter_task()) {
975
1
        out->mutable_alter_task()->Swap(in.mutable_alter_task());
976
1
    }
977
329k
    out->set_in_restore_mode(in.in_restore_mode());
978
329k
    out->mutable_tablet_uid()->CopyFrom(in.tablet_uid());
979
329k
    out->set_end_rowset_id(in.end_rowset_id());
980
329k
    out->set_preferred_rowset_type(in.preferred_rowset_type());
981
329k
    out->set_tablet_type(in.tablet_type());
982
329k
    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
329k
    out->set_replica_id(in.replica_id());
991
329k
    if (in.has_delete_bitmap()) {
992
1
        out->mutable_delete_bitmap()->Swap(in.mutable_delete_bitmap());
993
1
    }
994
329k
    out->set_enable_unique_key_merge_on_write(in.enable_unique_key_merge_on_write());
995
329k
    out->set_storage_policy_id(in.storage_policy_id());
996
329k
    out->mutable_cooldown_meta_id()->CopyFrom(in.cooldown_meta_id());
997
329k
    if (in.has_binlog_config()) {
998
1
        out->mutable_binlog_config()->Swap(in.mutable_binlog_config());
999
1
    }
1000
329k
    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
329k
    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
329k
    if (in.has_row_binlog_schema_hash()) {
1013
1
        out->set_row_binlog_schema_hash(in.row_binlog_schema_hash());
1014
1
    }
1015
329k
    out->set_compaction_policy(in.compaction_policy());
1016
329k
    out->set_time_series_compaction_goal_size_mbytes(in.time_series_compaction_goal_size_mbytes());
1017
329k
    out->set_time_series_compaction_file_count_threshold(
1018
329k
            in.time_series_compaction_file_count_threshold());
1019
329k
    out->set_time_series_compaction_time_threshold_seconds(
1020
329k
            in.time_series_compaction_time_threshold_seconds());
1021
329k
    out->set_time_series_compaction_empty_rowsets_threshold(
1022
329k
            in.time_series_compaction_empty_rowsets_threshold());
1023
329k
    out->set_time_series_compaction_level_threshold(in.time_series_compaction_level_threshold());
1024
329k
    out->set_vertical_compaction_num_columns_per_group(
1025
329k
            in.vertical_compaction_num_columns_per_group());
1026
329k
    out->set_index_id(in.index_id());
1027
329k
    out->set_is_in_memory(in.is_in_memory());
1028
329k
    out->set_is_persistent(in.is_persistent());
1029
329k
    out->set_table_name(in.table_name());
1030
329k
    out->set_ttl_seconds(in.ttl_seconds());
1031
329k
    if (in.has_schema_version()) {
1032
328k
        out->set_schema_version(in.schema_version());
1033
328k
    }
1034
329k
    if (in.has_encryption_algorithm()) {
1035
328k
        out->set_encryption_algorithm(in.encryption_algorithm());
1036
328k
    }
1037
329k
}
1038
1039
} // namespace doris::cloud