Coverage Report

Created: 2026-06-07 12:43

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