From 2aaee38de81047537dfa42af9df63bcfb866e06c Mon Sep 17 00:00:00 2001 From: Junfan Zhang Date: Fri, 24 Nov 2023 16:40:12 +0800 Subject: [PATCH 1/2] feat: add `IF EXISTS` for `DROP` (#123) * feat: add IF EXISTS for DROP For https://github.com/GreptimeTeam/greptimedb/issues/2794 * generate code Signed-off-by: Ruihang Xia --------- Signed-off-by: Ruihang Xia Co-authored-by: Ruihang Xia --- c++/greptime/v1/ddl.pb.cc | 124 +++++++---- c++/greptime/v1/ddl.pb.h | 31 +++ go/greptime/v1/ddl.pb.go | 200 +++++++++--------- java/src/main/java/io/greptime/v1/Ddl.java | 138 +++++++++--- .../main/java/io/greptime/v1/index/Index.java | 4 +- proto/greptime/v1/ddl.proto | 1 + 6 files changed, 323 insertions(+), 175 deletions(-) diff --git a/c++/greptime/v1/ddl.pb.cc b/c++/greptime/v1/ddl.pb.cc index 4e60b390..7e52ed55 100644 --- a/c++/greptime/v1/ddl.pb.cc +++ b/c++/greptime/v1/ddl.pb.cc @@ -93,6 +93,7 @@ PROTOBUF_CONSTEXPR DropTableExpr::DropTableExpr( , /*decltype(_impl_.schema_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.table_name_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} , /*decltype(_impl_.table_id_)*/nullptr + , /*decltype(_impl_.drop_if_exists_)*/false , /*decltype(_impl_._cached_size_)*/{}} {} struct DropTableExprDefaultTypeInternal { PROTOBUF_CONSTEXPR DropTableExprDefaultTypeInternal() @@ -326,6 +327,7 @@ const uint32_t TableStruct_greptime_2fv1_2fddl_2eproto::offsets[] PROTOBUF_SECTI PROTOBUF_FIELD_OFFSET(::greptime::v1::DropTableExpr, _impl_.schema_name_), PROTOBUF_FIELD_OFFSET(::greptime::v1::DropTableExpr, _impl_.table_name_), PROTOBUF_FIELD_OFFSET(::greptime::v1::DropTableExpr, _impl_.table_id_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::DropTableExpr, _impl_.drop_if_exists_), PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, _has_bits_), PROTOBUF_FIELD_OFFSET(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse, _internal_metadata_), ~0u, // no _extensions_ @@ -426,17 +428,17 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 22, -1, -1, sizeof(::greptime::v1::CreateTableExpr)}, { 39, -1, -1, sizeof(::greptime::v1::AlterExpr)}, { 52, -1, -1, sizeof(::greptime::v1::DropTableExpr)}, - { 62, 70, -1, sizeof(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse)}, - { 72, -1, -1, sizeof(::greptime::v1::CreateDatabaseExpr)}, - { 81, -1, -1, sizeof(::greptime::v1::TruncateTableExpr)}, - { 91, -1, -1, sizeof(::greptime::v1::AddColumns)}, - { 98, -1, -1, sizeof(::greptime::v1::DropColumns)}, - { 105, -1, -1, sizeof(::greptime::v1::RenameTable)}, - { 112, -1, -1, sizeof(::greptime::v1::AddColumn)}, - { 120, -1, -1, sizeof(::greptime::v1::DropColumn)}, - { 127, -1, -1, sizeof(::greptime::v1::TableId)}, - { 134, -1, -1, sizeof(::greptime::v1::ColumnDef)}, - { 147, -1, -1, sizeof(::greptime::v1::AddColumnLocation)}, + { 63, 71, -1, sizeof(::greptime::v1::CreateDatabaseExpr_OptionsEntry_DoNotUse)}, + { 73, -1, -1, sizeof(::greptime::v1::CreateDatabaseExpr)}, + { 82, -1, -1, sizeof(::greptime::v1::TruncateTableExpr)}, + { 92, -1, -1, sizeof(::greptime::v1::AddColumns)}, + { 99, -1, -1, sizeof(::greptime::v1::DropColumns)}, + { 106, -1, -1, sizeof(::greptime::v1::RenameTable)}, + { 113, -1, -1, sizeof(::greptime::v1::AddColumn)}, + { 121, -1, -1, sizeof(::greptime::v1::DropColumn)}, + { 128, -1, -1, sizeof(::greptime::v1::TableId)}, + { 135, -1, -1, sizeof(::greptime::v1::ColumnDef)}, + { 148, -1, -1, sizeof(::greptime::v1::AddColumnLocation)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -483,45 +485,46 @@ const char descriptor_table_protodef_greptime_2fv1_2fddl_2eproto[] PROTOBUF_SECT "2\027.greptime.v1.AddColumnsH\000\0220\n\014drop_colu" "mns\030\005 \001(\0132\030.greptime.v1.DropColumnsH\000\0220\n" "\014rename_table\030\006 \001(\0132\030.greptime.v1.Rename" - "TableH\000B\006\n\004kind\"v\n\rDropTableExpr\022\024\n\014cata" - "log_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\nt" - "able_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.grep" - "time.v1.TableId\"\270\001\n\022CreateDatabaseExpr\022\025" - "\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if_not_e" - "xists\030\002 \001(\010\022=\n\007options\030\003 \003(\0132,.greptime." - "v1.CreateDatabaseExpr.OptionsEntry\032.\n\014Op" - "tionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002" - "8\001\"z\n\021TruncateTableExpr\022\024\n\014catalog_name\030" - "\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\ntable_name" - "\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.greptime.v1.T" - "ableId\"9\n\nAddColumns\022+\n\013add_columns\030\001 \003(" - "\0132\026.greptime.v1.AddColumn\"<\n\013DropColumns" - "\022-\n\014drop_columns\030\001 \003(\0132\027.greptime.v1.Dro" - "pColumn\"%\n\013RenameTable\022\026\n\016new_table_name" - "\030\001 \001(\t\"i\n\tAddColumn\022*\n\ncolumn_def\030\001 \001(\0132" - "\026.greptime.v1.ColumnDef\0220\n\010location\030\003 \001(" - "\0132\036.greptime.v1.AddColumnLocation\"\032\n\nDro" - "pColumn\022\014\n\004name\030\001 \001(\t\"\025\n\007TableId\022\n\n\002id\030\001" - " \001(\r\"\377\001\n\tColumnDef\022\014\n\004name\030\001 \001(\t\022.\n\tdata" - "_type\030\002 \001(\0162\033.greptime.v1.ColumnDataType" - "\022\023\n\013is_nullable\030\003 \001(\010\022\032\n\022default_constra" - "int\030\004 \001(\014\0220\n\rsemantic_type\030\005 \001(\0162\031.grept" - "ime.v1.SemanticType\022\017\n\007comment\030\006 \001(\t\022@\n\022" - "datatype_extension\030\007 \001(\0132$.greptime.v1.C" - "olumnDataTypeExtension\"\230\001\n\021AddColumnLoca" - "tion\022B\n\rlocation_type\030\001 \001(\0162+.greptime.v" - "1.AddColumnLocation.LocationType\022\031\n\021afte" - "r_column_name\030\002 \001(\t\"$\n\014LocationType\022\t\n\005F" - "IRST\020\000\022\t\n\005AFTER\020\001BL\n\016io.greptime.v1B\003Ddl" - "Z5github.com/GreptimeTeam/greptime-proto" - "/go/greptime/v1b\006proto3" + "TableH\000B\006\n\004kind\"\216\001\n\rDropTableExpr\022\024\n\014cat" + "alog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\n" + "table_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.gre" + "ptime.v1.TableId\022\026\n\016drop_if_exists\030\005 \001(\010" + "\"\270\001\n\022CreateDatabaseExpr\022\025\n\rdatabase_name" + "\030\001 \001(\t\022\034\n\024create_if_not_exists\030\002 \001(\010\022=\n\007" + "options\030\003 \003(\0132,.greptime.v1.CreateDataba" + "seExpr.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003k" + "ey\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"z\n\021TruncateT" + "ableExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023\n\013schema" + "_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022&\n\010table" + "_id\030\004 \001(\0132\024.greptime.v1.TableId\"9\n\nAddCo" + "lumns\022+\n\013add_columns\030\001 \003(\0132\026.greptime.v1" + ".AddColumn\"<\n\013DropColumns\022-\n\014drop_column" + "s\030\001 \003(\0132\027.greptime.v1.DropColumn\"%\n\013Rena" + "meTable\022\026\n\016new_table_name\030\001 \001(\t\"i\n\tAddCo" + "lumn\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.C" + "olumnDef\0220\n\010location\030\003 \001(\0132\036.greptime.v1" + ".AddColumnLocation\"\032\n\nDropColumn\022\014\n\004name" + "\030\001 \001(\t\"\025\n\007TableId\022\n\n\002id\030\001 \001(\r\"\377\001\n\tColumn" + "Def\022\014\n\004name\030\001 \001(\t\022.\n\tdata_type\030\002 \001(\0162\033.g" + "reptime.v1.ColumnDataType\022\023\n\013is_nullable" + "\030\003 \001(\010\022\032\n\022default_constraint\030\004 \001(\014\0220\n\rse" + "mantic_type\030\005 \001(\0162\031.greptime.v1.Semantic" + "Type\022\017\n\007comment\030\006 \001(\t\022@\n\022datatype_extens" + "ion\030\007 \001(\0132$.greptime.v1.ColumnDataTypeEx" + "tension\"\230\001\n\021AddColumnLocation\022B\n\rlocatio" + "n_type\030\001 \001(\0162+.greptime.v1.AddColumnLoca" + "tion.LocationType\022\031\n\021after_column_name\030\002" + " \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER" + "\020\001BL\n\016io.greptime.v1B\003DdlZ5github.com/Gr" + "eptimeTeam/greptime-proto/go/greptime/v1" + "b\006proto3" ; static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fddl_2eproto_deps[1] = { &::descriptor_table_greptime_2fv1_2fcommon_2eproto, }; static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fddl_2eproto_once; const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fddl_2eproto = { - false, false, 2223, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto, + false, false, 2248, descriptor_table_protodef_greptime_2fv1_2fddl_2eproto, "greptime/v1/ddl.proto", &descriptor_table_greptime_2fv1_2fddl_2eproto_once, descriptor_table_greptime_2fv1_2fddl_2eproto_deps, 1, 16, schemas, file_default_instances, TableStruct_greptime_2fv1_2fddl_2eproto::offsets, @@ -2258,6 +2261,7 @@ DropTableExpr::DropTableExpr(const DropTableExpr& from) , decltype(_impl_.schema_name_){} , decltype(_impl_.table_name_){} , decltype(_impl_.table_id_){nullptr} + , decltype(_impl_.drop_if_exists_){} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); @@ -2288,6 +2292,7 @@ DropTableExpr::DropTableExpr(const DropTableExpr& from) if (from._internal_has_table_id()) { _this->_impl_.table_id_ = new ::greptime::v1::TableId(*from._impl_.table_id_); } + _this->_impl_.drop_if_exists_ = from._impl_.drop_if_exists_; // @@protoc_insertion_point(copy_constructor:greptime.v1.DropTableExpr) } @@ -2300,6 +2305,7 @@ inline void DropTableExpr::SharedCtor( , decltype(_impl_.schema_name_){} , decltype(_impl_.table_name_){} , decltype(_impl_.table_id_){nullptr} + , decltype(_impl_.drop_if_exists_){false} , /*decltype(_impl_._cached_size_)*/{} }; _impl_.catalog_name_.InitDefault(); @@ -2350,6 +2356,7 @@ void DropTableExpr::Clear() { delete _impl_.table_id_; } _impl_.table_id_ = nullptr; + _impl_.drop_if_exists_ = false; _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(); } @@ -2397,6 +2404,14 @@ const char* DropTableExpr::_InternalParse(const char* ptr, ::_pbi::ParseContext* } else goto handle_unusual; continue; + // bool drop_if_exists = 5; + case 5: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 40)) { + _impl_.drop_if_exists_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -2463,6 +2478,12 @@ uint8_t* DropTableExpr::_InternalSerialize( _Internal::table_id(this).GetCachedSize(), target, stream); } + // bool drop_if_exists = 5; + if (this->_internal_drop_if_exists() != 0) { + target = stream->EnsureSpace(target); + target = ::_pbi::WireFormatLite::WriteBoolToArray(5, this->_internal_drop_if_exists(), 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); @@ -2507,6 +2528,11 @@ size_t DropTableExpr::ByteSizeLong() const { *_impl_.table_id_); } + // bool drop_if_exists = 5; + if (this->_internal_drop_if_exists() != 0) { + total_size += 1 + 1; + } + return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_); } @@ -2538,6 +2564,9 @@ void DropTableExpr::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const :: _this->_internal_mutable_table_id()->::greptime::v1::TableId::MergeFrom( from._internal_table_id()); } + if (from._internal_drop_if_exists() != 0) { + _this->_internal_set_drop_if_exists(from._internal_drop_if_exists()); + } _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); } @@ -2569,7 +2598,12 @@ void DropTableExpr::InternalSwap(DropTableExpr* other) { &_impl_.table_name_, lhs_arena, &other->_impl_.table_name_, rhs_arena ); - swap(_impl_.table_id_, other->_impl_.table_id_); + ::PROTOBUF_NAMESPACE_ID::internal::memswap< + PROTOBUF_FIELD_OFFSET(DropTableExpr, _impl_.drop_if_exists_) + + sizeof(DropTableExpr::_impl_.drop_if_exists_) + - PROTOBUF_FIELD_OFFSET(DropTableExpr, _impl_.table_id_)>( + reinterpret_cast(&_impl_.table_id_), + reinterpret_cast(&other->_impl_.table_id_)); } ::PROTOBUF_NAMESPACE_ID::Metadata DropTableExpr::GetMetadata() const { diff --git a/c++/greptime/v1/ddl.pb.h b/c++/greptime/v1/ddl.pb.h index 8a44b63f..e9b6c3d7 100644 --- a/c++/greptime/v1/ddl.pb.h +++ b/c++/greptime/v1/ddl.pb.h @@ -1166,6 +1166,7 @@ class DropTableExpr final : kSchemaNameFieldNumber = 2, kTableNameFieldNumber = 3, kTableIdFieldNumber = 4, + kDropIfExistsFieldNumber = 5, }; // string catalog_name = 1; void clear_catalog_name(); @@ -1227,6 +1228,15 @@ class DropTableExpr final : ::greptime::v1::TableId* table_id); ::greptime::v1::TableId* unsafe_arena_release_table_id(); + // bool drop_if_exists = 5; + void clear_drop_if_exists(); + bool drop_if_exists() const; + void set_drop_if_exists(bool value); + private: + bool _internal_drop_if_exists() const; + void _internal_set_drop_if_exists(bool value); + public: + // @@protoc_insertion_point(class_scope:greptime.v1.DropTableExpr) private: class _Internal; @@ -1239,6 +1249,7 @@ class DropTableExpr final : ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr schema_name_; ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr table_name_; ::greptime::v1::TableId* table_id_; + bool drop_if_exists_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; union { Impl_ _impl_; }; @@ -4623,6 +4634,26 @@ inline void DropTableExpr::set_allocated_table_id(::greptime::v1::TableId* table // @@protoc_insertion_point(field_set_allocated:greptime.v1.DropTableExpr.table_id) } +// bool drop_if_exists = 5; +inline void DropTableExpr::clear_drop_if_exists() { + _impl_.drop_if_exists_ = false; +} +inline bool DropTableExpr::_internal_drop_if_exists() const { + return _impl_.drop_if_exists_; +} +inline bool DropTableExpr::drop_if_exists() const { + // @@protoc_insertion_point(field_get:greptime.v1.DropTableExpr.drop_if_exists) + return _internal_drop_if_exists(); +} +inline void DropTableExpr::_internal_set_drop_if_exists(bool value) { + + _impl_.drop_if_exists_ = value; +} +inline void DropTableExpr::set_drop_if_exists(bool value) { + _internal_set_drop_if_exists(value); + // @@protoc_insertion_point(field_set:greptime.v1.DropTableExpr.drop_if_exists) +} + // ------------------------------------------------------------------- // ------------------------------------------------------------------- diff --git a/go/greptime/v1/ddl.pb.go b/go/greptime/v1/ddl.pb.go index 0fcb4908..9e04e9b3 100644 --- a/go/greptime/v1/ddl.pb.go +++ b/go/greptime/v1/ddl.pb.go @@ -458,10 +458,11 @@ type DropTableExpr struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` - SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` - TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` - TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` + CatalogName string `protobuf:"bytes,1,opt,name=catalog_name,json=catalogName,proto3" json:"catalog_name,omitempty"` + SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` + TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + TableId *TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` + DropIfExists bool `protobuf:"varint,5,opt,name=drop_if_exists,json=dropIfExists,proto3" json:"drop_if_exists,omitempty"` } func (x *DropTableExpr) Reset() { @@ -524,6 +525,13 @@ func (x *DropTableExpr) GetTableId() *TableId { return nil } +func (x *DropTableExpr) GetDropIfExists() bool { + if x != nil { + return x.DropIfExists + } + return false +} + type CreateDatabaseExpr struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -1180,7 +1188,7 @@ var file_greptime_v1_ddl_proto_rawDesc = []byte{ 0x28, 0x0b, 0x32, 0x18, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x6e, 0x61, 0x6d, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x48, 0x00, 0x52, 0x0b, 0x72, 0x65, 0x6e, 0x61, 0x6d, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x42, 0x06, 0x0a, 0x04, 0x6b, - 0x69, 0x6e, 0x64, 0x22, 0xa3, 0x01, 0x0a, 0x0d, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, + 0x69, 0x6e, 0x64, 0x22, 0xc9, 0x01, 0x0a, 0x0d, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x63, 0x68, 0x65, @@ -1190,96 +1198,98 @@ var file_greptime_v1_ddl_proto_rawDesc = []byte{ 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, - 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x22, 0xee, 0x01, 0x0a, 0x12, 0x43, 0x72, - 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, - 0x12, 0x23, 0x0a, 0x0d, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, - 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x14, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, - 0x69, 0x66, 0x5f, 0x6e, 0x6f, 0x74, 0x5f, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x08, 0x52, 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x49, 0x66, 0x4e, 0x6f, 0x74, - 0x45, 0x78, 0x69, 0x73, 0x74, 0x73, 0x12, 0x46, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, - 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, - 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x2e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, - 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x3a, - 0x0a, 0x0c, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, - 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, - 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0xa7, 0x01, 0x0a, 0x11, 0x54, - 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, - 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, - 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, - 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, - 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, - 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4e, - 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, - 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, - 0x6c, 0x65, 0x49, 0x64, 0x22, 0x45, 0x0a, 0x0a, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, - 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x0b, 0x61, 0x64, 0x64, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, - 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, - 0x0a, 0x61, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0x49, 0x0a, 0x0b, 0x44, - 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x3a, 0x0a, 0x0c, 0x64, 0x72, - 0x6f, 0x70, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, - 0x32, 0x17, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, - 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x0b, 0x64, 0x72, 0x6f, 0x70, 0x43, - 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0x33, 0x0a, 0x0b, 0x52, 0x65, 0x6e, 0x61, 0x6d, 0x65, - 0x54, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x0e, 0x6e, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x62, - 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6e, - 0x65, 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x7e, 0x0a, 0x09, 0x41, - 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x35, 0x0a, 0x0a, 0x63, 0x6f, 0x6c, 0x75, - 0x6d, 0x6e, 0x5f, 0x64, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, - 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, - 0x6e, 0x44, 0x65, 0x66, 0x52, 0x09, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, - 0x3a, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, - 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, - 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, - 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x20, 0x0a, 0x0a, 0x44, - 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, - 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x22, 0x19, 0x0a, - 0x07, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x69, 0x64, 0x22, 0xd8, 0x02, 0x0a, 0x09, 0x43, 0x6f, 0x6c, - 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x38, 0x0a, 0x09, 0x64, 0x61, - 0x74, 0x61, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1b, 0x2e, - 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, - 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, - 0x54, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x73, 0x5f, 0x6e, 0x75, 0x6c, 0x6c, 0x61, - 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, 0x0a, 0x69, 0x73, 0x4e, 0x75, 0x6c, - 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x2d, 0x0a, 0x12, 0x64, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, - 0x5f, 0x63, 0x6f, 0x6e, 0x73, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, - 0x0c, 0x52, 0x11, 0x64, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x43, 0x6f, 0x6e, 0x73, 0x74, 0x72, - 0x61, 0x69, 0x6e, 0x74, 0x12, 0x3e, 0x0a, 0x0d, 0x73, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, - 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x19, 0x2e, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x53, 0x65, 0x6d, 0x61, 0x6e, 0x74, - 0x69, 0x63, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0c, 0x73, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, - 0x54, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x18, - 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x53, - 0x0a, 0x12, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x65, 0x78, 0x74, 0x65, 0x6e, - 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, - 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, - 0x52, 0x11, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, - 0x69, 0x6f, 0x6e, 0x22, 0xb7, 0x01, 0x0a, 0x11, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, - 0x6e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x50, 0x0a, 0x0d, 0x6c, 0x6f, 0x63, - 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, - 0x32, 0x2b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, - 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, - 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0c, 0x6c, - 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x2a, 0x0a, 0x11, 0x61, - 0x66, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x66, 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6c, - 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x24, 0x0a, 0x0c, 0x4c, 0x6f, 0x63, 0x61, 0x74, - 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x46, 0x49, 0x52, 0x53, 0x54, - 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, 0x52, 0x10, 0x01, 0x42, 0x4c, 0x0a, - 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, - 0x03, 0x44, 0x64, 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, - 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, - 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, - 0x74, 0x6f, 0x33, + 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x24, 0x0a, 0x0e, 0x64, 0x72, 0x6f, + 0x70, 0x5f, 0x69, 0x66, 0x5f, 0x65, 0x78, 0x69, 0x73, 0x74, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, + 0x08, 0x52, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x49, 0x66, 0x45, 0x78, 0x69, 0x73, 0x74, 0x73, 0x22, + 0xee, 0x01, 0x0a, 0x12, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x23, 0x0a, 0x0d, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x64, + 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x14, 0x63, + 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x69, 0x66, 0x5f, 0x6e, 0x6f, 0x74, 0x5f, 0x65, 0x78, 0x69, + 0x73, 0x74, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, + 0x65, 0x49, 0x66, 0x4e, 0x6f, 0x74, 0x45, 0x78, 0x69, 0x73, 0x74, 0x73, 0x12, 0x46, 0x0a, 0x07, + 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, + 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x45, 0x78, 0x70, 0x72, 0x2e, 0x4f, + 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x07, 0x6f, 0x70, 0x74, + 0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x3a, 0x0a, 0x0c, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x45, + 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, + 0x22, 0xa7, 0x01, 0x0a, 0x11, 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, + 0x6c, 0x65, 0x45, 0x78, 0x70, 0x72, 0x12, 0x21, 0x0a, 0x0c, 0x63, 0x61, 0x74, 0x61, 0x6c, 0x6f, + 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x63, 0x61, + 0x74, 0x61, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x63, 0x68, + 0x65, 0x6d, 0x61, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, + 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x1d, 0x0a, 0x0a, 0x74, 0x61, + 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, + 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x2f, 0x0a, 0x08, 0x74, 0x61, 0x62, + 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, + 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, + 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x22, 0x45, 0x0a, 0x0a, 0x41, 0x64, + 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x12, 0x37, 0x0a, 0x0b, 0x61, 0x64, 0x64, 0x5f, + 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, 0x0a, 0x61, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, + 0x73, 0x22, 0x49, 0x0a, 0x0b, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, + 0x12, 0x3a, 0x0a, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, + 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x17, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x52, + 0x0b, 0x64, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x73, 0x22, 0x33, 0x0a, 0x0b, + 0x52, 0x65, 0x6e, 0x61, 0x6d, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x24, 0x0a, 0x0e, 0x6e, + 0x65, 0x77, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x0c, 0x6e, 0x65, 0x77, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4e, 0x61, 0x6d, + 0x65, 0x22, 0x7e, 0x0a, 0x09, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, 0x35, + 0x0a, 0x0a, 0x63, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x5f, 0x64, 0x65, 0x66, 0x18, 0x01, 0x20, 0x01, + 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, + 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x52, 0x09, 0x63, 0x6f, 0x6c, 0x75, + 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x3a, 0x0a, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, + 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, + 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4c, + 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, + 0x6e, 0x22, 0x20, 0x0a, 0x0a, 0x44, 0x72, 0x6f, 0x70, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x12, + 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, + 0x61, 0x6d, 0x65, 0x22, 0x19, 0x0a, 0x07, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x0e, + 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x02, 0x69, 0x64, 0x22, 0xd8, + 0x02, 0x0a, 0x09, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x65, 0x66, 0x12, 0x12, 0x0a, 0x04, + 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, + 0x12, 0x38, 0x0a, 0x09, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x0e, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, + 0x31, 0x2e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, + 0x52, 0x08, 0x64, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x12, 0x1f, 0x0a, 0x0b, 0x69, 0x73, + 0x5f, 0x6e, 0x75, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x08, 0x52, + 0x0a, 0x69, 0x73, 0x4e, 0x75, 0x6c, 0x6c, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x2d, 0x0a, 0x12, 0x64, + 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, 0x5f, 0x63, 0x6f, 0x6e, 0x73, 0x74, 0x72, 0x61, 0x69, 0x6e, + 0x74, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x11, 0x64, 0x65, 0x66, 0x61, 0x75, 0x6c, 0x74, + 0x43, 0x6f, 0x6e, 0x73, 0x74, 0x72, 0x61, 0x69, 0x6e, 0x74, 0x12, 0x3e, 0x0a, 0x0d, 0x73, 0x65, + 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, + 0x0e, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x53, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, 0x54, 0x79, 0x70, 0x65, 0x52, 0x0c, 0x73, 0x65, + 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, 0x54, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x63, 0x6f, + 0x6d, 0x6d, 0x65, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x63, 0x6f, 0x6d, + 0x6d, 0x65, 0x6e, 0x74, 0x12, 0x53, 0x0a, 0x12, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, + 0x5f, 0x65, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, + 0x32, 0x24, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, + 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x11, 0x64, 0x61, 0x74, 0x61, 0x74, 0x79, 0x70, 0x65, + 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xb7, 0x01, 0x0a, 0x11, 0x41, 0x64, + 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x12, + 0x50, 0x0a, 0x0d, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x74, 0x79, 0x70, 0x65, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x64, 0x64, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4c, 0x6f, + 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x2e, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, + 0x79, 0x70, 0x65, 0x52, 0x0c, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, + 0x65, 0x12, 0x2a, 0x0a, 0x11, 0x61, 0x66, 0x74, 0x65, 0x72, 0x5f, 0x63, 0x6f, 0x6c, 0x75, 0x6d, + 0x6e, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0f, 0x61, 0x66, + 0x74, 0x65, 0x72, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x4e, 0x61, 0x6d, 0x65, 0x22, 0x24, 0x0a, + 0x0c, 0x4c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, + 0x05, 0x46, 0x49, 0x52, 0x53, 0x54, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x46, 0x54, 0x45, + 0x52, 0x10, 0x01, 0x42, 0x4c, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, + 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x03, 0x44, 0x64, 0x6c, 0x5a, 0x35, 0x67, 0x69, 0x74, 0x68, + 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, + 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, + 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, + 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, } var ( diff --git a/java/src/main/java/io/greptime/v1/Ddl.java b/java/src/main/java/io/greptime/v1/Ddl.java index e5bcc802..c5b7b2fd 100644 --- a/java/src/main/java/io/greptime/v1/Ddl.java +++ b/java/src/main/java/io/greptime/v1/Ddl.java @@ -5862,6 +5862,12 @@ public interface DropTableExprOrBuilder extends * .greptime.v1.TableId table_id = 4; */ io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder(); + + /** + * bool drop_if_exists = 5; + * @return The dropIfExists. + */ + boolean getDropIfExists(); } /** * Protobuf type {@code greptime.v1.DropTableExpr} @@ -5942,6 +5948,11 @@ private DropTableExpr( break; } + case 40: { + + dropIfExists_ = input.readBool(); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -6116,6 +6127,17 @@ public io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder() { return getTableId(); } + public static final int DROP_IF_EXISTS_FIELD_NUMBER = 5; + private boolean dropIfExists_; + /** + * bool drop_if_exists = 5; + * @return The dropIfExists. + */ + @java.lang.Override + public boolean getDropIfExists() { + return dropIfExists_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -6142,6 +6164,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (tableId_ != null) { output.writeMessage(4, getTableId()); } + if (dropIfExists_ != false) { + output.writeBool(5, dropIfExists_); + } unknownFields.writeTo(output); } @@ -6164,6 +6189,10 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeMessageSize(4, getTableId()); } + if (dropIfExists_ != false) { + size += com.google.protobuf.CodedOutputStream + .computeBoolSize(5, dropIfExists_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -6190,6 +6219,8 @@ public boolean equals(final java.lang.Object obj) { if (!getTableId() .equals(other.getTableId())) return false; } + if (getDropIfExists() + != other.getDropIfExists()) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -6211,6 +6242,9 @@ public int hashCode() { hash = (37 * hash) + TABLE_ID_FIELD_NUMBER; hash = (53 * hash) + getTableId().hashCode(); } + hash = (37 * hash) + DROP_IF_EXISTS_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean( + getDropIfExists()); hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -6356,6 +6390,8 @@ public Builder clear() { tableId_ = null; tableIdBuilder_ = null; } + dropIfExists_ = false; + return this; } @@ -6390,6 +6426,7 @@ public io.greptime.v1.Ddl.DropTableExpr buildPartial() { } else { result.tableId_ = tableIdBuilder_.build(); } + result.dropIfExists_ = dropIfExists_; onBuilt(); return result; } @@ -6453,6 +6490,9 @@ public Builder mergeFrom(io.greptime.v1.Ddl.DropTableExpr other) { if (other.hasTableId()) { mergeTableId(other.getTableId()); } + if (other.getDropIfExists() != false) { + setDropIfExists(other.getDropIfExists()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -6828,6 +6868,37 @@ public io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder() { } return tableIdBuilder_; } + + private boolean dropIfExists_ ; + /** + * bool drop_if_exists = 5; + * @return The dropIfExists. + */ + @java.lang.Override + public boolean getDropIfExists() { + return dropIfExists_; + } + /** + * bool drop_if_exists = 5; + * @param value The dropIfExists to set. + * @return This builder for chaining. + */ + public Builder setDropIfExists(boolean value) { + + dropIfExists_ = value; + onChanged(); + return this; + } + /** + * bool drop_if_exists = 5; + * @return This builder for chaining. + */ + public Builder clearDropIfExists() { + + dropIfExists_ = false; + onChanged(); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -15206,38 +15277,39 @@ public io.greptime.v1.Ddl.AddColumnLocation getDefaultInstanceForType() { "2\027.greptime.v1.AddColumnsH\000\0220\n\014drop_colu" + "mns\030\005 \001(\0132\030.greptime.v1.DropColumnsH\000\0220\n" + "\014rename_table\030\006 \001(\0132\030.greptime.v1.Rename" + - "TableH\000B\006\n\004kind\"v\n\rDropTableExpr\022\024\n\014cata" + - "log_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\nt" + - "able_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.grep" + - "time.v1.TableId\"\270\001\n\022CreateDatabaseExpr\022\025" + - "\n\rdatabase_name\030\001 \001(\t\022\034\n\024create_if_not_e" + - "xists\030\002 \001(\010\022=\n\007options\030\003 \003(\0132,.greptime." + - "v1.CreateDatabaseExpr.OptionsEntry\032.\n\014Op" + - "tionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\002" + - "8\001\"z\n\021TruncateTableExpr\022\024\n\014catalog_name\030" + - "\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\ntable_name" + - "\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.greptime.v1.T" + - "ableId\"9\n\nAddColumns\022+\n\013add_columns\030\001 \003(" + - "\0132\026.greptime.v1.AddColumn\"<\n\013DropColumns" + - "\022-\n\014drop_columns\030\001 \003(\0132\027.greptime.v1.Dro" + - "pColumn\"%\n\013RenameTable\022\026\n\016new_table_name" + - "\030\001 \001(\t\"i\n\tAddColumn\022*\n\ncolumn_def\030\001 \001(\0132" + - "\026.greptime.v1.ColumnDef\0220\n\010location\030\003 \001(" + - "\0132\036.greptime.v1.AddColumnLocation\"\032\n\nDro" + - "pColumn\022\014\n\004name\030\001 \001(\t\"\025\n\007TableId\022\n\n\002id\030\001" + - " \001(\r\"\377\001\n\tColumnDef\022\014\n\004name\030\001 \001(\t\022.\n\tdata" + - "_type\030\002 \001(\0162\033.greptime.v1.ColumnDataType" + - "\022\023\n\013is_nullable\030\003 \001(\010\022\032\n\022default_constra" + - "int\030\004 \001(\014\0220\n\rsemantic_type\030\005 \001(\0162\031.grept" + - "ime.v1.SemanticType\022\017\n\007comment\030\006 \001(\t\022@\n\022" + - "datatype_extension\030\007 \001(\0132$.greptime.v1.C" + - "olumnDataTypeExtension\"\230\001\n\021AddColumnLoca" + - "tion\022B\n\rlocation_type\030\001 \001(\0162+.greptime.v" + - "1.AddColumnLocation.LocationType\022\031\n\021afte" + - "r_column_name\030\002 \001(\t\"$\n\014LocationType\022\t\n\005F" + - "IRST\020\000\022\t\n\005AFTER\020\001BL\n\016io.greptime.v1B\003Ddl" + - "Z5github.com/GreptimeTeam/greptime-proto" + - "/go/greptime/v1b\006proto3" + "TableH\000B\006\n\004kind\"\216\001\n\rDropTableExpr\022\024\n\014cat" + + "alog_name\030\001 \001(\t\022\023\n\013schema_name\030\002 \001(\t\022\022\n\n" + + "table_name\030\003 \001(\t\022&\n\010table_id\030\004 \001(\0132\024.gre" + + "ptime.v1.TableId\022\026\n\016drop_if_exists\030\005 \001(\010" + + "\"\270\001\n\022CreateDatabaseExpr\022\025\n\rdatabase_name" + + "\030\001 \001(\t\022\034\n\024create_if_not_exists\030\002 \001(\010\022=\n\007" + + "options\030\003 \003(\0132,.greptime.v1.CreateDataba" + + "seExpr.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003k" + + "ey\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"z\n\021TruncateT" + + "ableExpr\022\024\n\014catalog_name\030\001 \001(\t\022\023\n\013schema" + + "_name\030\002 \001(\t\022\022\n\ntable_name\030\003 \001(\t\022&\n\010table" + + "_id\030\004 \001(\0132\024.greptime.v1.TableId\"9\n\nAddCo" + + "lumns\022+\n\013add_columns\030\001 \003(\0132\026.greptime.v1" + + ".AddColumn\"<\n\013DropColumns\022-\n\014drop_column" + + "s\030\001 \003(\0132\027.greptime.v1.DropColumn\"%\n\013Rena" + + "meTable\022\026\n\016new_table_name\030\001 \001(\t\"i\n\tAddCo" + + "lumn\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.C" + + "olumnDef\0220\n\010location\030\003 \001(\0132\036.greptime.v1" + + ".AddColumnLocation\"\032\n\nDropColumn\022\014\n\004name" + + "\030\001 \001(\t\"\025\n\007TableId\022\n\n\002id\030\001 \001(\r\"\377\001\n\tColumn" + + "Def\022\014\n\004name\030\001 \001(\t\022.\n\tdata_type\030\002 \001(\0162\033.g" + + "reptime.v1.ColumnDataType\022\023\n\013is_nullable" + + "\030\003 \001(\010\022\032\n\022default_constraint\030\004 \001(\014\0220\n\rse" + + "mantic_type\030\005 \001(\0162\031.greptime.v1.Semantic" + + "Type\022\017\n\007comment\030\006 \001(\t\022@\n\022datatype_extens" + + "ion\030\007 \001(\0132$.greptime.v1.ColumnDataTypeEx" + + "tension\"\230\001\n\021AddColumnLocation\022B\n\rlocatio" + + "n_type\030\001 \001(\0162+.greptime.v1.AddColumnLoca" + + "tion.LocationType\022\031\n\021after_column_name\030\002" + + " \001(\t\"$\n\014LocationType\022\t\n\005FIRST\020\000\022\t\n\005AFTER" + + "\020\001BL\n\016io.greptime.v1B\003DdlZ5github.com/Gr" + + "eptimeTeam/greptime-proto/go/greptime/v1" + + "b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -15273,7 +15345,7 @@ public io.greptime.v1.Ddl.AddColumnLocation getDefaultInstanceForType() { internal_static_greptime_v1_DropTableExpr_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_greptime_v1_DropTableExpr_descriptor, - new java.lang.String[] { "CatalogName", "SchemaName", "TableName", "TableId", }); + new java.lang.String[] { "CatalogName", "SchemaName", "TableName", "TableId", "DropIfExists", }); internal_static_greptime_v1_CreateDatabaseExpr_descriptor = getDescriptor().getMessageTypes().get(4); internal_static_greptime_v1_CreateDatabaseExpr_fieldAccessorTable = new diff --git a/java/src/main/java/io/greptime/v1/index/Index.java b/java/src/main/java/io/greptime/v1/index/Index.java index 889caf93..33a0b2ca 100644 --- a/java/src/main/java/io/greptime/v1/index/Index.java +++ b/java/src/main/java/io/greptime/v1/index/Index.java @@ -82,7 +82,7 @@ io.greptime.v1.index.Index.InvertedIndexMeta getMetasOrThrow( /** *
    * InvertedIndexMetas defines the metadata for an inverted index
-   * within a inverted index blob.
+   * within an inverted index blob.
    * 
* * Protobuf type {@code greptime.v1.index.InvertedIndexMetas} @@ -459,7 +459,7 @@ protected Builder newBuilderForType( /** *
      * InvertedIndexMetas defines the metadata for an inverted index
-     * within a inverted index blob.
+     * within an inverted index blob.
      * 
* * Protobuf type {@code greptime.v1.index.InvertedIndexMetas} diff --git a/proto/greptime/v1/ddl.proto b/proto/greptime/v1/ddl.proto index 1c47abcc..eb6ca3d7 100644 --- a/proto/greptime/v1/ddl.proto +++ b/proto/greptime/v1/ddl.proto @@ -66,6 +66,7 @@ message DropTableExpr { string schema_name = 2; string table_name = 3; TableId table_id = 4; + bool drop_if_exists = 5; } message CreateDatabaseExpr { From 4377b4377cba3cd5881aa17c41030ffbfcab1b9b Mon Sep 17 00:00:00 2001 From: Weny Xu Date: Mon, 4 Dec 2023 18:42:07 +0900 Subject: [PATCH 2/2] feat: add closeable_region_ids in RegionLease (#125) * feat: add closeable_region_ids in RegionLease * fix: use repeated uint64 --- c++/greptime/v1/meta/heartbeat.pb.cc | 92 +++++-- c++/greptime/v1/meta/heartbeat.pb.h | 72 +++++ go/greptime/v1/meta/heartbeat.pb.go | 101 +++---- .../greptime/v1/meta/HeartbeatOuterClass.java | 253 ++++++++++++++++-- proto/greptime/v1/meta/heartbeat.proto | 3 +- 5 files changed, 423 insertions(+), 98 deletions(-) diff --git a/c++/greptime/v1/meta/heartbeat.pb.cc b/c++/greptime/v1/meta/heartbeat.pb.cc index 437c1daa..8249d8fa 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.cc +++ b/c++/greptime/v1/meta/heartbeat.pb.cc @@ -93,6 +93,8 @@ PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORIT PROTOBUF_CONSTEXPR RegionLease::RegionLease( ::_pbi::ConstantInitialized): _impl_{ /*decltype(_impl_.regions_)*/{} + , /*decltype(_impl_.closeable_region_ids_)*/{} + , /*decltype(_impl_._closeable_region_ids_cached_byte_size_)*/{0} , /*decltype(_impl_.duration_since_epoch_)*/uint64_t{0u} , /*decltype(_impl_.lease_seconds_)*/uint64_t{0u} , /*decltype(_impl_._cached_size_)*/{}} {} @@ -211,6 +213,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fheartbeat_2eproto::offsets[] P PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.regions_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.duration_since_epoch_), PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.lease_seconds_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::RegionLease, _impl_.closeable_region_ids_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::AskLeaderRequest, _internal_metadata_), ~0u, // no _extensions_ @@ -246,9 +249,9 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 26, -1, -1, sizeof(::greptime::v1::meta::HeartbeatResponse)}, { 35, -1, -1, sizeof(::greptime::v1::meta::GrantedRegion)}, { 43, -1, -1, sizeof(::greptime::v1::meta::RegionLease)}, - { 52, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, - { 59, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, - { 67, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, + { 53, -1, -1, sizeof(::greptime::v1::meta::AskLeaderRequest)}, + { 60, -1, -1, sizeof(::greptime::v1::meta::AskLeaderResponse)}, + { 68, -1, -1, sizeof(::greptime::v1::meta::MailboxMessage)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -284,32 +287,33 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fheartbeat_2eproto[] "egion_lease\030\003 \001(\0132\035.greptime.v1.meta.Reg" "ionLease\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001" " \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta.Re" - "gionRole\"t\n\013RegionLease\0220\n\007regions\030\001 \003(\013" - "2\037.greptime.v1.meta.GrantedRegion\022\034\n\024dur" - "ation_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds" - "\030\003 \001(\004\"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001" - "(\0132\037.greptime.v1.meta.RequestHeader\"m\n\021A" - "skLeaderResponse\0220\n\006header\030\001 \001(\0132 .grept" - "ime.v1.meta.ResponseHeader\022&\n\006leader\030\002 \001" - "(\0132\026.greptime.v1.meta.Peer\"|\n\016MailboxMes" - "sage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004fro" - "m\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030" - "\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*&\n\nRegi" - "onRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\0012\277\001\n\tHea" - "rtbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta.H" - "eartbeatRequest\032#.greptime.v1.meta.Heart" - "beatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grepti" - "me.v1.meta.AskLeaderRequest\032#.greptime.v" - "1.meta.AskLeaderResponse\"\000B( reinterpret_cast(&_impl_.lease_seconds_) - reinterpret_cast(&_impl_.duration_since_epoch_)) + sizeof(_impl_.lease_seconds_)); @@ -1735,6 +1745,17 @@ const char* RegionLease::_InternalParse(const char* ptr, ::_pbi::ParseContext* c } else goto handle_unusual; continue; + // repeated uint64 closeable_region_ids = 4; + case 4: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 34)) { + ptr = ::PROTOBUF_NAMESPACE_ID::internal::PackedUInt64Parser(_internal_mutable_closeable_region_ids(), ptr, ctx); + CHK_(ptr); + } else if (static_cast(tag) == 32) { + _internal_add_closeable_region_ids(::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr)); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -1784,6 +1805,15 @@ uint8_t* RegionLease::_InternalSerialize( target = ::_pbi::WireFormatLite::WriteUInt64ToArray(3, this->_internal_lease_seconds(), target); } + // repeated uint64 closeable_region_ids = 4; + { + int byte_size = _impl_._closeable_region_ids_cached_byte_size_.load(std::memory_order_relaxed); + if (byte_size > 0) { + target = stream->WriteUInt64Packed( + 4, _internal_closeable_region_ids(), byte_size, 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); @@ -1807,6 +1837,20 @@ size_t RegionLease::ByteSizeLong() const { ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg); } + // repeated uint64 closeable_region_ids = 4; + { + size_t data_size = ::_pbi::WireFormatLite:: + UInt64Size(this->_impl_.closeable_region_ids_); + if (data_size > 0) { + total_size += 1 + + ::_pbi::WireFormatLite::Int32Size(static_cast(data_size)); + } + int cached_size = ::_pbi::ToCachedSize(data_size); + _impl_._closeable_region_ids_cached_byte_size_.store(cached_size, + std::memory_order_relaxed); + total_size += data_size; + } + // uint64 duration_since_epoch = 2; if (this->_internal_duration_since_epoch() != 0) { total_size += ::_pbi::WireFormatLite::UInt64SizePlusOne(this->_internal_duration_since_epoch()); @@ -1836,6 +1880,7 @@ void RegionLease::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PR (void) cached_has_bits; _this->_impl_.regions_.MergeFrom(from._impl_.regions_); + _this->_impl_.closeable_region_ids_.MergeFrom(from._impl_.closeable_region_ids_); if (from._internal_duration_since_epoch() != 0) { _this->_internal_set_duration_since_epoch(from._internal_duration_since_epoch()); } @@ -1860,6 +1905,7 @@ void RegionLease::InternalSwap(RegionLease* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); _impl_.regions_.InternalSwap(&other->_impl_.regions_); + _impl_.closeable_region_ids_.InternalSwap(&other->_impl_.closeable_region_ids_); ::PROTOBUF_NAMESPACE_ID::internal::memswap< PROTOBUF_FIELD_OFFSET(RegionLease, _impl_.lease_seconds_) + sizeof(RegionLease::_impl_.lease_seconds_) diff --git a/c++/greptime/v1/meta/heartbeat.pb.h b/c++/greptime/v1/meta/heartbeat.pb.h index 6036e778..b5d5987c 100644 --- a/c++/greptime/v1/meta/heartbeat.pb.h +++ b/c++/greptime/v1/meta/heartbeat.pb.h @@ -1073,6 +1073,7 @@ class RegionLease final : enum : int { kRegionsFieldNumber = 1, + kCloseableRegionIdsFieldNumber = 4, kDurationSinceEpochFieldNumber = 2, kLeaseSecondsFieldNumber = 3, }; @@ -1094,6 +1095,28 @@ class RegionLease final : const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::meta::GrantedRegion >& regions() const; + // repeated uint64 closeable_region_ids = 4; + int closeable_region_ids_size() const; + private: + int _internal_closeable_region_ids_size() const; + public: + void clear_closeable_region_ids(); + private: + uint64_t _internal_closeable_region_ids(int index) const; + const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& + _internal_closeable_region_ids() const; + void _internal_add_closeable_region_ids(uint64_t value); + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* + _internal_mutable_closeable_region_ids(); + public: + uint64_t closeable_region_ids(int index) const; + void set_closeable_region_ids(int index, uint64_t value); + void add_closeable_region_ids(uint64_t value); + const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& + closeable_region_ids() const; + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* + mutable_closeable_region_ids(); + // uint64 duration_since_epoch = 2; void clear_duration_since_epoch(); uint64_t duration_since_epoch() const; @@ -1121,6 +1144,8 @@ class RegionLease final : typedef void DestructorSkippable_; struct Impl_ { ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::meta::GrantedRegion > regions_; + ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t > closeable_region_ids_; + mutable std::atomic _closeable_region_ids_cached_byte_size_; uint64_t duration_since_epoch_; uint64_t lease_seconds_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; @@ -2713,6 +2738,53 @@ inline void RegionLease::set_lease_seconds(uint64_t value) { // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionLease.lease_seconds) } +// repeated uint64 closeable_region_ids = 4; +inline int RegionLease::_internal_closeable_region_ids_size() const { + return _impl_.closeable_region_ids_.size(); +} +inline int RegionLease::closeable_region_ids_size() const { + return _internal_closeable_region_ids_size(); +} +inline void RegionLease::clear_closeable_region_ids() { + _impl_.closeable_region_ids_.Clear(); +} +inline uint64_t RegionLease::_internal_closeable_region_ids(int index) const { + return _impl_.closeable_region_ids_.Get(index); +} +inline uint64_t RegionLease::closeable_region_ids(int index) const { + // @@protoc_insertion_point(field_get:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_closeable_region_ids(index); +} +inline void RegionLease::set_closeable_region_ids(int index, uint64_t value) { + _impl_.closeable_region_ids_.Set(index, value); + // @@protoc_insertion_point(field_set:greptime.v1.meta.RegionLease.closeable_region_ids) +} +inline void RegionLease::_internal_add_closeable_region_ids(uint64_t value) { + _impl_.closeable_region_ids_.Add(value); +} +inline void RegionLease::add_closeable_region_ids(uint64_t value) { + _internal_add_closeable_region_ids(value); + // @@protoc_insertion_point(field_add:greptime.v1.meta.RegionLease.closeable_region_ids) +} +inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& +RegionLease::_internal_closeable_region_ids() const { + return _impl_.closeable_region_ids_; +} +inline const ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >& +RegionLease::closeable_region_ids() const { + // @@protoc_insertion_point(field_list:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_closeable_region_ids(); +} +inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* +RegionLease::_internal_mutable_closeable_region_ids() { + return &_impl_.closeable_region_ids_; +} +inline ::PROTOBUF_NAMESPACE_ID::RepeatedField< uint64_t >* +RegionLease::mutable_closeable_region_ids() { + // @@protoc_insertion_point(field_mutable_list:greptime.v1.meta.RegionLease.closeable_region_ids) + return _internal_mutable_closeable_region_ids(); +} + // ------------------------------------------------------------------- // AskLeaderRequest diff --git a/go/greptime/v1/meta/heartbeat.pb.go b/go/greptime/v1/meta/heartbeat.pb.go index a9a9b6d6..2d5e9a2a 100644 --- a/go/greptime/v1/meta/heartbeat.pb.go +++ b/go/greptime/v1/meta/heartbeat.pb.go @@ -197,7 +197,7 @@ type RegionStat struct { ApproximateBytes int64 `protobuf:"varint,4,opt,name=approximate_bytes,json=approximateBytes,proto3" json:"approximate_bytes,omitempty"` // Approximate number of rows in this region ApproximateRows int64 `protobuf:"varint,5,opt,name=approximate_rows,json=approximateRows,proto3" json:"approximate_rows,omitempty"` - // engine name + // Engine name Engine string `protobuf:"bytes,6,opt,name=engine,proto3" json:"engine,omitempty"` // Region role Role RegionRole `protobuf:"varint,7,opt,name=role,proto3,enum=greptime.v1.meta.RegionRole" json:"role,omitempty"` @@ -410,6 +410,7 @@ type RegionLease struct { Regions []*GrantedRegion `protobuf:"bytes,1,rep,name=regions,proto3" json:"regions,omitempty"` DurationSinceEpoch uint64 `protobuf:"varint,2,opt,name=duration_since_epoch,json=durationSinceEpoch,proto3" json:"duration_since_epoch,omitempty"` LeaseSeconds uint64 `protobuf:"varint,3,opt,name=lease_seconds,json=leaseSeconds,proto3" json:"lease_seconds,omitempty"` + CloseableRegionIds []uint64 `protobuf:"varint,4,rep,packed,name=closeable_region_ids,json=closeableRegionIds,proto3" json:"closeable_region_ids,omitempty"` } func (x *RegionLease) Reset() { @@ -465,6 +466,13 @@ func (x *RegionLease) GetLeaseSeconds() uint64 { return 0 } +func (x *RegionLease) GetCloseableRegionIds() []uint64 { + if x != nil { + return x.CloseableRegionIds + } + return nil +} + type AskLeaderRequest struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -749,7 +757,7 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x30, 0x0a, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x1c, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, - 0x52, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x22, 0x9f, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, + 0x52, 0x04, 0x72, 0x6f, 0x6c, 0x65, 0x22, 0xd1, 0x01, 0x0a, 0x0b, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x4c, 0x65, 0x61, 0x73, 0x65, 0x12, 0x39, 0x0a, 0x07, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x47, 0x72, 0x61, 0x6e, 0x74, @@ -759,50 +767,53 @@ var file_greptime_v1_meta_heartbeat_proto_rawDesc = []byte{ 0x12, 0x64, 0x75, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x53, 0x69, 0x6e, 0x63, 0x65, 0x45, 0x70, 0x6f, 0x63, 0x68, 0x12, 0x23, 0x0a, 0x0d, 0x6c, 0x65, 0x61, 0x73, 0x65, 0x5f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x04, 0x52, 0x0c, 0x6c, 0x65, 0x61, 0x73, - 0x65, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, 0x6b, 0x4c, - 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, 0x0a, 0x06, - 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x67, + 0x65, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x12, 0x30, 0x0a, 0x14, 0x63, 0x6c, 0x6f, 0x73, + 0x65, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x72, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x73, + 0x18, 0x04, 0x20, 0x03, 0x28, 0x04, 0x52, 0x12, 0x63, 0x6c, 0x6f, 0x73, 0x65, 0x61, 0x62, 0x6c, + 0x65, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x73, 0x22, 0x4b, 0x0a, 0x10, 0x41, 0x73, + 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x37, + 0x0a, 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, + 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, + 0x61, 0x2e, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, + 0x06, 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, + 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, + 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, - 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, - 0x65, 0x61, 0x64, 0x65, 0x72, 0x22, 0x7d, 0x0a, 0x11, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, - 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x38, 0x0a, 0x06, 0x68, 0x65, - 0x61, 0x64, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, - 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x52, 0x65, - 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, 0x68, 0x65, - 0x61, 0x64, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x18, 0x02, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, 0x6c, 0x65, - 0x61, 0x64, 0x65, 0x72, 0x22, 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, 0x6f, 0x78, - 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x04, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, - 0x63, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, 0x65, 0x63, - 0x74, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, - 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, 0x01, 0x28, - 0x09, 0x52, 0x02, 0x74, 0x6f, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, - 0x6d, 0x70, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, - 0x0f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, 0x69, 0x73, - 0x12, 0x14, 0x0a, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x48, 0x00, - 0x52, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, 0x6f, 0x61, - 0x64, 0x2a, 0x26, 0x0a, 0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, 0x65, 0x12, - 0x0a, 0x0a, 0x06, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x46, - 0x6f, 0x6c, 0x6c, 0x6f, 0x77, 0x65, 0x72, 0x10, 0x01, 0x32, 0xbf, 0x01, 0x0a, 0x09, 0x48, 0x65, - 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, 0x0a, 0x09, 0x48, 0x65, 0x61, 0x72, 0x74, - 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, - 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, - 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, - 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, - 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, - 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, - 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x65, 0x71, - 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, - 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3c, 0x5a, 0x3a, 0x67, - 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2d, - 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x33, + 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x48, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, 0x06, + 0x68, 0x65, 0x61, 0x64, 0x65, 0x72, 0x12, 0x2e, 0x0a, 0x06, 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x65, 0x65, 0x72, 0x52, 0x06, + 0x6c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x22, 0xaa, 0x01, 0x0a, 0x0e, 0x4d, 0x61, 0x69, 0x6c, 0x62, + 0x6f, 0x78, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x0e, 0x0a, 0x02, 0x69, 0x64, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x04, 0x52, 0x02, 0x69, 0x64, 0x12, 0x18, 0x0a, 0x07, 0x73, 0x75, 0x62, + 0x6a, 0x65, 0x63, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x73, 0x75, 0x62, 0x6a, + 0x65, 0x63, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x18, 0x03, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x04, 0x66, 0x72, 0x6f, 0x6d, 0x12, 0x0e, 0x0a, 0x02, 0x74, 0x6f, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x02, 0x74, 0x6f, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x69, 0x6d, 0x65, 0x73, + 0x74, 0x61, 0x6d, 0x70, 0x5f, 0x6d, 0x69, 0x6c, 0x6c, 0x69, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, + 0x03, 0x52, 0x0f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x4d, 0x69, 0x6c, 0x6c, + 0x69, 0x73, 0x12, 0x14, 0x0a, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, + 0x48, 0x00, 0x52, 0x04, 0x6a, 0x73, 0x6f, 0x6e, 0x42, 0x09, 0x0a, 0x07, 0x70, 0x61, 0x79, 0x6c, + 0x6f, 0x61, 0x64, 0x2a, 0x26, 0x0a, 0x0a, 0x52, 0x65, 0x67, 0x69, 0x6f, 0x6e, 0x52, 0x6f, 0x6c, + 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x10, 0x00, 0x12, 0x0c, 0x0a, + 0x08, 0x46, 0x6f, 0x6c, 0x6c, 0x6f, 0x77, 0x65, 0x72, 0x10, 0x01, 0x32, 0xbf, 0x01, 0x0a, 0x09, + 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x5a, 0x0a, 0x09, 0x48, 0x65, 0x61, + 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, 0x61, 0x72, 0x74, 0x62, + 0x65, 0x61, 0x74, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, + 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x48, 0x65, + 0x61, 0x72, 0x74, 0x62, 0x65, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, + 0x00, 0x28, 0x01, 0x30, 0x01, 0x12, 0x56, 0x0a, 0x09, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, + 0x65, 0x72, 0x12, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, + 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, 0x64, 0x65, 0x72, 0x52, + 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x73, 0x6b, 0x4c, 0x65, 0x61, + 0x64, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x42, 0x3c, 0x5a, + 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74, + 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70, 0x72, 0x6f, + 0x74, 0x6f, 0x33, } var ( diff --git a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java index 64eb7588..2c85d9b6 100644 --- a/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java +++ b/java/src/main/java/greptime/v1/meta/HeartbeatOuterClass.java @@ -2271,7 +2271,7 @@ public interface RegionStatOrBuilder extends /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2280,7 +2280,7 @@ public interface RegionStatOrBuilder extends java.lang.String getEngine(); /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2501,7 +2501,7 @@ public long getApproximateRows() { private volatile java.lang.Object engine_; /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -2522,7 +2522,7 @@ public java.lang.String getEngine() { } /** *
-     * engine name
+     * Engine name
      * 
* * string engine = 6; @@ -3184,7 +3184,7 @@ public Builder clearApproximateRows() { private java.lang.Object engine_ = ""; /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3204,7 +3204,7 @@ public java.lang.String getEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3225,7 +3225,7 @@ public java.lang.String getEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3244,7 +3244,7 @@ public Builder setEngine( } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -3258,7 +3258,7 @@ public Builder clearEngine() { } /** *
-       * engine name
+       * Engine name
        * 
* * string engine = 6; @@ -5069,6 +5069,23 @@ greptime.v1.meta.HeartbeatOuterClass.GrantedRegionOrBuilder getRegionsOrBuilder( * @return The leaseSeconds. */ long getLeaseSeconds(); + + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + java.util.List getCloseableRegionIdsList(); + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + int getCloseableRegionIdsCount(); + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + long getCloseableRegionIds(int index); } /** * Protobuf type {@code greptime.v1.meta.RegionLease} @@ -5084,6 +5101,7 @@ private RegionLease(com.google.protobuf.GeneratedMessageV3.Builder builder) { } private RegionLease() { regions_ = java.util.Collections.emptyList(); + closeableRegionIds_ = emptyLongList(); } @java.lang.Override @@ -5136,6 +5154,27 @@ private RegionLease( leaseSeconds_ = input.readUInt64(); break; } + case 32: { + if (!((mutable_bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_ = newLongList(); + mutable_bitField0_ |= 0x00000002; + } + closeableRegionIds_.addLong(input.readUInt64()); + break; + } + case 34: { + int length = input.readRawVarint32(); + int limit = input.pushLimit(length); + if (!((mutable_bitField0_ & 0x00000002) != 0) && input.getBytesUntilLimit() > 0) { + closeableRegionIds_ = newLongList(); + mutable_bitField0_ |= 0x00000002; + } + while (input.getBytesUntilLimit() > 0) { + closeableRegionIds_.addLong(input.readUInt64()); + } + input.popLimit(limit); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -5156,6 +5195,9 @@ private RegionLease( if (((mutable_bitField0_ & 0x00000001) != 0)) { regions_ = java.util.Collections.unmodifiableList(regions_); } + if (((mutable_bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_.makeImmutable(); // C + } this.unknownFields = unknownFields.build(); makeExtensionsImmutable(); } @@ -5235,6 +5277,34 @@ public long getLeaseSeconds() { return leaseSeconds_; } + public static final int CLOSEABLE_REGION_IDS_FIELD_NUMBER = 4; + private com.google.protobuf.Internal.LongList closeableRegionIds_; + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + @java.lang.Override + public java.util.List + getCloseableRegionIdsList() { + return closeableRegionIds_; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + public int getCloseableRegionIdsCount() { + return closeableRegionIds_.size(); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + public long getCloseableRegionIds(int index) { + return closeableRegionIds_.getLong(index); + } + private int closeableRegionIdsMemoizedSerializedSize = -1; + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -5249,6 +5319,7 @@ public final boolean isInitialized() { @java.lang.Override public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { + getSerializedSize(); for (int i = 0; i < regions_.size(); i++) { output.writeMessage(1, regions_.get(i)); } @@ -5258,6 +5329,13 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (leaseSeconds_ != 0L) { output.writeUInt64(3, leaseSeconds_); } + if (getCloseableRegionIdsList().size() > 0) { + output.writeUInt32NoTag(34); + output.writeUInt32NoTag(closeableRegionIdsMemoizedSerializedSize); + } + for (int i = 0; i < closeableRegionIds_.size(); i++) { + output.writeUInt64NoTag(closeableRegionIds_.getLong(i)); + } unknownFields.writeTo(output); } @@ -5279,6 +5357,20 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeUInt64Size(3, leaseSeconds_); } + { + int dataSize = 0; + for (int i = 0; i < closeableRegionIds_.size(); i++) { + dataSize += com.google.protobuf.CodedOutputStream + .computeUInt64SizeNoTag(closeableRegionIds_.getLong(i)); + } + size += dataSize; + if (!getCloseableRegionIdsList().isEmpty()) { + size += 1; + size += com.google.protobuf.CodedOutputStream + .computeInt32SizeNoTag(dataSize); + } + closeableRegionIdsMemoizedSerializedSize = dataSize; + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -5300,6 +5392,8 @@ public boolean equals(final java.lang.Object obj) { != other.getDurationSinceEpoch()) return false; if (getLeaseSeconds() != other.getLeaseSeconds()) return false; + if (!getCloseableRegionIdsList() + .equals(other.getCloseableRegionIdsList())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -5321,6 +5415,10 @@ public int hashCode() { hash = (37 * hash) + LEASE_SECONDS_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashLong( getLeaseSeconds()); + if (getCloseableRegionIdsCount() > 0) { + hash = (37 * hash) + CLOSEABLE_REGION_IDS_FIELD_NUMBER; + hash = (53 * hash) + getCloseableRegionIdsList().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -5465,6 +5563,8 @@ public Builder clear() { leaseSeconds_ = 0L; + closeableRegionIds_ = emptyLongList(); + bitField0_ = (bitField0_ & ~0x00000002); return this; } @@ -5503,6 +5603,11 @@ public greptime.v1.meta.HeartbeatOuterClass.RegionLease buildPartial() { } result.durationSinceEpoch_ = durationSinceEpoch_; result.leaseSeconds_ = leaseSeconds_; + if (((bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_.makeImmutable(); + bitField0_ = (bitField0_ & ~0x00000002); + } + result.closeableRegionIds_ = closeableRegionIds_; onBuilt(); return result; } @@ -5583,6 +5688,16 @@ public Builder mergeFrom(greptime.v1.meta.HeartbeatOuterClass.RegionLease other) if (other.getLeaseSeconds() != 0L) { setLeaseSeconds(other.getLeaseSeconds()); } + if (!other.closeableRegionIds_.isEmpty()) { + if (closeableRegionIds_.isEmpty()) { + closeableRegionIds_ = other.closeableRegionIds_; + bitField0_ = (bitField0_ & ~0x00000002); + } else { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.addAll(other.closeableRegionIds_); + } + onChanged(); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -5914,6 +6029,85 @@ public Builder clearLeaseSeconds() { onChanged(); return this; } + + private com.google.protobuf.Internal.LongList closeableRegionIds_ = emptyLongList(); + private void ensureCloseableRegionIdsIsMutable() { + if (!((bitField0_ & 0x00000002) != 0)) { + closeableRegionIds_ = mutableCopy(closeableRegionIds_); + bitField0_ |= 0x00000002; + } + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return A list containing the closeableRegionIds. + */ + public java.util.List + getCloseableRegionIdsList() { + return ((bitField0_ & 0x00000002) != 0) ? + java.util.Collections.unmodifiableList(closeableRegionIds_) : closeableRegionIds_; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return The count of closeableRegionIds. + */ + public int getCloseableRegionIdsCount() { + return closeableRegionIds_.size(); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index of the element to return. + * @return The closeableRegionIds at the given index. + */ + public long getCloseableRegionIds(int index) { + return closeableRegionIds_.getLong(index); + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param index The index to set the value at. + * @param value The closeableRegionIds to set. + * @return This builder for chaining. + */ + public Builder setCloseableRegionIds( + int index, long value) { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.setLong(index, value); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param value The closeableRegionIds to add. + * @return This builder for chaining. + */ + public Builder addCloseableRegionIds(long value) { + ensureCloseableRegionIdsIsMutable(); + closeableRegionIds_.addLong(value); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @param values The closeableRegionIds to add. + * @return This builder for chaining. + */ + public Builder addAllCloseableRegionIds( + java.lang.Iterable values) { + ensureCloseableRegionIdsIsMutable(); + com.google.protobuf.AbstractMessageLite.Builder.addAll( + values, closeableRegionIds_); + onChanged(); + return this; + } + /** + * repeated uint64 closeable_region_ids = 4; + * @return This builder for chaining. + */ + public Builder clearCloseableRegionIds() { + closeableRegionIds_ = emptyLongList(); + bitField0_ = (bitField0_ & ~0x00000002); + onChanged(); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -8851,25 +9045,26 @@ public greptime.v1.meta.HeartbeatOuterClass.MailboxMessage getDefaultInstanceFor "egion_lease\030\003 \001(\0132\035.greptime.v1.meta.Reg" + "ionLease\"N\n\rGrantedRegion\022\021\n\tregion_id\030\001" + " \001(\004\022*\n\004role\030\002 \001(\0162\034.greptime.v1.meta.Re" + - "gionRole\"t\n\013RegionLease\0220\n\007regions\030\001 \003(\013" + - "2\037.greptime.v1.meta.GrantedRegion\022\034\n\024dur" + - "ation_since_epoch\030\002 \001(\004\022\025\n\rlease_seconds" + - "\030\003 \001(\004\"C\n\020AskLeaderRequest\022/\n\006header\030\001 \001" + - "(\0132\037.greptime.v1.meta.RequestHeader\"m\n\021A" + - "skLeaderResponse\0220\n\006header\030\001 \001(\0132 .grept" + - "ime.v1.meta.ResponseHeader\022&\n\006leader\030\002 \001" + - "(\0132\026.greptime.v1.meta.Peer\"|\n\016MailboxMes" + - "sage\022\n\n\002id\030\001 \001(\004\022\017\n\007subject\030\002 \001(\t\022\014\n\004fro" + - "m\030\003 \001(\t\022\n\n\002to\030\004 \001(\t\022\030\n\020timestamp_millis\030" + - "\005 \001(\003\022\016\n\004json\030\006 \001(\tH\000B\t\n\007payload*&\n\nRegi" + - "onRole\022\n\n\006Leader\020\000\022\014\n\010Follower\020\0012\277\001\n\tHea" + - "rtbeat\022Z\n\tHeartbeat\022\".greptime.v1.meta.H" + - "eartbeatRequest\032#.greptime.v1.meta.Heart" + - "beatResponse\"\000(\0010\001\022V\n\tAskLeader\022\".grepti" + - "me.v1.meta.AskLeaderRequest\032#.greptime.v" + - "1.meta.AskLeaderResponse\"\000B