8000 [Refactor] rename aggregate/shared prefix to bundle by luohaha · Pull Request #60057 · StarRocks/starrocks · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

[Refactor] rename aggregate/shared prefix to bundle #60057

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Jun 19, 2025
Merged

[Refactor] rename aggregate/shared prefix to bundle #60057

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
603817b
[Refactor] rename aggregate/shared prefix to bundle
luohaha Jun 19, 2025
cdb9cbb
update
luohaha Jun 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 2 additions & 4 deletions be/src/service/service_be/lake_service.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -339,13 +339,11 @@ struct AggregatePublishContext {
} else {
auto latch = BThreadCountDownLatch(1);
auto task = std::make_shared<AutoCleanRunnable>(
[&] {
publish_status = env->lake_tablet_manager()->put_aggregate_tablet_metadata(tablet_metas);
},
[&] { publish_status = env->lake_tablet_manager()->put_bundle_tablet_metadata(tablet_metas); },
[&] { latch.count_down(); });
Status submit_st = thread_pool->submit(std::move(task));
if (!submit_st.ok()) {
LOG(WARNING) << "Fail to submit put_aggregate_tablet_metadata task";
LOG(WARNING) << "Fail to submit put_bundle_tablet_metadata task";
publish_status = submit_st;
}
latch.wait();
Expand Down
2 changes: 1 addition & 1 deletion be/src/storage/lake/location_provider.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ class LocationProvider {
return join_path(metadata_root_location(tablet_id), tablet_initial_metadata_filename());
}

std::string aggregate_tablet_metadata_location(int64_t tablet_id, int64_t version) const {
std::string bundle_tablet_metadata_location(int64_t tablet_id, int64_t version) const {
return join_path(metadata_root_location(tablet_id), tablet_metadata_filename(0, version));
}

Expand Down
4 changes: 2 additions & 2 deletions be/src/storage/lake/schema_change.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -470,8 +470,8 @@ Status SchemaChangeHandler::do_process_update_tablet_meta(const TTabletMetaInfo&

// TODO(zhangqiang)
// aggregate alter txn log
if (tablet_meta_info.__isset.aggregate_tablet_metadata) {
metadata_update_info->set_aggregate_tablet_metadata(tablet_meta_info.aggregate_tablet_metadata);
if (tablet_meta_info.__isset.bundle_tablet_metadata) {
metadata_update_info->set_bundle_tablet_metadata(tablet_meta_info.bundle_tablet_metadata);
}

RETURN_IF_ERROR(tablet.put_txn_log(std::move(txn_log)));
Expand Down
56 changes: 28 additions & 28 deletions be/src/storage/lake/tablet_manager.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -94,8 +94,8 @@ std::string TabletManager::tablet_initial_metadata_location(int64_t tablet_id) c
return _location_provider->tablet_initial_metadata_location(tablet_id);
}

std::string TabletManager::aggregate_tablet_metadata_location(int64_t tablet_id, int64_t version) const {
return _location_provider->aggregate_tablet_metadata_location(tablet_id, version);
std::string TabletManager::bundle_tablet_metadata_location(int64_t tablet_id, int64_t version) const {
return _location_provider->bundle_tablet_metadata_location(tablet_id, version);
}

std::string TabletManager::txn_log_location(int64_t tablet_id, int64_t txn_id) const {
Expand Down Expand Up @@ -282,24 +282,24 @@ Status TabletManager::put_tablet_metadata(const TabletMetadata& metadata) {

// NOTE: tablet_metas is non-const and we will clear schemas for optimization.
// Callers should ensure thread safety.
Status TabletManager::put_aggregate_tablet_metadata(std::map<int64_t, TabletMetadataPB>& tablet_metas) {
Status TabletManager::put_bundle_tablet_metadata(std::map<int64_t, TabletMetadataPB>& tablet_metas) {
if (tablet_metas.empty()) {
return Status::InternalError("tablet_metas cannot be empty");
}

SharedTabletMetadataPB shared_meta;
BundleTabletMetadataPB bundle_meta;
auto partition_location = tablet_metadata_root_location(tablet_metas.begin()->first);
std::unordered_map<int64_t, TabletSchemaPB> unique_schemas;
for (auto& [tablet_id, meta] : tablet_metas) {
(*shared_meta.mutable_tablet_to_schema())[tablet_id] = meta.schema().id();
(*bundle_meta.mutable_tablet_to_schema())[tablet_id] = meta.schema().id();
unique_schemas.emplace(meta.schema().id(), meta.schema());
for (const auto& [schema_id, schema] : meta.historical_schemas()) {
unique_schemas.emplace(schema_id, schema);
}
}

for (auto& [schema_id, schema] : unique_schemas) {
(*shared_meta.mutable_schemas())[schema_id] = std::move(schema);
(*bundle_meta.mutable_schemas())[schema_id] = std::move(schema);
}

auto make_page_pointer = [](int64_t offset, int64_t size) {
Expand All @@ -310,7 +310,7 @@ Status TabletManager::put_aggregate_tablet_metadata(std::map<int64_t, TabletMeta
};

const std::string meta_location =
aggregate_tablet_metadata_location(tablet_metas.begin()->first, tablet_metas.begin()->second.version());
bundle_tablet_metadata_location(tablet_metas.begin()->first, tablet_metas.begin()->second.version());

ASSIGN_OR_RETURN(auto fs, FileSystem::CreateSharedFromString(meta_location));
WritableFileOptions opts{.sync_on_close = true, .mode = FileSystem::CREATE_OR_OPEN_WITH_TRUNCATE};
Expand All @@ -325,14 +325,14 @@ Status TabletManager::put_aggregate_tablet_metadata(std::map<int64_t, TabletMeta
return Status::InternalError("Failed to serialize tablet metadata");
}

(*shared_meta.mutable_tablet_meta_pages())[tablet_id] =
(*bundle_meta.mutable_tablet_meta_pages())[tablet_id] =
make_page_pointer(current_offset, serialized_buf.size());
RETURN_IF_ERROR(meta_file->append(Slice(serialized_buf)));
current_offset += serialized_buf.size();
}

serialized_buf.clear();
if (!shared_meta.SerializeToString(&serialized_buf)) {
if (!bundle_meta.SerializeToString(&serialized_buf)) {
return Status::IOError("Failed to write shared metadata header");
}
RETURN_IF_ERROR(meta_file->append(Slice(serialized_buf)));
Expand Down Expand Up @@ -462,7 +462,7 @@ StatusOr<TabletMetadataPtr> TabletManager::get_tablet_metadata(const string& pat
return metadata_or.value();
}

DEFINE_FAIL_POINT(tablet_schema_not_found_in_shared_metadata);
DEFINE_FAIL_POINT(tablet_schema_not_found_in_bundle_metadata);
StatusOr<TabletMetadataPtr> TabletManager::get_single_tablet_metadata(int64_t tablet_id, int64_t version,
bool fill_cache, int64_t expecte 6D40 d_gtid,
const std::shared_ptr<FileSystem>& fs) {
Expand All @@ -473,7 +473,7 @@ StatusOr<TabletMetadataPtr> TabletManager::get_single_tablet_metadata(int64_t ta
if (version == kInitialVersion) {
return Status::NotFound("Not found expected tablet metadata");
}
auto path = aggregate_tablet_metadata_location(tablet_id, version);
auto path = bundle_tablet_metadata_location(tablet_id, version);
std::shared_ptr<FileSystem> file_system;
if (!fs) {
ASSIGN_OR_RETURN(file_system, FileSystem::CreateSharedFromString(path));
Expand All @@ -490,24 +490,24 @@ StatusOr<TabletMetadataPtr> TabletManager::get_single_tablet_metadata(int64_t ta

auto file_size = serialized_string.size();
auto footer_size = sizeof(uint64_t);
auto shared_metadata_size = decode_fixed64_le((uint8_t*)(serialized_string.data() + file_size - footer_size));
if (file_size < footer_size + shared_metadata_size) {
auto bundle_metadata_size = decode_fixed64_le((uint8_t*)(serialized_string.data() + file_size - footer_size));
if (file_size < footer_size + bundle_metadata_size) {
return Status::Corruption(
strings::Substitute("deserialized shared metadata($0) failed, file_size($1) < shared_metadata_size($2)",
path, file_size, shared_metadata_size + footer_size));
strings::Substitute("deserialized shared metadata($0) failed, file_size($1) < bundle_metadata_size($2)",
path, file_size, bundle_metadata_size + footer_size));
}

auto shared_metadata = std::make_shared<SharedTabletMetadataPB>();
std::string_view shared_metadata_str =
std::string_view(serialized_string.data() + file_size - footer_size - shared_metadata_size);
if (!shared_metadata->ParseFromArray(shared_metadata_str.data(), shared_metadata_size)) {
auto bundle_metadata = std::make_shared<BundleTabletMetadataPB>();
std::string_view bundle_metadata_str =
std::string_view(serialized_string.data() + file_size - footer_size - bundle_metadata_size);
if (!bundle_metadata->ParseFromArray(bundle_metadata_str.data(), bundle_metadata_size)) {
return Status::Corruption(strings::Substitute("deserialized shared metadata failed"));
}

auto meta_it = shared_metadata->tablet_meta_pages().find(tablet_id);
auto meta_it = bundle_metadata->tablet_meta_pages().find(tablet_id);
size_t offset = 0;
size_t size = 0;
if (meta_it == shared_metadata->tablet_meta_pages().end()) {
if (meta_it == bundle_metadata->tablet_meta_pages().end()) {
return Status::Corruption(strings::Substitute("can not find tablet $0 from shared tablet metadata", tablet_id));
} else {
const PagePointerPB& page_pointer = meta_it->second;
Expand All @@ -530,14 +530,14 @@ StatusOr<TabletMetadataPtr> TabletManager::get_single_tablet_metadata(int64_t ta
return Status::Corruption(strings::Substitute("deserialized tablet $0 metadata failed", tablet_id));
}

FAIL_POINT_TRIGGER_EXECUTE(tablet_schema_not_found_in_shared_metadata, { tablet_id = 10003; });
auto schema_id = shared_metadata->tablet_to_schema().find(tablet_id);
if (schema_id == shared_metadata->tablet_to_schema().end()) {
FAIL_POINT_TRIGGER_EXECUTE(tablet_schema_not_found_in_bundle_metadata, { tablet_id = 10003; });
auto schema_id = bundle_metadata->tablet_to_schema().find(tablet_id);
if (schema_id == bundle_metadata->tablet_to_schema().end()) {
return Status::Corruption(
strings::Substitute("tablet $0 metadata can not find schema_id in shared metadata", tablet_id));
}
auto schema_it = shared_metadata->schemas().find(schema_id->second);
if (schema_it == shared_metadata->schemas().end()) {
auto schema_it = bundle_metadata->schemas().find(schema_id->second);
if (schema_it == bundle_metadata->schemas().end()) {
return Status::Corruption(strings::Substitute("tablet $0 metadata can not find schema($1) in shared metadata",
tablet_id, schema_id->second));
} else {
Expand All @@ -547,8 +547,8 @@ StatusOr<TabletMetadataPtr> TabletManager::get_single_tablet_metadata(int64_t ta
}

for (auto& [_, schema_id] : metadata->rowset_to_schema()) {
schema_it = shared_metadata->schemas().find(schema_id);
if (schema_it == shared_metadata->schemas().end()) {
schema_it = bundle_metadata->schemas().find(schema_id);
if (schema_it == bundle_metadata->schemas().end()) {
return Status::Corruption(strings::Substitute(
"tablet $0 metadata can not find schema($1) in shared metadata", tablet_id, schema_id));
} else {
Expand Down
4 changes: 2 additions & 2 deletions be/src/storage/lake/tablet_manager.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ class TabletManager {

Status cache_tablet_metadata(const TabletMetadataPtr& metadata);

Status put_aggregate_tablet_metadata(std::map<int64_t, TabletMetadataPB>& tablet_metas);
Status put_bundle_tablet_metadata(std::map<int64_t, TabletMetadataPB>& tablet_metas);

// When using get_tablet_metadata to determine whether a new version exists in publish version,
// a valid expected_gtid must be passed in.
Expand Down Expand Up @@ -161,7 +161,7 @@ class TabletManager {

std::string tablet_initial_metadata_location(int64_t tablet_id) const;

std::string aggregate_tablet_metadata_location(int64_t tablet_id, int64_t version) const;
std::string bundle_tablet_metadata_location(int64_t tablet_id, int64_t version) const;

std::string txn_log_location(int64_t tablet_id, int64_t txn_id) const;

Expand Down
1 change: 1 addition & 0 deletions be/src/storage/lake/tablet_metadata.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,5 +23,6 @@ namespace starrocks {
using TabletMetadata = TabletMetadataPB;
using TabletMetadataPtr = std::shared_ptr<const TabletMetadata>;
using MutableTabletMetadataPtr = std::shared_ptr<TabletMetadata>;
using BundleTabletMetadataPtr = std::shared_ptr<BundleTabletMetadataPB>;

} // namespace starrocks
2 changes: 1 addition & 1 deletion be/src/storage/lake/txn_log_applier.cpp
View file
Open in desktop
10000
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ Status apply_alter_meta_log(TabletMetadataPB* metadata, const TxnLogPB_OpAlterMe
metadata->mutable_schema()->CopyFrom(alter_meta.tablet_schema());
}

if (alter_meta.has_aggregate_tablet_metadata()) {
if (alter_meta.has_bundle_tablet_metadata()) {
// do nothing
}
}
Expand Down
8 changes: 4 additions & 4 deletions be/test/storage/lake/alter_tablet_meta_test.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -609,7 +609,7 @@ TEST_F(AlterTabletMetaTest, test_skip_load_pindex) {
}
}

TEST_F(AlterTabletMetaTest, test_aggregate_tablet_metadata) {
TEST_F(AlterTabletMetaTest, test_bundle_tablet_metadata) {
lake::SchemaChangeHandler handler(_tablet_mgr.get());
TUpdateTabletMetaInfoReq update_tablet_meta_req;
int64_t txn_id = next_id();
Expand All @@ -618,16 +618,16 @@ TEST_F(AlterTabletMetaTest, test_aggregate_tablet_metadata) {
TTabletMetaInfo tablet_meta_info;
auto tablet_id = _tablet_metadata->id();
tablet_meta_info.__set_tablet_id(tablet_id);
tablet_meta_info.__set_aggregate_tablet_metadata(true);
tablet_meta_info.__set_bundle_tablet_metadata(true);

update_tablet_meta_req.tabletMetaInfos.push_back(tablet_meta_info);
ASSERT_OK(handler.process_update_tablet_meta(update_tablet_meta_req));

ASSIGN_OR_ABORT(auto txn_log, _tablet_mgr->get_txn_log(tablet_id, txn_id));
ASSERT_TRUE(txn_log->has_op_alter_metadata());
for (const auto& alter_meta : txn_log->op_alter_metadata().metadata_update_infos()) {
ASSERT_TRUE(alter_meta.has_aggregate_tablet_metadata());
ASSERT_TRUE(alter_meta.aggregate_tablet_metadata());
ASSERT_TRUE(alter_meta.has_bundle_tablet_metadata());
ASSERT_TRUE(alter_meta.bundle_tablet_metadata());
}
auto new_tablet_meta = publish_single_version(tablet_id, 2, txn_id);
ASSERT_OK(new_tablet_meta.status());
Expand Down
6 changes: 3 additions & 3 deletions be/test/storage/lake/tablet_manager_test.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -575,7 +575,7 @@ TEST_F(LakeTabletManagerTest, create_tablet_with_cloud_native_persistent_index)
EXPECT_EQ(TPersistentIndexType::CLOUD_NATIVE, metadata->persistent_index_type());
}

TEST_F(LakeTabletManagerTest, put_aggregate_tablet_metadata) {
TEST_F(LakeTabletManagerTest, put_bundle_tablet_metadata) {
std::map<int64_t, TabletMetadataPB> metadatas;
TabletSchemaPB schema_pb1;
{
Expand Down Expand Up @@ -646,7 +646,7 @@ TEST_F(LakeTabletManagerTest, put_aggregate_tablet_metadata) {

metadatas.emplace(1, metadata1);
metadatas.emplace(2, metadata2);
EXPECT_OK(_tablet_manager->put_aggregate_tablet_metadata(metadatas));
EXPECT_OK(_tablet_manager->put_bundle_tablet_metadata(metadatas));

{
auto res = _tablet_manager->get_tablet_metadata(1, 2);
Expand All @@ -657,7 +657,7 @@ TEST_F(LakeTabletManagerTest, put_aggregate_tablet_metadata) {
}

{
std::string fp_name = "tablet_schema_not_found_in_shared_metadata";
std::string fp_name = "tablet_schema_not_found_in_bundle_metadata";
auto fp = starrocks::failpoint::FailPointRegistry::GetInstance()->get(fp_name);
PFailPointTriggerMode trigger_mode;
trigger_mode.set_mode(FailPointTriggerModeType::ENABLE);
Expand Down
2 changes: 1 addition & 1 deletion be/test/storage/lake/test_util.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -174,7 +174,7 @@ inline Status TEST_aggregate_publish_version(TabletManager* tablet_mgr, std::vec
for (const auto& meta : response.tablet_metas()) {
tablet_metas.emplace(meta.first, meta.second);
}
return tablet_mgr->put_aggregate_tablet_metadata(tablet_metas);
return tablet_mgr->put_bundle_tablet_metadata(tablet_metas);
} else {
return Status::InternalError(fmt::format("failed to publish version. tablet_sz={} txn_id={} new_version={}",
tablet_ids.size(), txn_id, new_version));
Expand Down
16 changes: 8 additions & 8 deletions be/test/storage/lake/vacuum_test.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1635,7 +1635,7 @@ TEST(LakeVacuumTest2, test_delete_files_retry4) {
EXPECT_GT(attempts, 1);
}

TEST_P(LakeVacuumTest, test_vacuum_shared_metadata) {
TEST_P(LakeVacuumTest, test_vacuum_bundle_metadata) {
create_data_file("00000000000259e4_27dc159f-6bfc-4a3a-9d9c-c97c10bb2e1d.dat");
create_data_file("00000000000259e4_27dc159f-6bfc-4a3a-9d9c-c97c10bb2e1e.dat");
create_data_file("00000000000259e4_a542395a-bff5-48a7-a3a7-2ed05691b58c.dat");
Expand Down Expand Up @@ -1730,17 +1730,17 @@ TEST_P(LakeVacuumTest, test_vacuum_shared_metadata) {
t600_v1->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v1[600] F438 = *t600_v1;
tablet_metas_v1[601] = *t601_v1;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v1));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v1));
std::map<int64_t, TabletMetadataPB> tablet_metas_v2;
t600_v2->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v2[600] = *t600_v2;
tablet_metas_v2[601] = *t601_v2;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v2));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v2));
std::map<int64_t, TabletMetadataPB> tablet_metas_v3;
t600_v3->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v3[600] = *t600_v3;
tablet_metas_v3[601] = *t601_v3;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v3));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v3));
auto* metacache = _tablet_mgr->metacache();
metacache->cache_tablet_metadata(_tablet_mgr->tablet_metadata_location(600, 1), t600_v1);
metacache->cache_tablet_metadata(_tablet_mgr->tablet_metadata_location(601, 1), t601_v1);
Expand Down Expand Up @@ -2013,17 +2013,17 @@ TEST_P(LakeVacuumTest, test_vacuum_shared_data_files) {
t600_v1->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v1[600] = *t600_v1;
tablet_metas_v1[601] = *t601_v1;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v1));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v1));
std::map<int64_t, TabletMetadataPB> tablet_metas_v2;
t600_v2->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v2[600] = *t600_v2;
tablet_metas_v2[601] = *t601_v2;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v2));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v2));
std::map<int64_t, TabletMetadataPB> tablet_metas_v3;
t600_v3->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v3[600] = *t600_v3;
tablet_metas_v3[601] = *t601_v3;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v3));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v3));
auto* metacache = _tablet_mgr->metacache();
metacache->cache_tablet_metadata(_tablet_mgr->tablet_metadata_location(600, 1), t600_v1);
metacache->cache_tablet_metadata(_tablet_mgr->tablet_metadata_location(601, 1), t601_v1);
Expand Down Expand Up @@ -2099,7 +2099,7 @@ TEST_P(LakeVacuumTest, test_vacuum_shared_data_files) {
t600_v4->mutable_schema()->CopyFrom(schema_pb1);
tablet_metas_v4[600] = *t600_v4;
tablet_metas_v4[601] = *t601_v4;
ASSERT_OK(_tablet_mgr->put_aggregate_tablet_metadata(tablet_metas_v4));
ASSERT_OK(_tablet_mgr->put_bundle_tablet_metadata(tablet_metas_v4));

// shared files will be deleted.
{
Expand Down
2 changes: 1 addition & 1 deletion fe/fe-core/src/main/java/com/starrocks/task/TabletMetadataUpdateAgentTaskFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,7 @@ public List<TTabletMetaInfo> getTTabletMetaInfoList() {
for (Long tabletId : tablets) {
TTabletMetaInfo metaInfo = new TTabletMetaInfo();
metaInfo.setTablet_id(tabletId);
metaInfo.setAggregate_tablet_metadata(enableFileBundling);
metaInfo.setBundle_tablet_metadata(enableFileBundling);
metaInfos.add(metaInfo);
}
return metaInfos;
Expand Down
4 changes: 2 additions & 2 deletions gensrc/proto/lake_types.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -163,10 +163,10 @@ message MetadataUpdateInfoPB {
optional bool enable_persistent_index = 1;
optional TabletSchemaPB tablet_schema = 2;
optional PersistentIndexTypePB persistent_index_type = 3;
optional bool aggregate_tablet_metadata = 4;
optional bool bundle_tablet_metadata = 4;
}

message SharedTabletMetadataPB {
message BundleTabletMetadataPB {
map<int64, int64> tablet_to_schema = 1; // tablet id -> schema id
map<int64, TabletSchemaPB> schemas = 2;
map<int64, PagePointerPB> tablet_meta_pages = 3;
Expand Down
2 changes: 1 addition & 1 deletion gensrc/thrift/AgentService.thrift
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -455,7 +455,7 @@ struct TTabletMetaInfo {
10: optional bool create_schema_file;
11: optional TPersistentIndexType persistent_index_type;
12: optional TFlatJsonConfig flat_json_config;
13: optional bool aggregate_tablet_metadata;
13: optional bool bundle_tablet_metadata;
}

struct TUpdateTabletMetaInfoReq {
Expand Down
Loading
0