feat: introduce ApplyStagingManifestRequest (#296)

Signed-off-by: WenyXu <wenymedia@gmail.com>

c++/greptime/v1/region/server.pb.cc

@@ -543,10 +543,38 @@ struct BuildIndexRequestDefaultTypeInternal {
   };
 };
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 BuildIndexRequestDefaultTypeInternal _BuildIndexRequest_default_instance_;
+PROTOBUF_CONSTEXPR FileMetas::FileMetas(
+    ::_pbi::ConstantInitialized): _impl_{
+    /*decltype(_impl_.data_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
+  , /*decltype(_impl_._cached_size_)*/{}} {}
+struct FileMetasDefaultTypeInternal {
+  PROTOBUF_CONSTEXPR FileMetasDefaultTypeInternal()
+      : _instance(::_pbi::ConstantInitialized{}) {}
+  ~FileMetasDefaultTypeInternal() {}
+  union {
+    FileMetas _instance;
+  };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FileMetasDefaultTypeInternal _FileMetas_default_instance_;
+PROTOBUF_CONSTEXPR ApplyStagingManifestRequest::ApplyStagingManifestRequest(
+    ::_pbi::ConstantInitialized): _impl_{
+    /*decltype(_impl_.partition_expr_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
+  , /*decltype(_impl_.files_to_add_)*/nullptr
+  , /*decltype(_impl_.region_id_)*/uint64_t{0u}
+  , /*decltype(_impl_._cached_size_)*/{}} {}
+struct ApplyStagingManifestRequestDefaultTypeInternal {
+  PROTOBUF_CONSTEXPR ApplyStagingManifestRequestDefaultTypeInternal()
+      : _instance(::_pbi::ConstantInitialized{}) {}
+  ~ApplyStagingManifestRequestDefaultTypeInternal() {}
+  union {
+    ApplyStagingManifestRequest _instance;
+  };
+};
+PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 ApplyStagingManifestRequestDefaultTypeInternal _ApplyStagingManifestRequest_default_instance_;
 }  // namespace region
 }  // namespace v1
 }  // namespace greptime
-static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[38];
+static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[40];
 static constexpr ::_pb::EnumDescriptor const** file_level_enum_descriptors_greptime_2fv1_2fregion_2fserver_2eproto = nullptr;
 static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fregion_2fserver_2eproto = nullptr;
 
@@ -594,6 +622,7 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR
   ::_pbi::kInvalidFieldOffsetTag,
   ::_pbi::kInvalidFieldOffsetTag,
   ::_pbi::kInvalidFieldOffsetTag,
+  ::_pbi::kInvalidFieldOffsetTag,
   PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionRequest, _impl_.body_),
   PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse_ExtensionsEntry_DoNotUse, _has_bits_),
   PROTOBUF_FIELD_OFFSET(::greptime::v1::region::RegionResponse_ExtensionsEntry_DoNotUse, _internal_metadata_),
@@ -893,46 +922,64 @@ const uint32_t TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets[] PR
   ~0u,  // no _weak_field_map_
   ~0u,  // no _inlined_string_donated_
   PROTOBUF_FIELD_OFFSET(::greptime::v1::region::BuildIndexRequest, _impl_.region_id_),
+  ~0u,  // no _has_bits_
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::FileMetas, _internal_metadata_),
+  ~0u,  // no _extensions_
+  ~0u,  // no _oneof_case_
+  ~0u,  // no _weak_field_map_
+  ~0u,  // no _inlined_string_donated_
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::FileMetas, _impl_.data_),
+  ~0u,  // no _has_bits_
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::ApplyStagingManifestRequest, _internal_metadata_),
+  ~0u,  // no _extensions_
+  ~0u,  // no _oneof_case_
+  ~0u,  // no _weak_field_map_
+  ~0u,  // no _inlined_string_donated_
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::ApplyStagingManifestRequest, _impl_.region_id_),
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::ApplyStagingManifestRequest, _impl_.partition_expr_),
+  PROTOBUF_FIELD_OFFSET(::greptime::v1::region::ApplyStagingManifestRequest, _impl_.files_to_add_),
 };
 static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
   { 0, 8, -1, sizeof(::greptime::v1::region::RegionRequestHeader_TracingContextEntry_DoNotUse)},
   { 10, -1, -1, sizeof(::greptime::v1::region::RegionRequestHeader)},
   { 19, -1, -1, sizeof(::greptime::v1::region::RegionRequest)},
-  { 44, 52, -1, sizeof(::greptime::v1::region::RegionResponse_ExtensionsEntry_DoNotUse)},
+  { 45, 53, -1, sizeof(::greptime::v1::region::RegionResponse_ExtensionsEntry_DoNotUse)},
-  { 54, -1, -1, sizeof(::greptime::v1::region::RegionResponse)},
+  { 55, -1, -1, sizeof(::greptime::v1::region::RegionResponse)},
-  { 64, -1, -1, sizeof(::greptime::v1::region::InsertRequests)},
+  { 65, -1, -1, sizeof(::greptime::v1::region::InsertRequests)},
-  { 71, -1, -1, sizeof(::greptime::v1::region::DeleteRequests)},
+  { 72, -1, -1, sizeof(::greptime::v1::region::DeleteRequests)},
-  { 78, -1, -1, sizeof(::greptime::v1::region::InsertRequest)},
+  { 79, -1, -1, sizeof(::greptime::v1::region::InsertRequest)},
-  { 86, -1, -1, sizeof(::greptime::v1::region::DeleteRequest)},
+  { 87, -1, -1, sizeof(::greptime::v1::region::DeleteRequest)},
-  { 94, -1, -1, sizeof(::greptime::v1::region::QueryRequest)},
+  { 95, -1, -1, sizeof(::greptime::v1::region::QueryRequest)},
-  { 103, -1, -1, sizeof(::greptime::v1::region::CreateRequests)},
+  { 104, -1, -1, sizeof(::greptime::v1::region::CreateRequests)},
-  { 110, 118, -1, sizeof(::greptime::v1::region::CreateRequest_OptionsEntry_DoNotUse)},
+  { 111, 119, -1, sizeof(::greptime::v1::region::CreateRequest_OptionsEntry_DoNotUse)},
-  { 120, -1, -1, sizeof(::greptime::v1::region::CreateRequest)},
+  { 121, -1, -1, sizeof(::greptime::v1::region::CreateRequest)},
-  { 133, -1, -1, sizeof(::greptime::v1::region::DropRequests)},
+  { 134, -1, -1, sizeof(::greptime::v1::region::DropRequests)},
-  { 140, -1, -1, sizeof(::greptime::v1::region::DropRequest)},
+  { 141, -1, -1, sizeof(::greptime::v1::region::DropRequest)},
-  { 148, 156, -1, sizeof(::greptime::v1::region::OpenRequest_OptionsEntry_DoNotUse)},
+  { 149, 157, -1, sizeof(::greptime::v1::region::OpenRequest_OptionsEntry_DoNotUse)},
-  { 158, -1, -1, sizeof(::greptime::v1::region::OpenRequest)},
+  { 159, -1, -1, sizeof(::greptime::v1::region::OpenRequest)},
-  { 168, -1, -1, sizeof(::greptime::v1::region::CloseRequest)},
+  { 169, -1, -1, sizeof(::greptime::v1::region::CloseRequest)},
-  { 175, -1, -1, sizeof(::greptime::v1::region::AlterRequests)},
+  { 176, -1, -1, sizeof(::greptime::v1::region::AlterRequests)},
-  { 182, -1, -1, sizeof(::greptime::v1::region::AlterRequest)},
+  { 183, -1, -1, sizeof(::greptime::v1::region::AlterRequest)},
-  { 203, -1, -1, sizeof(::greptime::v1::region::SyncColumns)},
+  { 204, -1, -1, sizeof(::greptime::v1::region::SyncColumns)},
-  { 210, -1, -1, sizeof(::greptime::v1::region::AddColumns)},
+  { 211, -1, -1, sizeof(::greptime::v1::region::AddColumns)},
-  { 217, -1, -1, sizeof(::greptime::v1::region::DropColumns)},
+  { 218, -1, -1, sizeof(::greptime::v1::region::DropColumns)},
-  { 224, -1, -1, sizeof(::greptime::v1::region::AddColumn)},
+  { 225, -1, -1, sizeof(::greptime::v1::region::AddColumn)},
-  { 232, -1, -1, sizeof(::greptime::v1::region::DropColumn)},
+  { 233, -1, -1, sizeof(::greptime::v1::region::DropColumn)},
-  { 239, -1, -1, sizeof(::greptime::v1::region::FlushRequest)},
+  { 240, -1, -1, sizeof(::greptime::v1::region::FlushRequest)},
-  { 246, -1, -1, sizeof(::greptime::v1::region::Regular)},
+  { 247, -1, -1, sizeof(::greptime::v1::region::Regular)},
-  { 252, -1, -1, sizeof(::greptime::v1::region::StrictWindow)},
+  { 253, -1, -1, sizeof(::greptime::v1::region::StrictWindow)},
-  { 259, -1, -1, sizeof(::greptime::v1::region::CompactRequest)},
+  { 260, -1, -1, sizeof(::greptime::v1::region::CompactRequest)},
-  { 270, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)},
+  { 271, -1, -1, sizeof(::greptime::v1::region::TruncateRequest)},
-  { 280, -1, -1, sizeof(::greptime::v1::region::All)},
+  { 281, -1, -1, sizeof(::greptime::v1::region::All)},
-  { 286, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)},
+  { 287, -1, -1, sizeof(::greptime::v1::region::RegionColumnDef)},
-  { 294, -1, -1, sizeof(::greptime::v1::region::BulkInsertRequest)},
+  { 295, -1, -1, sizeof(::greptime::v1::region::BulkInsertRequest)},
-  { 303, -1, -1, sizeof(::greptime::v1::region::MitoManifestInfo)},
+  { 304, -1, -1, sizeof(::greptime::v1::region::MitoManifestInfo)},
-  { 310, -1, -1, sizeof(::greptime::v1::region::MetricManifestInfo)},
+  { 311, -1, -1, sizeof(::greptime::v1::region::MetricManifestInfo)},
-  { 318, -1, -1, sizeof(::greptime::v1::region::SyncRequest)},
+  { 319, -1, -1, sizeof(::greptime::v1::region::SyncRequest)},
-  { 328, -1, -1, sizeof(::greptime::v1::region::ListMetadataRequest)},
+  { 329, -1, -1, sizeof(::greptime::v1::region::ListMetadataRequest)},
-  { 335, -1, -1, sizeof(::greptime::v1::region::BuildIndexRequest)},
+  { 336, -1, -1, sizeof(::greptime::v1::region::BuildIndexRequest)},
+  { 343, -1, -1, sizeof(::greptime::v1::region::FileMetas)},
+  { 350, -1, -1, sizeof(::greptime::v1::region::ApplyStagingManifestRequest)},
 };
 
 static const ::_pb::Message* const file_default_instances[] = {
@@ -974,6 +1021,8 @@ static const ::_pb::Message* const file_default_instances[] = {
   &::greptime::v1::region::_SyncRequest_default_instance_._instance,
   &::greptime::v1::region::_ListMetadataRequest_default_instance_._instance,
   &::greptime::v1::region::_BuildIndexRequest_default_instance_._instance,
+  &::greptime::v1::region::_FileMetas_default_instance_._instance,
+  &::greptime::v1::region::_ApplyStagingManifestRequest_default_instance_._instance,
 };
 
 const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
@@ -986,7 +1035,7 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P
   "eader.TracingContextEntry\022\016\n\006dbname\030\003 \001("
   "\t\0220\n\rquery_context\030\006 \001(\0132\031.greptime.v1.Q"
   "ueryContext\0325\n\023TracingContextEntry\022\013\n\003ke"
-  "y\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\354\007\n\rRegionReq"
+  "y\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\277\010\n\rRegionReq"
   "uest\0227\n\006header\030\001 \001(\0132\'.greptime.v1.regio"
   "n.RegionRequestHeader\0225\n\007inserts\030\003 \001(\0132\""
   ".greptime.v1.region.InsertRequestsH\000\0225\n\007"
@@ -1011,99 +1060,105 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P
   "ion.SyncRequestH\000\022@\n\rlist_metadata\030\022 \001(\013"
   "2\'.greptime.v1.region.ListMetadataReques"
   "tH\000\022<\n\013build_index\030\023 \001(\0132%.greptime.v1.r"
-  "egion.BuildIndexRequestH\000B\006\n\004body\"\341\001\n\016Re"
+  "egion.BuildIndexRequestH\000\022Q\n\026apply_stagi"
-  "gionResponse\022+\n\006header\030\001 \001(\0132\033.greptime."
+  "ng_manifest\030\024 \001(\0132/.greptime.v1.region.A"
-  "v1.ResponseHeader\022\025\n\raffected_rows\030\002 \001(\004"
+  "pplyStagingManifestRequestH\000B\006\n\004body\"\341\001\n"
-  "\022F\n\nextensions\030\003 \003(\01322.greptime.v1.regio"
+  "\016RegionResponse\022+\n\006header\030\001 \001(\0132\033.grepti"
-  "n.RegionResponse.ExtensionsEntry\022\020\n\010meta"
+  "me.v1.ResponseHeader\022\025\n\raffected_rows\030\002 "
-  "data\030\004 \001(\014\0321\n\017ExtensionsEntry\022\013\n\003key\030\001 \001"
+  "\001(\004\022F\n\nextensions\030\003 \003(\01322.greptime.v1.re"
-  "(\t\022\r\n\005value\030\002 \001(\014:\0028\001\"E\n\016InsertRequests\022"
+  "gion.RegionResponse.ExtensionsEntry\022\020\n\010m"
-  "3\n\010requests\030\001 \003(\0132!.greptime.v1.region.I"
+  "etadata\030\004 \001(\014\0321\n\017ExtensionsEntry\022\013\n\003key\030"
-  "nsertRequest\"E\n\016DeleteRequests\0223\n\010reques"
+  "\001 \001(\t\022\r\n\005value\030\002 \001(\014:\0028\001\"E\n\016InsertReques"
-  "ts\030\001 \003(\0132!.greptime.v1.region.DeleteRequ"
+  "ts\0223\n\010requests\030\001 \003(\0132!.greptime.v1.regio"
-  "est\"C\n\rInsertRequest\022\021\n\tregion_id\030\001 \001(\004\022"
+  "n.InsertRequest\"E\n\016DeleteRequests\0223\n\010req"
-  "\037\n\004rows\030\002 \001(\0132\021.greptime.v1.Rows\"C\n\rDele"
+  "uests\030\001 \003(\0132!.greptime.v1.region.DeleteR"
-  "teRequest\022\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001"
+  "equest\"C\n\rInsertRequest\022\021\n\tregion_id\030\001 \001"
-  "(\0132\021.greptime.v1.Rows\"h\n\014QueryRequest\0227\n"
+  "(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime.v1.Rows\"C\n\rD"
-  "\006header\030\001 \001(\0132\'.greptime.v1.region.Regio"
+  "eleteRequest\022\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030"
-  "nRequestHeader\022\021\n\tregion_id\030\002 \001(\004\022\014\n\004pla"
+  "\002 \001(\0132\021.greptime.v1.Rows\"h\n\014QueryRequest"
-  "n\030\003 \001(\014\"E\n\016CreateRequests\0223\n\010requests\030\001 "
+  "\0227\n\006header\030\001 \001(\0132\'.greptime.v1.region.Re"
-  "\003(\0132!.greptime.v1.region.CreateRequest\"\260"
+  "gionRequestHeader\022\021\n\tregion_id\030\002 \001(\004\022\014\n\004"
-  "\002\n\rCreateRequest\022\021\n\tregion_id\030\001 \001(\004\022\016\n\006e"
+  "plan\030\003 \001(\014\"E\n\016CreateRequests\0223\n\010requests"
-  "ngine\030\002 \001(\t\0228\n\013column_defs\030\003 \003(\0132#.grept"
+  "\030\001 \003(\0132!.greptime.v1.region.CreateReques"
-  "ime.v1.region.RegionColumnDef\022\023\n\013primary"
+  "t\"\260\002\n\rCreateRequest\022\021\n\tregion_id\030\001 \001(\004\022\016"
-  "_key\030\004 \003(\r\022\014\n\004path\030\005 \001(\t\022\?\n\007options\030\006 \003("
+  "\n\006engine\030\002 \001(\t\0228\n\013column_defs\030\003 \003(\0132#.gr"
-  "\0132..greptime.v1.region.CreateRequest.Opt"
+  "eptime.v1.region.RegionColumnDef\022\023\n\013prim"
-  "ionsEntry\022.\n\tpartition\030\007 \001(\0132\033.greptime."
+  "ary_key\030\004 \003(\r\022\014\n\004path\030\005 \001(\t\022\?\n\007options\030\006"
-  "v1.meta.Partition\032.\n\014OptionsEntry\022\013\n\003key"
+  " \003(\0132..greptime.v1.region.CreateRequest."
-  "\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"A\n\014DropRequest"
+  "OptionsEntry\022.\n\tpartition\030\007 \001(\0132\033.grepti"
-  "s\0221\n\010requests\030\001 \003(\0132\037.greptime.v1.region"
+  "me.v1.meta.Partition\032.\n\014OptionsEntry\022\013\n\003"
-  ".DropRequest\"3\n\013DropRequest\022\021\n\tregion_id"
+  "key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"A\n\014DropRequ"
-  "\030\001 \001(\004\022\021\n\tfast_path\030\002 \001(\010\"\255\001\n\013OpenReques"
+  "ests\0221\n\010requests\030\001 \003(\0132\037.greptime.v1.reg"
-  "t\022\021\n\tregion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\014\n\004"
+  "ion.DropRequest\"3\n\013DropRequest\022\021\n\tregion"
-  "path\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v"
+  "_id\030\001 \001(\004\022\021\n\tfast_path\030\002 \001(\010\"\255\001\n\013OpenReq"
-  "1.region.OpenRequest.OptionsEntry\032.\n\014Opt"
+  "uest\022\021\n\tregion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022"
-  "ionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028"
+  "\014\n\004path\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptim"
-  "\001\"!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"C\n\r"
+  "e.v1.region.OpenRequest.OptionsEntry\032.\n\014"
-  "AlterRequests\0222\n\010requests\030\001 \003(\0132 .grepti"
+  "OptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t"
-  "me.v1.region.AlterRequest\"\311\005\n\014AlterReque"
+  ":\0028\001\"!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\""
-  "st\022\021\n\tregion_id\030\001 \001(\004\0225\n\013add_columns\030\002 \001"
+  "C\n\rAlterRequests\0222\n\010requests\030\001 \003(\0132 .gre"
-  "(\0132\036.greptime.v1.region.AddColumnsH\000\0227\n\014"
+  "ptime.v1.region.AlterRequest\"\311\005\n\014AlterRe"
-  "drop_columns\030\003 \001(\0132\037.greptime.v1.region."
+  "quest\022\021\n\tregion_id\030\001 \001(\004\0225\n\013add_columns\030"
-  "DropColumnsH\000\022=\n\023modify_column_types\030\005 \001"
+  "\002 \001(\0132\036.greptime.v1.region.AddColumnsH\000\022"
-  "(\0132\036.greptime.v1.ModifyColumnTypesH\000\0229\n\021"
+  "7\n\014drop_columns\030\003 \001(\0132\037.greptime.v1.regi"
-  "set_table_options\030\006 \001(\0132\034.greptime.v1.Se"
+  "on.DropColumnsH\000\022=\n\023modify_column_types\030"
-  "tTableOptionsH\000\022=\n\023unset_table_options\030\t"
+  "\005 \001(\0132\036.greptime.v1.ModifyColumnTypesH\000\022"
-  " \001(\0132\036.greptime.v1.UnsetTableOptionsH\000\022*"
+  "9\n\021set_table_options\030\006 \001(\0132\034.greptime.v1"
-  "\n\tset_index\030\n \001(\0132\025.greptime.v1.SetIndex"
+  ".SetTableOptionsH\000\022=\n\023unset_table_option"
-  "H\000\022.\n\013unset_index\030\013 \001(\0132\027.greptime.v1.Un"
+  "s\030\t \001(\0132\036.greptime.v1.UnsetTableOptionsH"
-  "setIndexH\000\0222\n\rdrop_defaults\030\014 \001(\0132\031.grep"
+  "\000\022*\n\tset_index\030\n \001(\0132\025.greptime.v1.SetIn"
-  "time.v1.DropDefaultsH\000\022.\n\013set_indexes\030\r "
+  "dexH\000\022.\n\013unset_index\030\013 \001(\0132\027.greptime.v1"
-  "\001(\0132\027.greptime.v1.SetIndexesH\000\0222\n\runset_"
+  ".UnsetIndexH\000\0222\n\rdrop_defaults\030\014 \001(\0132\031.g"
-  "indexes\030\016 \001(\0132\031.greptime.v1.UnsetIndexes"
+  "reptime.v1.DropDefaultsH\000\022.\n\013set_indexes"
-  "H\000\0220\n\014set_defaults\030\017 \001(\0132\030.greptime.v1.S"
+  "\030\r \001(\0132\027.greptime.v1.SetIndexesH\000\0222\n\runs"
-  "etDefaultsH\000\0227\n\014sync_columns\030\020 \001(\0132\037.gre"
+  "et_indexes\030\016 \001(\0132\031.greptime.v1.UnsetInde"
-  "ptime.v1.region.SyncColumnsH\000\022\026\n\016schema_"
+  "xesH\000\0220\n\014set_defaults\030\017 \001(\0132\030.greptime.v"
-  "version\030\004 \001(\004B\006\n\004kind\"G\n\013SyncColumns\0228\n\013"
+  "1.SetDefaultsH\000\0227\n\014sync_columns\030\020 \001(\0132\037."
-  "column_defs\030\001 \003(\0132#.greptime.v1.region.R"
+  "greptime.v1.region.SyncColumnsH\000\022\026\n\016sche"
-  "egionColumnDef\"@\n\nAddColumns\0222\n\013add_colu"
+  "ma_version\030\004 \001(\004B\006\n\004kind\"G\n\013SyncColumns\022"
-  "mns\030\001 \003(\0132\035.greptime.v1.region.AddColumn"
+  "8\n\013column_defs\030\001 \003(\0132#.greptime.v1.regio"
-  "\"C\n\013DropColumns\0224\n\014drop_columns\030\001 \003(\0132\036."
+  "n.RegionColumnDef\"@\n\nAddColumns\0222\n\013add_c"
-  "greptime.v1.region.DropColumn\"v\n\tAddColu"
+  "olumns\030\001 \003(\0132\035.greptime.v1.region.AddCol"
-  "mn\0227\n\ncolumn_def\030\001 \001(\0132#.greptime.v1.reg"
+  "umn\"C\n\013DropColumns\0224\n\014drop_columns\030\001 \003(\013"
-  "ion.RegionColumnDef\0220\n\010location\030\003 \001(\0132\036."
+  "2\036.greptime.v1.region.DropColumn\"v\n\tAddC"
-  "greptime.v1.AddColumnLocation\"\032\n\nDropCol"
+  "olumn\0227\n\ncolumn_def\030\001 \001(\0132#.greptime.v1."
-  "umn\022\014\n\004name\030\001 \001(\t\"!\n\014FlushRequest\022\021\n\treg"
+  "region.RegionColumnDef\0220\n\010location\030\003 \001(\013"
-  "ion_id\030\001 \001(\004\"\t\n\007Regular\"&\n\014StrictWindow\022"
+  "2\036.greptime.v1.AddColumnLocation\"\032\n\nDrop"
-  "\026\n\016window_seconds\030\001 \001(\003\"\256\001\n\016CompactReque"
+  "Column\022\014\n\004name\030\001 \001(\t\"!\n\014FlushRequest\022\021\n\t"
-  "st\022\021\n\tregion_id\030\001 \001(\004\022.\n\007regular\030\002 \001(\0132\033"
+  "region_id\030\001 \001(\004\"\t\n\007Regular\"&\n\014StrictWind"
-  ".greptime.v1.region.RegularH\000\0229\n\rstrict_"
+  "ow\022\026\n\016window_seconds\030\001 \001(\003\"\256\001\n\016CompactRe"
-  "window\030\003 \001(\0132 .greptime.v1.region.Strict"
+  "quest\022\021\n\tregion_id\030\001 \001(\004\022.\n\007regular\030\002 \001("
-  "WindowH\000\022\023\n\013parallelism\030\004 \001(\rB\t\n\007options"
+  "\0132\033.greptime.v1.region.RegularH\000\0229\n\rstri"
-  "\"\204\001\n\017TruncateRequest\022\021\n\tregion_id\030\001 \001(\004\022"
+  "ct_window\030\003 \001(\0132 .greptime.v1.region.Str"
-  "&\n\003all\030\002 \001(\0132\027.greptime.v1.region.AllH\000\022"
+  "ictWindowH\000\022\023\n\013parallelism\030\004 \001(\rB\t\n\007opti"
-  ".\n\013time_ranges\030\003 \001(\0132\027.greptime.v1.TimeR"
+  "ons\"\204\001\n\017TruncateRequest\022\021\n\tregion_id\030\001 \001"
-  "angesH\000B\006\n\004kind\"\005\n\003All\"P\n\017RegionColumnDe"
+  "(\004\022&\n\003all\030\002 \001(\0132\027.greptime.v1.region.All"
-  "f\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.Colu"
+  "H\000\022.\n\013time_ranges\030\003 \001(\0132\027.greptime.v1.Ti"
-  "mnDef\022\021\n\tcolumn_id\030\002 \001(\r\"Z\n\021BulkInsertRe"
+  "meRangesH\000B\006\n\004kind\"\005\n\003All\"P\n\017RegionColum"
-  "quest\022\021\n\tregion_id\030\001 \001(\004\022*\n\tarrow_ipc\030\002 "
+  "nDef\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.C"
-  "\001(\0132\025.greptime.v1.ArrowIpcH\000B\006\n\004body\"1\n\020"
+  "olumnDef\022\021\n\tcolumn_id\030\002 \001(\r\"Z\n\021BulkInser"
-  "MitoManifestInfo\022\035\n\025data_manifest_versio"
+  "tRequest\022\021\n\tregion_id\030\001 \001(\004\022*\n\tarrow_ipc"
-  "n\030\001 \001(\004\"V\n\022MetricManifestInfo\022\035\n\025data_ma"
+  "\030\002 \001(\0132\025.greptime.v1.ArrowIpcH\000B\006\n\004body\""
-  "nifest_version\030\001 \001(\004\022!\n\031metadata_manifes"
+  "1\n\020MitoManifestInfo\022\035\n\025data_manifest_ver"
-  "t_version\030\002 \001(\004\"\275\001\n\013SyncRequest\022\021\n\tregio"
+  "sion\030\001 \001(\004\"V\n\022MetricManifestInfo\022\035\n\025data"
-  "n_id\030\001 \001(\004\022B\n\022mito_manifest_info\030\002 \001(\0132$"
+  "_manifest_version\030\001 \001(\004\022!\n\031metadata_mani"
-  ".greptime.v1.region.MitoManifestInfoH\000\022F"
+  "fest_version\030\002 \001(\004\"\275\001\n\013SyncRequest\022\021\n\tre"
-  "\n\024metric_manifest_info\030\003 \001(\0132&.greptime."
+  "gion_id\030\001 \001(\004\022B\n\022mito_manifest_info\030\002 \001("
-  "v1.region.MetricManifestInfoH\000B\017\n\rmanife"
+  "\0132$.greptime.v1.region.MitoManifestInfoH"
-  "st_info\")\n\023ListMetadataRequest\022\022\n\nregion"
+  "\000\022F\n\024metric_manifest_info\030\003 \001(\0132&.grepti"
-  "_ids\030\001 \003(\004\"&\n\021BuildIndexRequest\022\021\n\tregio"
+  "me.v1.region.MetricManifestInfoH\000B\017\n\rman"
-  "n_id\030\001 \001(\0042Y\n\006Region\022O\n\006Handle\022!.greptim"
+  "ifest_info\")\n\023ListMetadataRequest\022\022\n\nreg"
-  "e.v1.region.RegionRequest\032\".greptime.v1."
+  "ion_ids\030\001 \003(\004\"&\n\021BuildIndexRequest\022\021\n\tre"
-  "region.RegionResponseB]\n\025io.greptime.v1."
+  "gion_id\030\001 \001(\004\"\031\n\tFileMetas\022\014\n\004data\030\001 \001(\014"
-  "regionB\006ServerZ<github.com/GreptimeTeam/"
+  "\"}\n\033ApplyStagingManifestRequest\022\021\n\tregio"
-  "greptime-proto/go/greptime/v1/regionb\006pr"
+  "n_id\030\001 \001(\004\022\026\n\016partition_expr\030\002 \001(\t\0223\n\014fi"
-  "oto3"
+  "les_to_add\030\003 \001(\0132\035.greptime.v1.region.Fi"
+  "leMetas2Y\n\006Region\022O\n\006Handle\022!.greptime.v"
+  "1.region.RegionRequest\032\".greptime.v1.reg"
+  "ion.RegionResponseB]\n\025io.greptime.v1.reg"
+  "ionB\006ServerZ<github.com/GreptimeTeam/gre"
+  "ptime-proto/go/greptime/v1/regionb\006proto"
+  "3"
   ;
 static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps[4] = {
   &::descriptor_table_greptime_2fv1_2fcommon_2eproto,
@@ -1113,9 +1168,9 @@ static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2freg
 };
 static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto = {
-    false, false, 5044, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
+    false, false, 5281, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
     "greptime/v1/region/server.proto",
-    &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 4, 38,
+    &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 4, 40,
     schemas, file_default_instances, TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets,
     file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto, file_level_enum_descriptors_greptime_2fv1_2fregion_2fserver_2eproto,
     file_level_service_descriptors_greptime_2fv1_2fregion_2fserver_2eproto,
@@ -1485,6 +1540,7 @@ class RegionRequest::_Internal {
   static const ::greptime::v1::region::SyncRequest& sync(const RegionRequest* msg);
   static const ::greptime::v1::region::ListMetadataRequest& list_metadata(const RegionRequest* msg);
   static const ::greptime::v1::region::BuildIndexRequest& build_index(const RegionRequest* msg);
+  static const ::greptime::v1::region::ApplyStagingManifestRequest& apply_staging_manifest(const RegionRequest* msg);
 };
 
 const ::greptime::v1::region::RegionRequestHeader&
@@ -1559,6 +1615,10 @@ const ::greptime::v1::region::BuildIndexRequest&
 RegionRequest::_Internal::build_index(const RegionRequest* msg) {
   return *msg->_impl_.body_.build_index_;
 }
+const ::greptime::v1::region::ApplyStagingManifestRequest&
+RegionRequest::_Internal::apply_staging_manifest(const RegionRequest* msg) {
+  return *msg->_impl_.body_.apply_staging_manifest_;
+}
 void RegionRequest::set_allocated_inserts(::greptime::v1::region::InsertRequests* inserts) {
   ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
   clear_body();
@@ -1814,6 +1874,21 @@ void RegionRequest::set_allocated_build_index(::greptime::v1::region::BuildIndex
   }
   // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.RegionRequest.build_index)
 }
+void RegionRequest::set_allocated_apply_staging_manifest(::greptime::v1::region::ApplyStagingManifestRequest* apply_staging_manifest) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  clear_body();
+  if (apply_staging_manifest) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+      ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(apply_staging_manifest);
+    if (message_arena != submessage_arena) {
+      apply_staging_manifest = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, apply_staging_manifest, submessage_arena);
+    }
+    set_has_apply_staging_manifest();
+    _impl_.body_.apply_staging_manifest_ = apply_staging_manifest;
+  }
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.RegionRequest.apply_staging_manifest)
+}
 RegionRequest::RegionRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
   : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
@@ -1920,6 +1995,11 @@ RegionRequest::RegionRequest(const RegionRequest& from)
           from._internal_build_index());
       break;
     }
+    case kApplyStagingManifest: {
+      _this->_internal_mutable_apply_staging_manifest()->::greptime::v1::region::ApplyStagingManifestRequest::MergeFrom(
+          from._internal_apply_staging_manifest());
+      break;
+    }
     case BODY_NOT_SET: {
       break;
     }
@@ -2066,6 +2146,12 @@ void RegionRequest::clear_body() {
       }
       break;
     }
+    case kApplyStagingManifest: {
+      if (GetArenaForAllocation() == nullptr) {
+        delete _impl_.body_.apply_staging_manifest_;
+      }
+      break;
+    }
     case BODY_NOT_SET: {
       break;
     }
@@ -2238,6 +2324,14 @@ const char* RegionRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext*
         } else
           goto handle_unusual;
         continue;
+      // .greptime.v1.region.ApplyStagingManifestRequest apply_staging_manifest = 20;
+      case 20:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 162)) {
+          ptr = ctx->ParseMessage(_internal_mutable_apply_staging_manifest(), ptr);
+          CHK_(ptr);
+        } else
+          goto handle_unusual;
+        continue;
       default:
         goto handle_unusual;
     }  // switch
@@ -2393,6 +2487,13 @@ uint8_t* RegionRequest::_InternalSerialize(
         _Internal::build_index(this).GetCachedSize(), target, stream);
   }
 
+  // .greptime.v1.region.ApplyStagingManifestRequest apply_staging_manifest = 20;
+  if (_internal_has_apply_staging_manifest()) {
+    target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
+      InternalWriteMessage(20, _Internal::apply_staging_manifest(this),
+        _Internal::apply_staging_manifest(this).GetCachedSize(), target, stream);
+  }
+
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
     target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
         _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
@@ -2536,6 +2637,13 @@ size_t RegionRequest::ByteSizeLong() const {
           *_impl_.body_.build_index_);
       break;
     }
+    // .greptime.v1.region.ApplyStagingManifestRequest apply_staging_manifest = 20;
+    case kApplyStagingManifest: {
+      total_size += 2 +
+        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
+          *_impl_.body_.apply_staging_manifest_);
+      break;
+    }
     case BODY_NOT_SET: {
       break;
     }
@@ -2648,6 +2756,11 @@ void RegionRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::
           from._internal_build_index());
       break;
     }
+    case kApplyStagingManifest: {
+      _this->_internal_mutable_apply_staging_manifest()->::greptime::v1::region::ApplyStagingManifestRequest::MergeFrom(
+          from._internal_apply_staging_manifest());
+      break;
+    }
     case BODY_NOT_SET: {
       break;
     }
@@ -10708,6 +10821,480 @@ void BuildIndexRequest::InternalSwap(BuildIndexRequest* other) {
       file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[37]);
 }
 
+// ===================================================================
+
+class FileMetas::_Internal {
+ public:
+};
+
+FileMetas::FileMetas(::PROTOBUF_NAMESPACE_ID::Arena* arena,
+                         bool is_message_owned)
+  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
+  SharedCtor(arena, is_message_owned);
+  // @@protoc_insertion_point(arena_constructor:greptime.v1.region.FileMetas)
+}
+FileMetas::FileMetas(const FileMetas& from)
+  : ::PROTOBUF_NAMESPACE_ID::Message() {
+  FileMetas* const _this = this; (void)_this;
+  new (&_impl_) Impl_{
+      decltype(_impl_.data_){}
+    , /*decltype(_impl_._cached_size_)*/{}};
+
+  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  _impl_.data_.InitDefault();
+  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+    _impl_.data_.Set("", GetArenaForAllocation());
+  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  if (!from._internal_data().empty()) {
+    _this->_impl_.data_.Set(from._internal_data(), 
+      _this->GetArenaForAllocation());
+  }
+  // @@protoc_insertion_point(copy_constructor:greptime.v1.region.FileMetas)
+}
+
+inline void FileMetas::SharedCtor(
+    ::_pb::Arena* arena, bool is_message_owned) {
+  (void)arena;
+  (void)is_message_owned;
+  new (&_impl_) Impl_{
+      decltype(_impl_.data_){}
+    , /*decltype(_impl_._cached_size_)*/{}
+  };
+  _impl_.data_.InitDefault();
+  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+    _impl_.data_.Set("", GetArenaForAllocation());
+  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+}
+
+FileMetas::~FileMetas() {
+  // @@protoc_insertion_point(destructor:greptime.v1.region.FileMetas)
+  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
+  (void)arena;
+    return;
+  }
+  SharedDtor();
+}
+
+inline void FileMetas::SharedDtor() {
+  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
+  _impl_.data_.Destroy();
+}
+
+void FileMetas::SetCachedSize(int size) const {
+  _impl_._cached_size_.Set(size);
+}
+
+void FileMetas::Clear() {
+// @@protoc_insertion_point(message_clear_start:greptime.v1.region.FileMetas)
+  uint32_t cached_has_bits = 0;
+  // Prevent compiler warnings about cached_has_bits being unused
+  (void) cached_has_bits;
+
+  _impl_.data_.ClearToEmpty();
+  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+const char* FileMetas::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
+#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
+  while (!ctx->Done(&ptr)) {
+    uint32_t tag;
+    ptr = ::_pbi::ReadTag(ptr, &tag);
+    switch (tag >> 3) {
+      // bytes data = 1;
+      case 1:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 10)) {
+          auto str = _internal_mutable_data();
+          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
+          CHK_(ptr);
+        } else
+          goto handle_unusual;
+        continue;
+      default:
+        goto handle_unusual;
+    }  // switch
+  handle_unusual:
+    if ((tag == 0) || ((tag & 7) == 4)) {
+      CHK_(ptr);
+      ctx->SetLastTag(tag);
+      goto message_done;
+    }
+    ptr = UnknownFieldParse(
+        tag,
+        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
+        ptr, ctx);
+    CHK_(ptr != nullptr);
+  }  // while
+message_done:
+  return ptr;
+failure:
+  ptr = nullptr;
+  goto message_done;
+#undef CHK_
+}
+
+uint8_t* FileMetas::_InternalSerialize(
+    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
+  // @@protoc_insertion_point(serialize_to_array_start:greptime.v1.region.FileMetas)
+  uint32_t cached_has_bits = 0;
+  (void) cached_has_bits;
+
+  // bytes data = 1;
+  if (!this->_internal_data().empty()) {
+    target = stream->WriteBytesMaybeAliased(
+        1, this->_internal_data(), target);
+  }
+
+  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
+        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
+  }
+  // @@protoc_insertion_point(serialize_to_array_end:greptime.v1.region.FileMetas)
+  return target;
+}
+
+size_t FileMetas::ByteSizeLong() const {
+// @@protoc_insertion_point(message_byte_size_start:greptime.v1.region.FileMetas)
+  size_t total_size = 0;
+
+  uint32_t cached_has_bits = 0;
+  // Prevent compiler warnings about cached_has_bits being unused
+  (void) cached_has_bits;
+
+  // bytes data = 1;
+  if (!this->_internal_data().empty()) {
+    total_size += 1 +
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize(
+        this->_internal_data());
+  }
+
+  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
+}
+
+const ::PROTOBUF_NAMESPACE_ID::Message::ClassData FileMetas::_class_data_ = {
+    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
+    FileMetas::MergeImpl
+};
+const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*FileMetas::GetClassData() const { return &_class_data_; }
+
+
+void FileMetas::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
+  auto* const _this = static_cast<FileMetas*>(&to_msg);
+  auto& from = static_cast<const FileMetas&>(from_msg);
+  // @@protoc_insertion_point(class_specific_merge_from_start:greptime.v1.region.FileMetas)
+  GOOGLE_DCHECK_NE(&from, _this);
+  uint32_t cached_has_bits = 0;
+  (void) cached_has_bits;
+
+  if (!from._internal_data().empty()) {
+    _this->_internal_set_data(from._internal_data());
+  }
+  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+}
+
+void FileMetas::CopyFrom(const FileMetas& from) {
+// @@protoc_insertion_point(class_specific_copy_from_start:greptime.v1.region.FileMetas)
+  if (&from == this) return;
+  Clear();
+  MergeFrom(from);
+}
+
+bool FileMetas::IsInitialized() const {
+  return true;
+}
+
+void FileMetas::InternalSwap(FileMetas* other) {
+  using std::swap;
+  auto* lhs_arena = GetArenaForAllocation();
+  auto* rhs_arena = other->GetArenaForAllocation();
+  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
+  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
+      &_impl_.data_, lhs_arena,
+      &other->_impl_.data_, rhs_arena
+  );
+}
+
+::PROTOBUF_NAMESPACE_ID::Metadata FileMetas::GetMetadata() const {
+  return ::_pbi::AssignDescriptors(
+      &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once,
+      file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[38]);
+}
+
+// ===================================================================
+
+class ApplyStagingManifestRequest::_Internal {
+ public:
+  static const ::greptime::v1::region::FileMetas& files_to_add(const ApplyStagingManifestRequest* msg);
+};
+
+const ::greptime::v1::region::FileMetas&
+ApplyStagingManifestRequest::_Internal::files_to_add(const ApplyStagingManifestRequest* msg) {
+  return *msg->_impl_.files_to_add_;
+}
+ApplyStagingManifestRequest::ApplyStagingManifestRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
+                         bool is_message_owned)
+  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
+  SharedCtor(arena, is_message_owned);
+  // @@protoc_insertion_point(arena_constructor:greptime.v1.region.ApplyStagingManifestRequest)
+}
+ApplyStagingManifestRequest::ApplyStagingManifestRequest(const ApplyStagingManifestRequest& from)
+  : ::PROTOBUF_NAMESPACE_ID::Message() {
+  ApplyStagingManifestRequest* const _this = this; (void)_this;
+  new (&_impl_) Impl_{
+      decltype(_impl_.partition_expr_){}
+    , decltype(_impl_.files_to_add_){nullptr}
+    , decltype(_impl_.region_id_){}
+    , /*decltype(_impl_._cached_size_)*/{}};
+
+  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  _impl_.partition_expr_.InitDefault();
+  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+    _impl_.partition_expr_.Set("", GetArenaForAllocation());
+  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  if (!from._internal_partition_expr().empty()) {
+    _this->_impl_.partition_expr_.Set(from._internal_partition_expr(), 
+      _this->GetArenaForAllocation());
+  }
+  if (from._internal_has_files_to_add()) {
+    _this->_impl_.files_to_add_ = new ::greptime::v1::region::FileMetas(*from._impl_.files_to_add_);
+  }
+  _this->_impl_.region_id_ = from._impl_.region_id_;
+  // @@protoc_insertion_point(copy_constructor:greptime.v1.region.ApplyStagingManifestRequest)
+}
+
+inline void ApplyStagingManifestRequest::SharedCtor(
+    ::_pb::Arena* arena, bool is_message_owned) {
+  (void)arena;
+  (void)is_message_owned;
+  new (&_impl_) Impl_{
+      decltype(_impl_.partition_expr_){}
+    , decltype(_impl_.files_to_add_){nullptr}
+    , decltype(_impl_.region_id_){uint64_t{0u}}
+    , /*decltype(_impl_._cached_size_)*/{}
+  };
+  _impl_.partition_expr_.InitDefault();
+  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+    _impl_.partition_expr_.Set("", GetArenaForAllocation());
+  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+}
+
+ApplyStagingManifestRequest::~ApplyStagingManifestRequest() {
+  // @@protoc_insertion_point(destructor:greptime.v1.region.ApplyStagingManifestRequest)
+  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
+  (void)arena;
+    return;
+  }
+  SharedDtor();
+}
+
+inline void ApplyStagingManifestRequest::SharedDtor() {
+  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
+  _impl_.partition_expr_.Destroy();
+  if (this != internal_default_instance()) delete _impl_.files_to_add_;
+}
+
+void ApplyStagingManifestRequest::SetCachedSize(int size) const {
+  _impl_._cached_size_.Set(size);
+}
+
+void ApplyStagingManifestRequest::Clear() {
+// @@protoc_insertion_point(message_clear_start:greptime.v1.region.ApplyStagingManifestRequest)
+  uint32_t cached_has_bits = 0;
+  // Prevent compiler warnings about cached_has_bits being unused
+  (void) cached_has_bits;
+
+  _impl_.partition_expr_.ClearToEmpty();
+  if (GetArenaForAllocation() == nullptr && _impl_.files_to_add_ != nullptr) {
+    delete _impl_.files_to_add_;
+  }
+  _impl_.files_to_add_ = nullptr;
+  _impl_.region_id_ = uint64_t{0u};
+  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
+}
+
+const char* ApplyStagingManifestRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
+#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
+  while (!ctx->Done(&ptr)) {
+    uint32_t tag;
+    ptr = ::_pbi::ReadTag(ptr, &tag);
+    switch (tag >> 3) {
+      // uint64 region_id = 1;
+      case 1:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 8)) {
+          _impl_.region_id_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
+          CHK_(ptr);
+        } else
+          goto handle_unusual;
+        continue;
+      // string partition_expr = 2;
+      case 2:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
+          auto str = _internal_mutable_partition_expr();
+          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
+          CHK_(ptr);
+          CHK_(::_pbi::VerifyUTF8(str, "greptime.v1.region.ApplyStagingManifestRequest.partition_expr"));
+        } else
+          goto handle_unusual;
+        continue;
+      // .greptime.v1.region.FileMetas files_to_add = 3;
+      case 3:
+        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 26)) {
+          ptr = ctx->ParseMessage(_internal_mutable_files_to_add(), ptr);
+          CHK_(ptr);
+        } else
+          goto handle_unusual;
+        continue;
+      default:
+        goto handle_unusual;
+    }  // switch
+  handle_unusual:
+    if ((tag == 0) || ((tag & 7) == 4)) {
+      CHK_(ptr);
+      ctx->SetLastTag(tag);
+      goto message_done;
+    }
+    ptr = UnknownFieldParse(
+        tag,
+        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
+        ptr, ctx);
+    CHK_(ptr != nullptr);
+  }  // while
+message_done:
+  return ptr;
+failure:
+  ptr = nullptr;
+  goto message_done;
+#undef CHK_
+}
+
+uint8_t* ApplyStagingManifestRequest::_InternalSerialize(
+    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
+  // @@protoc_insertion_point(serialize_to_array_start:greptime.v1.region.ApplyStagingManifestRequest)
+  uint32_t cached_has_bits = 0;
+  (void) cached_has_bits;
+
+  // uint64 region_id = 1;
+  if (this->_internal_region_id() != 0) {
+    target = stream->EnsureSpace(target);
+    target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target);
+  }
+
+  // string partition_expr = 2;
+  if (!this->_internal_partition_expr().empty()) {
+    ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(
+      this->_internal_partition_expr().data(), static_cast<int>(this->_internal_partition_expr().length()),
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE,
+      "greptime.v1.region.ApplyStagingManifestRequest.partition_expr");
+    target = stream->WriteStringMaybeAliased(
+        2, this->_internal_partition_expr(), target);
+  }
+
+  // .greptime.v1.region.FileMetas files_to_add = 3;
+  if (this->_internal_has_files_to_add()) {
+    target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
+      InternalWriteMessage(3, _Internal::files_to_add(this),
+        _Internal::files_to_add(this).GetCachedSize(), target, stream);
+  }
+
+  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
+    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
+        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
+  }
+  // @@protoc_insertion_point(serialize_to_array_end:greptime.v1.region.ApplyStagingManifestRequest)
+  return target;
+}
+
+size_t ApplyStagingManifestRequest::ByteSizeLong() const {
+// @@protoc_insertion_point(message_byte_size_start:greptime.v1.region.ApplyStagingManifestRequest)
+  size_t total_size = 0;
+
+  uint32_t cached_has_bits = 0;
+  // Prevent compiler warnings about cached_has_bits being unused
+  (void) cached_has_bits;
+
+  // string partition_expr = 2;
+  if (!this->_internal_partition_expr().empty()) {
+    total_size += 1 +
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
+        this->_internal_partition_expr());
+  }
+
+  // .greptime.v1.region.FileMetas files_to_add = 3;
+  if (this->_internal_has_files_to_add()) {
+    total_size += 1 +
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
+        *_impl_.files_to_add_);
+  }
+
+  // uint64 region_id = 1;
+  if (this->_internal_region_id() != 0) {
+    total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_region_id());
+  }
+
+  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
+}
+
+const ::PROTOBUF_NAMESPACE_ID::Message::ClassData ApplyStagingManifestRequest::_class_data_ = {
+    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
+    ApplyStagingManifestRequest::MergeImpl
+};
+const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*ApplyStagingManifestRequest::GetClassData() const { return &_class_data_; }
+
+
+void ApplyStagingManifestRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
+  auto* const _this = static_cast<ApplyStagingManifestRequest*>(&to_msg);
+  auto& from = static_cast<const ApplyStagingManifestRequest&>(from_msg);
+  // @@protoc_insertion_point(class_specific_merge_from_start:greptime.v1.region.ApplyStagingManifestRequest)
+  GOOGLE_DCHECK_NE(&from, _this);
+  uint32_t cached_has_bits = 0;
+  (void) cached_has_bits;
+
+  if (!from._internal_partition_expr().empty()) {
+    _this->_internal_set_partition_expr(from._internal_partition_expr());
+  }
+  if (from._internal_has_files_to_add()) {
+    _this->_internal_mutable_files_to_add()->::greptime::v1::region::FileMetas::MergeFrom(
+        from._internal_files_to_add());
+  }
+  if (from._internal_region_id() != 0) {
+    _this->_internal_set_region_id(from._internal_region_id());
+  }
+  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+}
+
+void ApplyStagingManifestRequest::CopyFrom(const ApplyStagingManifestRequest& from) {
+// @@protoc_insertion_point(class_specific_copy_from_start:greptime.v1.region.ApplyStagingManifestRequest)
+  if (&from == this) return;
+  Clear();
+  MergeFrom(from);
+}
+
+bool ApplyStagingManifestRequest::IsInitialized() const {
+  return true;
+}
+
+void ApplyStagingManifestRequest::InternalSwap(ApplyStagingManifestRequest* other) {
+  using std::swap;
+  auto* lhs_arena = GetArenaForAllocation();
+  auto* rhs_arena = other->GetArenaForAllocation();
+  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
+  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
+      &_impl_.partition_expr_, lhs_arena,
+      &other->_impl_.partition_expr_, rhs_arena
+  );
+  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
+      PROTOBUF_FIELD_OFFSET(ApplyStagingManifestRequest, _impl_.region_id_)
+      + sizeof(ApplyStagingManifestRequest::_impl_.region_id_)
+      - PROTOBUF_FIELD_OFFSET(ApplyStagingManifestRequest, _impl_.files_to_add_)>(
+          reinterpret_cast<char*>(&_impl_.files_to_add_),
+          reinterpret_cast<char*>(&other->_impl_.files_to_add_));
+}
+
+::PROTOBUF_NAMESPACE_ID::Metadata ApplyStagingManifestRequest::GetMetadata() const {
+  return ::_pbi::AssignDescriptors(
+      &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_getter, &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once,
+      file_level_metadata_greptime_2fv1_2fregion_2fserver_2eproto[39]);
+}
+
 // @@protoc_insertion_point(namespace_scope)
 }  // namespace region
 }  // namespace v1
@@ -10865,6 +11452,14 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::region::BuildIndexRequest*
 Arena::CreateMaybeMessage< ::greptime::v1::region::BuildIndexRequest >(Arena* arena) {
   return Arena::CreateMessageInternal< ::greptime::v1::region::BuildIndexRequest >(arena);
 }
+template<> PROTOBUF_NOINLINE ::greptime::v1::region::FileMetas*
+Arena::CreateMaybeMessage< ::greptime::v1::region::FileMetas >(Arena* arena) {
+  return Arena::CreateMessageInternal< ::greptime::v1::region::FileMetas >(arena);
+}
+template<> PROTOBUF_NOINLINE ::greptime::v1::region::ApplyStagingManifestRequest*
+Arena::CreateMaybeMessage< ::greptime::v1::region::ApplyStagingManifestRequest >(Arena* arena) {
+  return Arena::CreateMessageInternal< ::greptime::v1::region::ApplyStagingManifestRequest >(arena);
+}
 PROTOBUF_NAMESPACE_CLOSE
 
 // @@protoc_insertion_point(global_scope)

c++/greptime/v1/region/server.pb.h

@@ -70,6 +70,9 @@ extern AlterRequestDefaultTypeInternal _AlterRequest_default_instance_;
 class AlterRequests;
 struct AlterRequestsDefaultTypeInternal;
 extern AlterRequestsDefaultTypeInternal _AlterRequests_default_instance_;
+class ApplyStagingManifestRequest;
+struct ApplyStagingManifestRequestDefaultTypeInternal;
+extern ApplyStagingManifestRequestDefaultTypeInternal _ApplyStagingManifestRequest_default_instance_;
 class BuildIndexRequest;
 struct BuildIndexRequestDefaultTypeInternal;
 extern BuildIndexRequestDefaultTypeInternal _BuildIndexRequest_default_instance_;
@@ -109,6 +112,9 @@ extern DropRequestDefaultTypeInternal _DropRequest_default_instance_;
 class DropRequests;
 struct DropRequestsDefaultTypeInternal;
 extern DropRequestsDefaultTypeInternal _DropRequests_default_instance_;
+class FileMetas;
+struct FileMetasDefaultTypeInternal;
+extern FileMetasDefaultTypeInternal _FileMetas_default_instance_;
 class FlushRequest;
 struct FlushRequestDefaultTypeInternal;
 extern FlushRequestDefaultTypeInternal _FlushRequest_default_instance_;
@@ -178,6 +184,7 @@ template<> ::greptime::v1::region::AddColumns* Arena::CreateMaybeMessage<::grept
 template<> ::greptime::v1::region::All* Arena::CreateMaybeMessage<::greptime::v1::region::All>(Arena*);
 template<> ::greptime::v1::region::AlterRequest* Arena::CreateMaybeMessage<::greptime::v1::region::AlterRequest>(Arena*);
 template<> ::greptime::v1::region::AlterRequests* Arena::CreateMaybeMessage<::greptime::v1::region::AlterRequests>(Arena*);
+template<> ::greptime::v1::region::ApplyStagingManifestRequest* Arena::CreateMaybeMessage<::greptime::v1::region::ApplyStagingManifestRequest>(Arena*);
 template<> ::greptime::v1::region::BuildIndexRequest* Arena::CreateMaybeMessage<::greptime::v1::region::BuildIndexRequest>(Arena*);
 template<> ::greptime::v1::region::BulkInsertRequest* Arena::CreateMaybeMessage<::greptime::v1::region::BulkInsertRequest>(Arena*);
 template<> ::greptime::v1::region::CloseRequest* Arena::CreateMaybeMessage<::greptime::v1::region::CloseRequest>(Arena*);
@@ -191,6 +198,7 @@ template<> ::greptime::v1::region::DropColumn* Arena::CreateMaybeMessage<::grept
 template<> ::greptime::v1::region::DropColumns* Arena::CreateMaybeMessage<::greptime::v1::region::DropColumns>(Arena*);
 template<> ::greptime::v1::region::DropRequest* Arena::CreateMaybeMessage<::greptime::v1::region::DropRequest>(Arena*);
 template<> ::greptime::v1::region::DropRequests* Arena::CreateMaybeMessage<::greptime::v1::region::DropRequests>(Arena*);
+template<> ::greptime::v1::region::FileMetas* Arena::CreateMaybeMessage<::greptime::v1::region::FileMetas>(Arena*);
 template<> ::greptime::v1::region::FlushRequest* Arena::CreateMaybeMessage<::greptime::v1::region::FlushRequest>(Arena*);
 template<> ::greptime::v1::region::InsertRequest* Arena::CreateMaybeMessage<::greptime::v1::region::InsertRequest>(Arena*);
 template<> ::greptime::v1::region::InsertRequests* Arena::CreateMaybeMessage<::greptime::v1::region::InsertRequests>(Arena*);
@@ -506,6 +514,7 @@ class RegionRequest final :
     kSync = 17,
     kListMetadata = 18,
     kBuildIndex = 19,
+    kApplyStagingManifest = 20,
     BODY_NOT_SET = 0,
   };
 
@@ -605,6 +614,7 @@ class RegionRequest final :
     kSyncFieldNumber = 17,
     kListMetadataFieldNumber = 18,
     kBuildIndexFieldNumber = 19,
+    kApplyStagingManifestFieldNumber = 20,
   };
   // .greptime.v1.region.RegionRequestHeader header = 1;
   bool has_header() const;
@@ -930,6 +940,24 @@ class RegionRequest final :
       ::greptime::v1::region::BuildIndexRequest* build_index);
   ::greptime::v1::region::BuildIndexRequest* unsafe_arena_release_build_index();
 
+  // .greptime.v1.region.ApplyStagingManifestRequest apply_staging_manifest = 20;
+  bool has_apply_staging_manifest() const;
+  private:
+  bool _internal_has_apply_staging_manifest() const;
+  public:
+  void clear_apply_staging_manifest();
+  const ::greptime::v1::region::ApplyStagingManifestRequest& apply_staging_manifest() const;
+  PROTOBUF_NODISCARD ::greptime::v1::region::ApplyStagingManifestRequest* release_apply_staging_manifest();
+  ::greptime::v1::region::ApplyStagingManifestRequest* mutable_apply_staging_manifest();
+  void set_allocated_apply_staging_manifest(::greptime::v1::region::ApplyStagingManifestRequest* apply_staging_manifest);
+  private:
+  const ::greptime::v1::region::ApplyStagingManifestRequest& _internal_apply_staging_manifest() const;
+  ::greptime::v1::region::ApplyStagingManifestRequest* _internal_mutable_apply_staging_manifest();
+  public:
+  void unsafe_arena_set_allocated_apply_staging_manifest(
+      ::greptime::v1::region::ApplyStagingManifestRequest* apply_staging_manifest);
+  ::greptime::v1::region::ApplyStagingManifestRequest* unsafe_arena_release_apply_staging_manifest();
+
   void clear_body();
   BodyCase body_case() const;
   // @@protoc_insertion_point(class_scope:greptime.v1.region.RegionRequest)
@@ -952,6 +980,7 @@ class RegionRequest final :
   void set_has_sync();
   void set_has_list_metadata();
   void set_has_build_index();
+  void set_has_apply_staging_manifest();
 
   inline bool has_body() const;
   inline void clear_has_body();
@@ -981,6 +1010,7 @@ class RegionRequest final :
       ::greptime::v1::region::SyncRequest* sync_;
       ::greptime::v1::region::ListMetadataRequest* list_metadata_;
       ::greptime::v1::region::BuildIndexRequest* build_index_;
+      ::greptime::v1::region::ApplyStagingManifestRequest* apply_staging_manifest_;
     } body_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
     uint32_t _oneof_case_[1];
@@ -6743,6 +6773,343 @@ class BuildIndexRequest final :
   union { Impl_ _impl_; };
   friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto;
 };
+// -------------------------------------------------------------------
+
+class FileMetas final :
+    public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.region.FileMetas) */ {
+ public:
+  inline FileMetas() : FileMetas(nullptr) {}
+  ~FileMetas() override;
+  explicit PROTOBUF_CONSTEXPR FileMetas(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+
+  FileMetas(const FileMetas& from);
+  FileMetas(FileMetas&& from) noexcept
+    : FileMetas() {
+    *this = ::std::move(from);
+  }
+
+  inline FileMetas& operator=(const FileMetas& from) {
+    CopyFrom(from);
+    return *this;
+  }
+  inline FileMetas& operator=(FileMetas&& from) noexcept {
+    if (this == &from) return *this;
+    if (GetOwningArena() == from.GetOwningArena()
+  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
+        && GetOwningArena() != nullptr
+  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
+    ) {
+      InternalSwap(&from);
+    } else {
+      CopyFrom(from);
+    }
+    return *this;
+  }
+
+  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
+    return GetDescriptor();
+  }
+  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
+    return default_instance().GetMetadata().descriptor;
+  }
+  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
+    return default_instance().GetMetadata().reflection;
+  }
+  static const FileMetas& default_instance() {
+    return *internal_default_instance();
+  }
+  static inline const FileMetas* internal_default_instance() {
+    return reinterpret_cast<const FileMetas*>(
+               &_FileMetas_default_instance_);
+  }
+  static constexpr int kIndexInFileMessages =
+    38;
+
+  friend void swap(FileMetas& a, FileMetas& b) {
+    a.Swap(&b);
+  }
+  inline void Swap(FileMetas* other) {
+    if (other == this) return;
+  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
+    if (GetOwningArena() != nullptr &&
+        GetOwningArena() == other->GetOwningArena()) {
+   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
+    if (GetOwningArena() == other->GetOwningArena()) {
+  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
+      InternalSwap(other);
+    } else {
+      ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
+    }
+  }
+  void UnsafeArenaSwap(FileMetas* other) {
+    if (other == this) return;
+    GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
+    InternalSwap(other);
+  }
+
+  // implements Message ----------------------------------------------
+
+  FileMetas* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
+    return CreateMaybeMessage<FileMetas>(arena);
+  }
+  using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
+  void CopyFrom(const FileMetas& from);
+  using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
+  void MergeFrom( const FileMetas& from) {
+    FileMetas::MergeImpl(*this, from);
+  }
+  private:
+  static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
+  public:
+  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
+  bool IsInitialized() const final;
+
+  size_t ByteSizeLong() const final;
+  const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
+  uint8_t* _InternalSerialize(
+      uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
+  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
+
+  private:
+  void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
+  void SharedDtor();
+  void SetCachedSize(int size) const final;
+  void InternalSwap(FileMetas* other);
+
+  private:
+  friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
+  static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
+    return "greptime.v1.region.FileMetas";
+  }
+  protected:
+  explicit FileMetas(::PROTOBUF_NAMESPACE_ID::Arena* arena,
+                       bool is_message_owned = false);
+  public:
+
+  static const ClassData _class_data_;
+  const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
+
+  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+
+  // nested types ----------------------------------------------------
+
+  // accessors -------------------------------------------------------
+
+  enum : int {
+    kDataFieldNumber = 1,
+  };
+  // bytes data = 1;
+  void clear_data();
+  const std::string& data() const;
+  template <typename ArgT0 = const std::string&, typename... ArgT>
+  void set_data(ArgT0&& arg0, ArgT... args);
+  std::string* mutable_data();
+  PROTOBUF_NODISCARD std::string* release_data();
+  void set_allocated_data(std::string* data);
+  private:
+  const std::string& _internal_data() const;
+  inline PROTOBUF_ALWAYS_INLINE void _internal_set_data(const std::string& value);
+  std::string* _internal_mutable_data();
+  public:
+
+  // @@protoc_insertion_point(class_scope:greptime.v1.region.FileMetas)
+ private:
+  class _Internal;
+
+  template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
+  typedef void InternalArenaConstructable_;
+  typedef void DestructorSkippable_;
+  struct Impl_ {
+    ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr data_;
+    mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
+  };
+  union { Impl_ _impl_; };
+  friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto;
+};
+// -------------------------------------------------------------------
+
+class ApplyStagingManifestRequest final :
+    public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.region.ApplyStagingManifestRequest) */ {
+ public:
+  inline ApplyStagingManifestRequest() : ApplyStagingManifestRequest(nullptr) {}
+  ~ApplyStagingManifestRequest() override;
+  explicit PROTOBUF_CONSTEXPR ApplyStagingManifestRequest(::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized);
+
+  ApplyStagingManifestRequest(const ApplyStagingManifestRequest& from);
+  ApplyStagingManifestRequest(ApplyStagingManifestRequest&& from) noexcept
+    : ApplyStagingManifestRequest() {
+    *this = ::std::move(from);
+  }
+
+  inline ApplyStagingManifestRequest& operator=(const ApplyStagingManifestRequest& from) {
+    CopyFrom(from);
+    return *this;
+  }
+  inline ApplyStagingManifestRequest& operator=(ApplyStagingManifestRequest&& from) noexcept {
+    if (this == &from) return *this;
+    if (GetOwningArena() == from.GetOwningArena()
+  #ifdef PROTOBUF_FORCE_COPY_IN_MOVE
+        && GetOwningArena() != nullptr
+  #endif  // !PROTOBUF_FORCE_COPY_IN_MOVE
+    ) {
+      InternalSwap(&from);
+    } else {
+      CopyFrom(from);
+    }
+    return *this;
+  }
+
+  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* descriptor() {
+    return GetDescriptor();
+  }
+  static const ::PROTOBUF_NAMESPACE_ID::Descriptor* GetDescriptor() {
+    return default_instance().GetMetadata().descriptor;
+  }
+  static const ::PROTOBUF_NAMESPACE_ID::Reflection* GetReflection() {
+    return default_instance().GetMetadata().reflection;
+  }
+  static const ApplyStagingManifestRequest& default_instance() {
+    return *internal_default_instance();
+  }
+  static inline const ApplyStagingManifestRequest* internal_default_instance() {
+    return reinterpret_cast<const ApplyStagingManifestRequest*>(
+               &_ApplyStagingManifestRequest_default_instance_);
+  }
+  static constexpr int kIndexInFileMessages =
+    39;
+
+  friend void swap(ApplyStagingManifestRequest& a, ApplyStagingManifestRequest& b) {
+    a.Swap(&b);
+  }
+  inline void Swap(ApplyStagingManifestRequest* other) {
+    if (other == this) return;
+  #ifdef PROTOBUF_FORCE_COPY_IN_SWAP
+    if (GetOwningArena() != nullptr &&
+        GetOwningArena() == other->GetOwningArena()) {
+   #else  // PROTOBUF_FORCE_COPY_IN_SWAP
+    if (GetOwningArena() == other->GetOwningArena()) {
+  #endif  // !PROTOBUF_FORCE_COPY_IN_SWAP
+      InternalSwap(other);
+    } else {
+      ::PROTOBUF_NAMESPACE_ID::internal::GenericSwap(this, other);
+    }
+  }
+  void UnsafeArenaSwap(ApplyStagingManifestRequest* other) {
+    if (other == this) return;
+    GOOGLE_DCHECK(GetOwningArena() == other->GetOwningArena());
+    InternalSwap(other);
+  }
+
+  // implements Message ----------------------------------------------
+
+  ApplyStagingManifestRequest* New(::PROTOBUF_NAMESPACE_ID::Arena* arena = nullptr) const final {
+    return CreateMaybeMessage<ApplyStagingManifestRequest>(arena);
+  }
+  using ::PROTOBUF_NAMESPACE_ID::Message::CopyFrom;
+  void CopyFrom(const ApplyStagingManifestRequest& from);
+  using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom;
+  void MergeFrom( const ApplyStagingManifestRequest& from) {
+    ApplyStagingManifestRequest::MergeImpl(*this, from);
+  }
+  private:
+  static void MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg);
+  public:
+  PROTOBUF_ATTRIBUTE_REINITIALIZES void Clear() final;
+  bool IsInitialized() const final;
+
+  size_t ByteSizeLong() const final;
+  const char* _InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::internal::ParseContext* ctx) final;
+  uint8_t* _InternalSerialize(
+      uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const final;
+  int GetCachedSize() const final { return _impl_._cached_size_.Get(); }
+
+  private:
+  void SharedCtor(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned);
+  void SharedDtor();
+  void SetCachedSize(int size) const final;
+  void InternalSwap(ApplyStagingManifestRequest* other);
+
+  private:
+  friend class ::PROTOBUF_NAMESPACE_ID::internal::AnyMetadata;
+  static ::PROTOBUF_NAMESPACE_ID::StringPiece FullMessageName() {
+    return "greptime.v1.region.ApplyStagingManifestRequest";
+  }
+  protected:
+  explicit ApplyStagingManifestRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
+                       bool is_message_owned = false);
+  public:
+
+  static const ClassData _class_data_;
+  const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*GetClassData() const final;
+
+  ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final;
+
+  // nested types ----------------------------------------------------
+
+  // accessors -------------------------------------------------------
+
+  enum : int {
+    kPartitionExprFieldNumber = 2,
+    kFilesToAddFieldNumber = 3,
+    kRegionIdFieldNumber = 1,
+  };
+  // string partition_expr = 2;
+  void clear_partition_expr();
+  const std::string& partition_expr() const;
+  template <typename ArgT0 = const std::string&, typename... ArgT>
+  void set_partition_expr(ArgT0&& arg0, ArgT... args);
+  std::string* mutable_partition_expr();
+  PROTOBUF_NODISCARD std::string* release_partition_expr();
+  void set_allocated_partition_expr(std::string* partition_expr);
+  private:
+  const std::string& _internal_partition_expr() const;
+  inline PROTOBUF_ALWAYS_INLINE void _internal_set_partition_expr(const std::string& value);
+  std::string* _internal_mutable_partition_expr();
+  public:
+
+  // .greptime.v1.region.FileMetas files_to_add = 3;
+  bool has_files_to_add() const;
+  private:
+  bool _internal_has_files_to_add() const;
+  public:
+  void clear_files_to_add();
+  const ::greptime::v1::region::FileMetas& files_to_add() const;
+  PROTOBUF_NODISCARD ::greptime::v1::region::FileMetas* release_files_to_add();
+  ::greptime::v1::region::FileMetas* mutable_files_to_add();
+  void set_allocated_files_to_add(::greptime::v1::region::FileMetas* files_to_add);
+  private:
+  const ::greptime::v1::region::FileMetas& _internal_files_to_add() const;
+  ::greptime::v1::region::FileMetas* _internal_mutable_files_to_add();
+  public:
+  void unsafe_arena_set_allocated_files_to_add(
+      ::greptime::v1::region::FileMetas* files_to_add);
+  ::greptime::v1::region::FileMetas* unsafe_arena_release_files_to_add();
+
+  // uint64 region_id = 1;
+  void clear_region_id();
+  uint64_t region_id() const;
+  void set_region_id(uint64_t value);
+  private:
+  uint64_t _internal_region_id() const;
+  void _internal_set_region_id(uint64_t value);
+  public:
+
+  // @@protoc_insertion_point(class_scope:greptime.v1.region.ApplyStagingManifestRequest)
+ private:
+  class _Internal;
+
+  template <typename T> friend class ::PROTOBUF_NAMESPACE_ID::Arena::InternalHelper;
+  typedef void InternalArenaConstructable_;
+  typedef void DestructorSkippable_;
+  struct Impl_ {
+    ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr partition_expr_;
+    ::greptime::v1::region::FileMetas* files_to_add_;
+    uint64_t region_id_;
+    mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
+  };
+  union { Impl_ _impl_; };
+  friend struct ::TableStruct_greptime_2fv1_2fregion_2fserver_2eproto;
+};
 // ===================================================================
 
 
@@ -8272,6 +8639,80 @@ inline ::greptime::v1::region::BuildIndexRequest* RegionRequest::mutable_build_i
   return _msg;
 }
 
+// .greptime.v1.region.ApplyStagingManifestRequest apply_staging_manifest = 20;
+inline bool RegionRequest::_internal_has_apply_staging_manifest() const {
+  return body_case() == kApplyStagingManifest;
+}
+inline bool RegionRequest::has_apply_staging_manifest() const {
+  return _internal_has_apply_staging_manifest();
+}
+inline void RegionRequest::set_has_apply_staging_manifest() {
+  _impl_._oneof_case_[0] = kApplyStagingManifest;
+}
+inline void RegionRequest::clear_apply_staging_manifest() {
+  if (_internal_has_apply_staging_manifest()) {
+    if (GetArenaForAllocation() == nullptr) {
+      delete _impl_.body_.apply_staging_manifest_;
+    }
+    clear_has_body();
+  }
+}
+inline ::greptime::v1::region::ApplyStagingManifestRequest* RegionRequest::release_apply_staging_manifest() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.RegionRequest.apply_staging_manifest)
+  if (_internal_has_apply_staging_manifest()) {
+    clear_has_body();
+    ::greptime::v1::region::ApplyStagingManifestRequest* temp = _impl_.body_.apply_staging_manifest_;
+    if (GetArenaForAllocation() != nullptr) {
+      temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+    }
+    _impl_.body_.apply_staging_manifest_ = nullptr;
+    return temp;
+  } else {
+    return nullptr;
+  }
+}
+inline const ::greptime::v1::region::ApplyStagingManifestRequest& RegionRequest::_internal_apply_staging_manifest() const {
+  return _internal_has_apply_staging_manifest()
+      ? *_impl_.body_.apply_staging_manifest_
+      : reinterpret_cast< ::greptime::v1::region::ApplyStagingManifestRequest&>(::greptime::v1::region::_ApplyStagingManifestRequest_default_instance_);
+}
+inline const ::greptime::v1::region::ApplyStagingManifestRequest& RegionRequest::apply_staging_manifest() const {
+  // @@protoc_insertion_point(field_get:greptime.v1.region.RegionRequest.apply_staging_manifest)
+  return _internal_apply_staging_manifest();
+}
+inline ::greptime::v1::region::ApplyStagingManifestRequest* RegionRequest::unsafe_arena_release_apply_staging_manifest() {
+  // @@protoc_insertion_point(field_unsafe_arena_release:greptime.v1.region.RegionRequest.apply_staging_manifest)
+  if (_internal_has_apply_staging_manifest()) {
+    clear_has_body();
+    ::greptime::v1::region::ApplyStagingManifestRequest* temp = _impl_.body_.apply_staging_manifest_;
+    _impl_.body_.apply_staging_manifest_ = nullptr;
+    return temp;
+  } else {
+    return nullptr;
+  }
+}
+inline void RegionRequest::unsafe_arena_set_allocated_apply_staging_manifest(::greptime::v1::region::ApplyStagingManifestRequest* apply_staging_manifest) {
+  clear_body();
+  if (apply_staging_manifest) {
+    set_has_apply_staging_manifest();
+    _impl_.body_.apply_staging_manifest_ = apply_staging_manifest;
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.RegionRequest.apply_staging_manifest)
+}
+inline ::greptime::v1::region::ApplyStagingManifestRequest* RegionRequest::_internal_mutable_apply_staging_manifest() {
+  if (!_internal_has_apply_staging_manifest()) {
+    clear_body();
+    set_has_apply_staging_manifest();
+    _impl_.body_.apply_staging_manifest_ = CreateMaybeMessage< ::greptime::v1::region::ApplyStagingManifestRequest >(GetArenaForAllocation());
+  }
+  return _impl_.body_.apply_staging_manifest_;
+}
+inline ::greptime::v1::region::ApplyStagingManifestRequest* RegionRequest::mutable_apply_staging_manifest() {
+  ::greptime::v1::region::ApplyStagingManifestRequest* _msg = _internal_mutable_apply_staging_manifest();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.RegionRequest.apply_staging_manifest)
+  return _msg;
+}
+
 inline bool RegionRequest::has_body() const {
   return body_case() != BODY_NOT_SET;
 }
@@ -11819,6 +12260,224 @@ inline void BuildIndexRequest::set_region_id(uint64_t value) {
   // @@protoc_insertion_point(field_set:greptime.v1.region.BuildIndexRequest.region_id)
 }
 
+// -------------------------------------------------------------------
+
+// FileMetas
+
+// bytes data = 1;
+inline void FileMetas::clear_data() {
+  _impl_.data_.ClearToEmpty();
+}
+inline const std::string& FileMetas::data() const {
+  // @@protoc_insertion_point(field_get:greptime.v1.region.FileMetas.data)
+  return _internal_data();
+}
+template <typename ArgT0, typename... ArgT>
+inline PROTOBUF_ALWAYS_INLINE
+void FileMetas::set_data(ArgT0&& arg0, ArgT... args) {
+ 
+ _impl_.data_.SetBytes(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
+  // @@protoc_insertion_point(field_set:greptime.v1.region.FileMetas.data)
+}
+inline std::string* FileMetas::mutable_data() {
+  std::string* _s = _internal_mutable_data();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.FileMetas.data)
+  return _s;
+}
+inline const std::string& FileMetas::_internal_data() const {
+  return _impl_.data_.Get();
+}
+inline void FileMetas::_internal_set_data(const std::string& value) {
+  
+  _impl_.data_.Set(value, GetArenaForAllocation());
+}
+inline std::string* FileMetas::_internal_mutable_data() {
+  
+  return _impl_.data_.Mutable(GetArenaForAllocation());
+}
+inline std::string* FileMetas::release_data() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.FileMetas.data)
+  return _impl_.data_.Release();
+}
+inline void FileMetas::set_allocated_data(std::string* data) {
+  if (data != nullptr) {
+    
+  } else {
+    
+  }
+  _impl_.data_.SetAllocated(data, GetArenaForAllocation());
+#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  if (_impl_.data_.IsDefault()) {
+    _impl_.data_.Set("", GetArenaForAllocation());
+  }
+#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.FileMetas.data)
+}
+
+// -------------------------------------------------------------------
+
+// ApplyStagingManifestRequest
+
+// uint64 region_id = 1;
+inline void ApplyStagingManifestRequest::clear_region_id() {
+  _impl_.region_id_ = uint64_t{0u};
+}
+inline uint64_t ApplyStagingManifestRequest::_internal_region_id() const {
+  return _impl_.region_id_;
+}
+inline uint64_t ApplyStagingManifestRequest::region_id() const {
+  // @@protoc_insertion_point(field_get:greptime.v1.region.ApplyStagingManifestRequest.region_id)
+  return _internal_region_id();
+}
+inline void ApplyStagingManifestRequest::_internal_set_region_id(uint64_t value) {
+  
+  _impl_.region_id_ = value;
+}
+inline void ApplyStagingManifestRequest::set_region_id(uint64_t value) {
+  _internal_set_region_id(value);
+  // @@protoc_insertion_point(field_set:greptime.v1.region.ApplyStagingManifestRequest.region_id)
+}
+
+// string partition_expr = 2;
+inline void ApplyStagingManifestRequest::clear_partition_expr() {
+  _impl_.partition_expr_.ClearToEmpty();
+}
+inline const std::string& ApplyStagingManifestRequest::partition_expr() const {
+  // @@protoc_insertion_point(field_get:greptime.v1.region.ApplyStagingManifestRequest.partition_expr)
+  return _internal_partition_expr();
+}
+template <typename ArgT0, typename... ArgT>
+inline PROTOBUF_ALWAYS_INLINE
+void ApplyStagingManifestRequest::set_partition_expr(ArgT0&& arg0, ArgT... args) {
+ 
+ _impl_.partition_expr_.Set(static_cast<ArgT0 &&>(arg0), args..., GetArenaForAllocation());
+  // @@protoc_insertion_point(field_set:greptime.v1.region.ApplyStagingManifestRequest.partition_expr)
+}
+inline std::string* ApplyStagingManifestRequest::mutable_partition_expr() {
+  std::string* _s = _internal_mutable_partition_expr();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.ApplyStagingManifestRequest.partition_expr)
+  return _s;
+}
+inline const std::string& ApplyStagingManifestRequest::_internal_partition_expr() const {
+  return _impl_.partition_expr_.Get();
+}
+inline void ApplyStagingManifestRequest::_internal_set_partition_expr(const std::string& value) {
+  
+  _impl_.partition_expr_.Set(value, GetArenaForAllocation());
+}
+inline std::string* ApplyStagingManifestRequest::_internal_mutable_partition_expr() {
+  
+  return _impl_.partition_expr_.Mutable(GetArenaForAllocation());
+}
+inline std::string* ApplyStagingManifestRequest::release_partition_expr() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.ApplyStagingManifestRequest.partition_expr)
+  return _impl_.partition_expr_.Release();
+}
+inline void ApplyStagingManifestRequest::set_allocated_partition_expr(std::string* partition_expr) {
+  if (partition_expr != nullptr) {
+    
+  } else {
+    
+  }
+  _impl_.partition_expr_.SetAllocated(partition_expr, GetArenaForAllocation());
+#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  if (_impl_.partition_expr_.IsDefault()) {
+    _impl_.partition_expr_.Set("", GetArenaForAllocation());
+  }
+#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.ApplyStagingManifestRequest.partition_expr)
+}
+
+// .greptime.v1.region.FileMetas files_to_add = 3;
+inline bool ApplyStagingManifestRequest::_internal_has_files_to_add() const {
+  return this != internal_default_instance() && _impl_.files_to_add_ != nullptr;
+}
+inline bool ApplyStagingManifestRequest::has_files_to_add() const {
+  return _internal_has_files_to_add();
+}
+inline void ApplyStagingManifestRequest::clear_files_to_add() {
+  if (GetArenaForAllocation() == nullptr && _impl_.files_to_add_ != nullptr) {
+    delete _impl_.files_to_add_;
+  }
+  _impl_.files_to_add_ = nullptr;
+}
+inline const ::greptime::v1::region::FileMetas& ApplyStagingManifestRequest::_internal_files_to_add() const {
+  const ::greptime::v1::region::FileMetas* p = _impl_.files_to_add_;
+  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::region::FileMetas&>(
+      ::greptime::v1::region::_FileMetas_default_instance_);
+}
+inline const ::greptime::v1::region::FileMetas& ApplyStagingManifestRequest::files_to_add() const {
+  // @@protoc_insertion_point(field_get:greptime.v1.region.ApplyStagingManifestRequest.files_to_add)
+  return _internal_files_to_add();
+}
+inline void ApplyStagingManifestRequest::unsafe_arena_set_allocated_files_to_add(
+    ::greptime::v1::region::FileMetas* files_to_add) {
+  if (GetArenaForAllocation() == nullptr) {
+    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.files_to_add_);
+  }
+  _impl_.files_to_add_ = files_to_add;
+  if (files_to_add) {
+    
+  } else {
+    
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.ApplyStagingManifestRequest.files_to_add)
+}
+inline ::greptime::v1::region::FileMetas* ApplyStagingManifestRequest::release_files_to_add() {
+  
+  ::greptime::v1::region::FileMetas* temp = _impl_.files_to_add_;
+  _impl_.files_to_add_ = nullptr;
+#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
+  auto* old =  reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
+  temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  if (GetArenaForAllocation() == nullptr) { delete old; }
+#else  // PROTOBUF_FORCE_COPY_IN_RELEASE
+  if (GetArenaForAllocation() != nullptr) {
+    temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
+  }
+#endif  // !PROTOBUF_FORCE_COPY_IN_RELEASE
+  return temp;
+}
+inline ::greptime::v1::region::FileMetas* ApplyStagingManifestRequest::unsafe_arena_release_files_to_add() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.ApplyStagingManifestRequest.files_to_add)
+  
+  ::greptime::v1::region::FileMetas* temp = _impl_.files_to_add_;
+  _impl_.files_to_add_ = nullptr;
+  return temp;
+}
+inline ::greptime::v1::region::FileMetas* ApplyStagingManifestRequest::_internal_mutable_files_to_add() {
+  
+  if (_impl_.files_to_add_ == nullptr) {
+    auto* p = CreateMaybeMessage<::greptime::v1::region::FileMetas>(GetArenaForAllocation());
+    _impl_.files_to_add_ = p;
+  }
+  return _impl_.files_to_add_;
+}
+inline ::greptime::v1::region::FileMetas* ApplyStagingManifestRequest::mutable_files_to_add() {
+  ::greptime::v1::region::FileMetas* _msg = _internal_mutable_files_to_add();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.ApplyStagingManifestRequest.files_to_add)
+  return _msg;
+}
+inline void ApplyStagingManifestRequest::set_allocated_files_to_add(::greptime::v1::region::FileMetas* files_to_add) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  if (message_arena == nullptr) {
+    delete _impl_.files_to_add_;
+  }
+  if (files_to_add) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(files_to_add);
+    if (message_arena != submessage_arena) {
+      files_to_add = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, files_to_add, submessage_arena);
+    }
+    
+  } else {
+    
+  }
+  _impl_.files_to_add_ = files_to_add;
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.ApplyStagingManifestRequest.files_to_add)
+}
+
 #ifdef __GNUC__
   #pragma GCC diagnostic pop
 #endif  // __GNUC__
@@ -11896,6 +12555,10 @@ inline void BuildIndexRequest::set_region_id(uint64_t value) {
 
 // -------------------------------------------------------------------
 
+// -------------------------------------------------------------------
+
+// -------------------------------------------------------------------
+
 
 // @@protoc_insertion_point(namespace_scope)
 

proto/greptime/v1/region/server.proto

@@ -60,6 +60,7 @@ message RegionRequest {
     SyncRequest sync = 17;
     ListMetadataRequest list_metadata = 18;
     BuildIndexRequest build_index = 19;
+    ApplyStagingManifestRequest apply_staging_manifest = 20;
   }
 }
 
@@ -273,3 +274,19 @@ message ListMetadataRequest {
 message BuildIndexRequest {
   uint64 region_id = 1;
 }
+
+// The file metas of a staging manifest.
+// It is a json array of file metadatas.
+message FileMetas {
+  bytes data = 1;
+}
+
+/// Apply staging manifest request.
+message ApplyStagingManifestRequest {
+  // The target region id.
+  uint64 region_id = 1;
+  // The partition expression of the staging manifest.
+  string partition_expr = 2;
+  // The file metas to add to the staging manifest.
+  FileMetas files_to_add = 3;
+}