From 1acbb04adf51bf5fd2b89c3b47235dc9b514e200 Mon Sep 17 00:00:00 2001 From: Ruihang Xia Date: Fri, 15 Dec 2023 18:46:41 +0800 Subject: [PATCH] feat: add extension field to FlightMetadata Signed-off-by: Ruihang Xia --- c++/greptime/v1/common.pb.cc | 200 +++++++-- c++/greptime/v1/common.pb.h | 101 ++++- go/greptime/v1/common.pb.go | 180 ++++---- java/src/main/java/io/greptime/v1/Common.java | 395 ++++++++++++++++-- proto/greptime/v1/common.proto | 9 +- 5 files changed, 724 insertions(+), 161 deletions(-) diff --git a/c++/greptime/v1/common.pb.cc b/c++/greptime/v1/common.pb.cc index 8144eae3..df5d6454 100644 --- a/c++/greptime/v1/common.pb.cc +++ b/c++/greptime/v1/common.pb.cc @@ -131,9 +131,21 @@ struct AffectedRowsDefaultTypeInternal { }; }; PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 AffectedRowsDefaultTypeInternal _AffectedRows_default_instance_; +PROTOBUF_CONSTEXPR FlightMetadata_ExtensionEntry_DoNotUse::FlightMetadata_ExtensionEntry_DoNotUse( + ::_pbi::ConstantInitialized) {} +struct FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal { + PROTOBUF_CONSTEXPR FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal() + : _instance(::_pbi::ConstantInitialized{}) {} + ~FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal() {} + union { + FlightMetadata_ExtensionEntry_DoNotUse _instance; + }; +}; +PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal _FlightMetadata_ExtensionEntry_DoNotUse_default_instance_; PROTOBUF_CONSTEXPR FlightMetadata::FlightMetadata( ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.affected_rows_)*/nullptr + /*decltype(_impl_.extension_)*/{::_pbi::ConstantInitialized()} + , /*decltype(_impl_.affected_rows_)*/nullptr , /*decltype(_impl_._cached_size_)*/{}} {} struct FlightMetadataDefaultTypeInternal { PROTOBUF_CONSTEXPR FlightMetadataDefaultTypeInternal() @@ -203,7 +215,7 @@ struct DecimalTypeExtensionDefaultTypeInternal { PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DecimalTypeExtensionDefaultTypeInternal _DecimalTypeExtension_default_instance_; } // namespace v1 } // namespace greptime -static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fcommon_2eproto[13]; +static ::_pb::Metadata file_level_metadata_greptime_2fv1_2fcommon_2eproto[14]; static const ::_pb::EnumDescriptor* file_level_enum_descriptors_greptime_2fv1_2fcommon_2eproto[2]; static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_greptime_2fv1_2fcommon_2eproto = nullptr; @@ -275,6 +287,16 @@ const uint32_t TableStruct_greptime_2fv1_2fcommon_2eproto::offsets[] PROTOBUF_SE ~0u, // no _weak_field_map_ ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::AffectedRows, _impl_.value_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse, _has_bits_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse, _internal_metadata_), + ~0u, // no _extensions_ + ~0u, // no _oneof_case_ + ~0u, // no _weak_field_map_ + ~0u, // no _inlined_string_donated_ + PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse, key_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse, value_), + 0, + 1, ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata, _internal_metadata_), ~0u, // no _extensions_ @@ -282,6 +304,7 @@ const uint32_t TableStruct_greptime_2fv1_2fcommon_2eproto::offsets[] PROTOBUF_SE ~0u, // no _weak_field_map_ ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata, _impl_.affected_rows_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::FlightMetadata, _impl_.extension_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::IntervalMonthDayNano, _internal_metadata_), ~0u, // no _extensions_ @@ -325,11 +348,12 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 45, -1, -1, sizeof(::greptime::v1::Basic)}, { 53, -1, -1, sizeof(::greptime::v1::Token)}, { 60, -1, -1, sizeof(::greptime::v1::AffectedRows)}, - { 67, -1, -1, sizeof(::greptime::v1::FlightMetadata)}, - { 74, -1, -1, sizeof(::greptime::v1::IntervalMonthDayNano)}, - { 83, -1, -1, sizeof(::greptime::v1::Decimal128)}, - { 91, -1, -1, sizeof(::greptime::v1::ColumnDataTypeExtension)}, - { 99, -1, -1, sizeof(::greptime::v1::DecimalTypeExtension)}, + { 67, 75, -1, sizeof(::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse)}, + { 77, -1, -1, sizeof(::greptime::v1::FlightMetadata)}, + { 85, -1, -1, sizeof(::greptime::v1::IntervalMonthDayNano)}, + { 94, -1, -1, sizeof(::greptime::v1::Decimal128)}, + { 102, -1, -1, sizeof(::greptime::v1::ColumnDataTypeExtension)}, + { 110, -1, -1, sizeof(::greptime::v1::DecimalTypeExtension)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -341,6 +365,7 @@ static const ::_pb::Message* const file_default_instances[] = { &::greptime::v1::_Basic_default_instance_._instance, &::greptime::v1::_Token_default_instance_._instance, &::greptime::v1::_AffectedRows_default_instance_._instance, + &::greptime::v1::_FlightMetadata_ExtensionEntry_DoNotUse_default_instance_._instance, &::greptime::v1::_FlightMetadata_default_instance_._instance, &::greptime::v1::_IntervalMonthDayNano_default_instance_._instance, &::greptime::v1::_Decimal128_default_instance_._instance, @@ -363,39 +388,42 @@ const char descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto[] PROTOBUF_S "token\030\002 \001(\0132\022.greptime.v1.TokenH\000B\r\n\013aut" "h_scheme\"+\n\005Basic\022\020\n\010username\030\001 \001(\t\022\020\n\010p" "assword\030\002 \001(\t\"\026\n\005Token\022\r\n\005token\030\001 \001(\t\"\035\n" - "\014AffectedRows\022\r\n\005value\030\001 \001(\r\"B\n\016FlightMe" - "tadata\0220\n\raffected_rows\030\001 \001(\0132\031.greptime" - ".v1.AffectedRows\"I\n\024IntervalMonthDayNano" - "\022\016\n\006months\030\001 \001(\005\022\014\n\004days\030\002 \001(\005\022\023\n\013nanose" - "conds\030\003 \001(\003\"$\n\nDecimal128\022\n\n\002hi\030\001 \001(\003\022\n\n" - "\002lo\030\002 \001(\003\"`\n\027ColumnDataTypeExtension\0229\n\014" - "decimal_type\030\001 \001(\0132!.greptime.v1.Decimal" - "TypeExtensionH\000B\n\n\010type_ext\"8\n\024DecimalTy" - "peExtension\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030" - "\002 \001(\005*1\n\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020" - "\001\022\r\n\tTIMESTAMP\020\002*\270\004\n\016ColumnDataType\022\013\n\007B" - "OOLEAN\020\000\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003" - "\022\t\n\005INT64\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UI" - "NT32\020\007\022\n\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT" - "64\020\n\022\n\n\006BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014" - "\n\010DATETIME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TI" - "MESTAMP_MILLISECOND\020\020\022\031\n\025TIMESTAMP_MICRO" - "SECOND\020\021\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TI" - "ME_SECOND\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIM" - "E_MICROSECOND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023" - "INTERVAL_YEAR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TI" - "ME\020\030\022\033\n\027INTERVAL_MONTH_DAY_NANO\020\031\022\023\n\017DUR" - "ATION_SECOND\020\032\022\030\n\024DURATION_MILLISECOND\020\033" - "\022\030\n\024DURATION_MICROSECOND\020\034\022\027\n\023DURATION_N" - "ANOSECOND\020\035\022\016\n\nDECIMAL128\020\036BO\n\016io.grepti" - "me.v1B\006CommonZ5github.com/GreptimeTeam/g" - "reptime-proto/go/greptime/v1b\006proto3" + "\014AffectedRows\022\r\n\005value\030\001 \001(\r\"\263\001\n\016FlightM" + "etadata\0220\n\raffected_rows\030\001 \001(\0132\031.greptim" + "e.v1.AffectedRows\022=\n\textension\030\002 \003(\0132*.g" + "reptime.v1.FlightMetadata.ExtensionEntry" + "\0320\n\016ExtensionEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value" + "\030\002 \001(\t:\0028\001\"I\n\024IntervalMonthDayNano\022\016\n\006mo" + "nths\030\001 \001(\005\022\014\n\004days\030\002 \001(\005\022\023\n\013nanoseconds\030" + "\003 \001(\003\"$\n\nDecimal128\022\n\n\002hi\030\001 \001(\003\022\n\n\002lo\030\002 " + "\001(\003\"`\n\027ColumnDataTypeExtension\0229\n\014decima" + "l_type\030\001 \001(\0132!.greptime.v1.DecimalTypeEx" + "tensionH\000B\n\n\010type_ext\"8\n\024DecimalTypeExte" + "nsion\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030\002 \001(\005*" + "1\n\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020\001\022\r\n\tT" + "IMESTAMP\020\002*\270\004\n\016ColumnDataType\022\013\n\007BOOLEAN" + "\020\000\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003\022\t\n\005IN" + "T64\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UINT32\020\007" + "\022\n\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT64\020\n\022\n" + "\n\006BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014\n\010DATE" + "TIME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TIMESTAM" + "P_MILLISECOND\020\020\022\031\n\025TIMESTAMP_MICROSECOND" + "\020\021\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TIME_SEC" + "OND\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIME_MICR" + "OSECOND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023INTERV" + "AL_YEAR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TIME\020\030\022\033" + "\n\027INTERVAL_MONTH_DAY_NANO\020\031\022\023\n\017DURATION_" + "SECOND\020\032\022\030\n\024DURATION_MILLISECOND\020\033\022\030\n\024DU" + "RATION_MICROSECOND\020\034\022\027\n\023DURATION_NANOSEC" + "OND\020\035\022\016\n\nDECIMAL128\020\036BO\n\016io.greptime.v1B" + "\006CommonZ5github.com/GreptimeTeam/greptim" + "e-proto/go/greptime/v1b\006proto3" ; static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fcommon_2eproto_once; const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fcommon_2eproto = { - false, false, 1636, descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto, + false, false, 1750, descriptor_table_protodef_greptime_2fv1_2fcommon_2eproto, "greptime/v1/common.proto", - &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, nullptr, 0, 13, + &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, nullptr, 0, 14, schemas, file_default_instances, TableStruct_greptime_2fv1_2fcommon_2eproto::offsets, file_level_metadata_greptime_2fv1_2fcommon_2eproto, file_level_enum_descriptors_greptime_2fv1_2fcommon_2eproto, file_level_service_descriptors_greptime_2fv1_2fcommon_2eproto, @@ -2258,6 +2286,20 @@ ::PROTOBUF_NAMESPACE_ID::Metadata AffectedRows::GetMetadata() const { // =================================================================== +FlightMetadata_ExtensionEntry_DoNotUse::FlightMetadata_ExtensionEntry_DoNotUse() {} +FlightMetadata_ExtensionEntry_DoNotUse::FlightMetadata_ExtensionEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena) + : SuperType(arena) {} +void FlightMetadata_ExtensionEntry_DoNotUse::MergeFrom(const FlightMetadata_ExtensionEntry_DoNotUse& other) { + MergeFromInternal(other); +} +::PROTOBUF_NAMESPACE_ID::Metadata FlightMetadata_ExtensionEntry_DoNotUse::GetMetadata() const { + return ::_pbi::AssignDescriptors( + &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, + file_level_metadata_greptime_2fv1_2fcommon_2eproto[8]); +} + +// =================================================================== + class FlightMetadata::_Internal { public: static const ::greptime::v1::AffectedRows& affected_rows(const FlightMetadata* msg); @@ -2271,16 +2313,21 @@ FlightMetadata::FlightMetadata(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned) : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) { SharedCtor(arena, is_message_owned); + if (arena != nullptr && !is_message_owned) { + arena->OwnCustomDestructor(this, &FlightMetadata::ArenaDtor); + } // @@protoc_insertion_point(arena_constructor:greptime.v1.FlightMetadata) } FlightMetadata::FlightMetadata(const FlightMetadata& from) : ::PROTOBUF_NAMESPACE_ID::Message() { FlightMetadata* const _this = this; (void)_this; new (&_impl_) Impl_{ - decltype(_impl_.affected_rows_){nullptr} + /*decltype(_impl_.extension_)*/{} + , decltype(_impl_.affected_rows_){nullptr} , /*decltype(_impl_._cached_size_)*/{}}; _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_); + _this->_impl_.extension_.MergeFrom(from._impl_.extension_); if (from._internal_has_affected_rows()) { _this->_impl_.affected_rows_ = new ::greptime::v1::AffectedRows(*from._impl_.affected_rows_); } @@ -2292,7 +2339,8 @@ inline void FlightMetadata::SharedCtor( (void)arena; (void)is_message_owned; new (&_impl_) Impl_{ - decltype(_impl_.affected_rows_){nullptr} + /*decltype(_impl_.extension_)*/{::_pbi::ArenaInitialized(), arena} + , decltype(_impl_.affected_rows_){nullptr} , /*decltype(_impl_._cached_size_)*/{} }; } @@ -2301,6 +2349,7 @@ FlightMetadata::~FlightMetadata() { // @@protoc_insertion_point(destructor:greptime.v1.FlightMetadata) if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) { (void)arena; + ArenaDtor(this); return; } SharedDtor(); @@ -2308,9 +2357,15 @@ FlightMetadata::~FlightMetadata() { inline void FlightMetadata::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.extension_.Destruct(); + _impl_.extension_.~MapField(); if (this != internal_default_instance()) delete _impl_.affected_rows_; } +void FlightMetadata::ArenaDtor(void* object) { + FlightMetadata* _this = reinterpret_cast< FlightMetadata* >(object); + _this->_impl_.extension_.Destruct(); +} void FlightMetadata::SetCachedSize(int size) const { _impl_._cached_size_.Set(size); } @@ -2321,6 +2376,7 @@ void FlightMetadata::Clear() { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + _impl_.extension_.Clear(); if (GetArenaForAllocation() == nullptr && _impl_.affected_rows_ != nullptr) { delete _impl_.affected_rows_; } @@ -2342,6 +2398,19 @@ const char* FlightMetadata::_InternalParse(const char* ptr, ::_pbi::ParseContext } else goto handle_unusual; continue; + // map extension = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 18)) { + ptr -= 1; + do { + ptr += 1; + ptr = ctx->ParseMessage(&_impl_.extension_, ptr); + CHK_(ptr); + if (!ctx->DataAvailable(ptr)) break; + } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr)); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -2378,6 +2447,36 @@ uint8_t* FlightMetadata::_InternalSerialize( _Internal::affected_rows(this).GetCachedSize(), target, stream); } + // map extension = 2; + if (!this->_internal_extension().empty()) { + using MapType = ::_pb::Map; + using WireHelper = FlightMetadata_ExtensionEntry_DoNotUse::Funcs; + const auto& map_field = this->_internal_extension(); + auto check_utf8 = [](const MapType::value_type& entry) { + (void)entry; + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.first.data(), static_cast(entry.first.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.FlightMetadata.ExtensionEntry.key"); + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String( + entry.second.data(), static_cast(entry.second.length()), + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::SERIALIZE, + "greptime.v1.FlightMetadata.ExtensionEntry.value"); + }; + + if (stream->IsSerializationDeterministic() && map_field.size() > 1) { + for (const auto& entry : ::_pbi::MapSorterPtr(map_field)) { + target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } else { + for (const auto& entry : map_field) { + target = WireHelper::InternalSerialize(2, entry.first, entry.second, target, stream); + check_utf8(entry); + } + } + } + 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); @@ -2394,6 +2493,15 @@ size_t FlightMetadata::ByteSizeLong() const { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + // map extension = 2; + total_size += 1 * + ::PROTOBUF_NAMESPACE_ID::internal::FromIntSize(this->_internal_extension_size()); + for (::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >::const_iterator + it = this->_internal_extension().begin(); + it != this->_internal_extension().end(); ++it) { + total_size += FlightMetadata_ExtensionEntry_DoNotUse::Funcs::ByteSizeLong(it->first, it->second); + } + // .greptime.v1.AffectedRows affected_rows = 1; if (this->_internal_has_affected_rows()) { total_size += 1 + @@ -2419,6 +2527,7 @@ void FlightMetadata::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const : uint32_t cached_has_bits = 0; (void) cached_has_bits; + _this->_impl_.extension_.MergeFrom(from._impl_.extension_); if (from._internal_has_affected_rows()) { _this->_internal_mutable_affected_rows()->::greptime::v1::AffectedRows::MergeFrom( from._internal_affected_rows()); @@ -2440,13 +2549,14 @@ bool FlightMetadata::IsInitialized() const { void FlightMetadata::InternalSwap(FlightMetadata* other) { using std::swap; _internal_metadata_.InternalSwap(&other->_internal_metadata_); + _impl_.extension_.InternalSwap(&other->_impl_.extension_); swap(_impl_.affected_rows_, other->_impl_.affected_rows_); } ::PROTOBUF_NAMESPACE_ID::Metadata FlightMetadata::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, - file_level_metadata_greptime_2fv1_2fcommon_2eproto[8]); + file_level_metadata_greptime_2fv1_2fcommon_2eproto[9]); } // =================================================================== @@ -2681,7 +2791,7 @@ void IntervalMonthDayNano::InternalSwap(IntervalMonthDayNano* other) { ::PROTOBUF_NAMESPACE_ID::Metadata IntervalMonthDayNano::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, - file_level_metadata_greptime_2fv1_2fcommon_2eproto[9]); + file_level_metadata_greptime_2fv1_2fcommon_2eproto[10]); } // =================================================================== @@ -2892,7 +3002,7 @@ void Decimal128::InternalSwap(Decimal128* other) { ::PROTOBUF_NAMESPACE_ID::Metadata Decimal128::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, - file_level_metadata_greptime_2fv1_2fcommon_2eproto[10]); + file_level_metadata_greptime_2fv1_2fcommon_2eproto[11]); } // =================================================================== @@ -3139,7 +3249,7 @@ void ColumnDataTypeExtension::InternalSwap(ColumnDataTypeExtension* other) { ::PROTOBUF_NAMESPACE_ID::Metadata ColumnDataTypeExtension::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, - file_level_metadata_greptime_2fv1_2fcommon_2eproto[11]); + file_level_metadata_greptime_2fv1_2fcommon_2eproto[12]); } // =================================================================== @@ -3350,7 +3460,7 @@ void DecimalTypeExtension::InternalSwap(DecimalTypeExtension* other) { ::PROTOBUF_NAMESPACE_ID::Metadata DecimalTypeExtension::GetMetadata() const { return ::_pbi::AssignDescriptors( &descriptor_table_greptime_2fv1_2fcommon_2eproto_getter, &descriptor_table_greptime_2fv1_2fcommon_2eproto_once, - file_level_metadata_greptime_2fv1_2fcommon_2eproto[12]); + file_level_metadata_greptime_2fv1_2fcommon_2eproto[13]); } // @@protoc_insertion_point(namespace_scope) @@ -3389,6 +3499,10 @@ template<> PROTOBUF_NOINLINE ::greptime::v1::AffectedRows* Arena::CreateMaybeMessage< ::greptime::v1::AffectedRows >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::AffectedRows >(arena); } +template<> PROTOBUF_NOINLINE ::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse* +Arena::CreateMaybeMessage< ::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse >(Arena* arena) { + return Arena::CreateMessageInternal< ::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse >(arena); +} template<> PROTOBUF_NOINLINE ::greptime::v1::FlightMetadata* Arena::CreateMaybeMessage< ::greptime::v1::FlightMetadata >(Arena* arena) { return Arena::CreateMessageInternal< ::greptime::v1::FlightMetadata >(arena); diff --git a/c++/greptime/v1/common.pb.h b/c++/greptime/v1/common.pb.h index 74b724c4..e72fd84f 100644 --- a/c++/greptime/v1/common.pb.h +++ b/c++/greptime/v1/common.pb.h @@ -71,6 +71,9 @@ extern DecimalTypeExtensionDefaultTypeInternal _DecimalTypeExtension_default_ins class FlightMetadata; struct FlightMetadataDefaultTypeInternal; extern FlightMetadataDefaultTypeInternal _FlightMetadata_default_instance_; +class FlightMetadata_ExtensionEntry_DoNotUse; +struct FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal; +extern FlightMetadata_ExtensionEntry_DoNotUseDefaultTypeInternal _FlightMetadata_ExtensionEntry_DoNotUse_default_instance_; class IntervalMonthDayNano; struct IntervalMonthDayNanoDefaultTypeInternal; extern IntervalMonthDayNanoDefaultTypeInternal _IntervalMonthDayNano_default_instance_; @@ -99,6 +102,7 @@ template<> ::greptime::v1::ColumnDataTypeExtension* Arena::CreateMaybeMessage<:: template<> ::greptime::v1::Decimal128* Arena::CreateMaybeMessage<::greptime::v1::Decimal128>(Arena*); template<> ::greptime::v1::DecimalTypeExtension* Arena::CreateMaybeMessage<::greptime::v1::DecimalTypeExtension>(Arena*); template<> ::greptime::v1::FlightMetadata* Arena::CreateMaybeMessage<::greptime::v1::FlightMetadata>(Arena*); +template<> ::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::FlightMetadata_ExtensionEntry_DoNotUse>(Arena*); template<> ::greptime::v1::IntervalMonthDayNano* Arena::CreateMaybeMessage<::greptime::v1::IntervalMonthDayNano>(Arena*); template<> ::greptime::v1::RequestHeader* Arena::CreateMaybeMessage<::greptime::v1::RequestHeader>(Arena*); template<> ::greptime::v1::RequestHeader_TracingContextEntry_DoNotUse* Arena::CreateMaybeMessage<::greptime::v1::RequestHeader_TracingContextEntry_DoNotUse>(Arena*); @@ -1437,6 +1441,34 @@ class AffectedRows final : }; // ------------------------------------------------------------------- +class FlightMetadata_ExtensionEntry_DoNotUse : public ::PROTOBUF_NAMESPACE_ID::internal::MapEntry { +public: + typedef ::PROTOBUF_NAMESPACE_ID::internal::MapEntry SuperType; + FlightMetadata_ExtensionEntry_DoNotUse(); + explicit PROTOBUF_CONSTEXPR FlightMetadata_ExtensionEntry_DoNotUse( + ::PROTOBUF_NAMESPACE_ID::internal::ConstantInitialized); + explicit FlightMetadata_ExtensionEntry_DoNotUse(::PROTOBUF_NAMESPACE_ID::Arena* arena); + void MergeFrom(const FlightMetadata_ExtensionEntry_DoNotUse& other); + static const FlightMetadata_ExtensionEntry_DoNotUse* internal_default_instance() { return reinterpret_cast(&_FlightMetadata_ExtensionEntry_DoNotUse_default_instance_); } + static bool ValidateKey(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.FlightMetadata.ExtensionEntry.key"); + } + static bool ValidateValue(std::string* s) { + return ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::VerifyUtf8String(s->data(), static_cast(s->size()), ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::PARSE, "greptime.v1.FlightMetadata.ExtensionEntry.value"); + } + using ::PROTOBUF_NAMESPACE_ID::Message::MergeFrom; + ::PROTOBUF_NAMESPACE_ID::Metadata GetMetadata() const final; + friend struct ::TableStruct_greptime_2fv1_2fcommon_2eproto; +}; + +// ------------------------------------------------------------------- + class FlightMetadata final : public ::PROTOBUF_NAMESPACE_ID::Message /* @@protoc_insertion_point(class_definition:greptime.v1.FlightMetadata) */ { public: @@ -1485,7 +1517,7 @@ class FlightMetadata final : &_FlightMetadata_default_instance_); } static constexpr int kIndexInFileMessages = - 8; + 9; friend void swap(FlightMetadata& a, FlightMetadata& b) { a.Swap(&b); @@ -1546,6 +1578,8 @@ class FlightMetadata final : protected: explicit FlightMetadata(::PROTOBUF_NAMESPACE_ID::Arena* arena, bool is_message_owned = false); + private: + static void ArenaDtor(void* object); public: static const ClassData _class_data_; @@ -1555,11 +1589,30 @@ class FlightMetadata final : // nested types ---------------------------------------------------- + // accessors ------------------------------------------------------- enum : int { + kExtensionFieldNumber = 2, kAffectedRowsFieldNumber = 1, }; + // map extension = 2; + int extension_size() const; + private: + int _internal_extension_size() const; + public: + void clear_extension(); + private: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + _internal_extension() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + _internal_mutable_extension(); + public: + const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& + extension() const; + ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* + mutable_extension(); + // .greptime.v1.AffectedRows affected_rows = 1; bool has_affected_rows() const; private: @@ -1586,6 +1639,11 @@ class FlightMetadata final : typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::MapField< + FlightMetadata_ExtensionEntry_DoNotUse, + std::string, std::string, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING, + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::TYPE_STRING> extension_; ::greptime::v1::AffectedRows* affected_rows_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; @@ -1642,7 +1700,7 @@ class IntervalMonthDayNano final : &_IntervalMonthDayNano_default_instance_); } static constexpr int kIndexInFileMessages = - 9; + 10; friend void swap(IntervalMonthDayNano& a, IntervalMonthDayNano& b) { a.Swap(&b); @@ -1812,7 +1870,7 @@ class Decimal128 final : &_Decimal128_default_instance_); } static constexpr int kIndexInFileMessages = - 10; + 11; friend void swap(Decimal128& a, Decimal128& b) { a.Swap(&b); @@ -1976,7 +2034,7 @@ class ColumnDataTypeExtension final : &_ColumnDataTypeExtension_default_instance_); } static constexpr int kIndexInFileMessages = - 11; + 12; friend void swap(ColumnDataTypeExtension& a, ColumnDataTypeExtension& b) { a.Swap(&b); @@ -2145,7 +2203,7 @@ class DecimalTypeExtension final : &_DecimalTypeExtension_default_instance_); } static constexpr int kIndexInFileMessages = - 12; + 13; friend void swap(DecimalTypeExtension& a, DecimalTypeExtension& b) { a.Swap(&b); @@ -3049,6 +3107,8 @@ inline void AffectedRows::set_value(uint32_t value) { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // FlightMetadata // .greptime.v1.AffectedRows affected_rows = 1; @@ -3141,6 +3201,35 @@ inline void FlightMetadata::set_allocated_affected_rows(::greptime::v1::Affected // @@protoc_insertion_point(field_set_allocated:greptime.v1.FlightMetadata.affected_rows) } +// map extension = 2; +inline int FlightMetadata::_internal_extension_size() const { + return _impl_.extension_.size(); +} +inline int FlightMetadata::extension_size() const { + return _internal_extension_size(); +} +inline void FlightMetadata::clear_extension() { + _impl_.extension_.Clear(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +FlightMetadata::_internal_extension() const { + return _impl_.extension_.GetMap(); +} +inline const ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >& +FlightMetadata::extension() const { + // @@protoc_insertion_point(field_map:greptime.v1.FlightMetadata.extension) + return _internal_extension(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +FlightMetadata::_internal_mutable_extension() { + return _impl_.extension_.MutableMap(); +} +inline ::PROTOBUF_NAMESPACE_ID::Map< std::string, std::string >* +FlightMetadata::mutable_extension() { + // @@protoc_insertion_point(field_mutable_map:greptime.v1.FlightMetadata.extension) + return _internal_mutable_extension(); +} + // ------------------------------------------------------------------- // IntervalMonthDayNano @@ -3407,6 +3496,8 @@ inline void DecimalTypeExtension::set_scale(int32_t value) { // ------------------------------------------------------------------- +// ------------------------------------------------------------------- + // @@protoc_insertion_point(namespace_scope) diff --git a/go/greptime/v1/common.pb.go b/go/greptime/v1/common.pb.go index 746e08da..1c5735e9 100644 --- a/go/greptime/v1/common.pb.go +++ b/go/greptime/v1/common.pb.go @@ -639,7 +639,8 @@ type FlightMetadata struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - AffectedRows *AffectedRows `protobuf:"bytes,1,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"` + AffectedRows *AffectedRows `protobuf:"bytes,1,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"` + Extension map[string]string `protobuf:"bytes,2,rep,name=extension,proto3" json:"extension,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"` } func (x *FlightMetadata) Reset() { @@ -681,6 +682,13 @@ func (x *FlightMetadata) GetAffectedRows() *AffectedRows { return nil } +func (x *FlightMetadata) GetExtension() map[string]string { + if x != nil { + return x.Extension + } + return nil +} + type IntervalMonthDayNano struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -971,78 +979,86 @@ var file_greptime_v1_common_proto_rawDesc = []byte{ 0x12, 0x14, 0x0a, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x74, 0x6f, 0x6b, 0x65, 0x6e, 0x22, 0x24, 0x0a, 0x0c, 0x41, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x50, 0x0a, 0x0e, - 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, 0x3e, - 0x0a, 0x0d, 0x61, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, - 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x73, - 0x52, 0x0c, 0x61, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x22, 0x64, - 0x0a, 0x14, 0x49, 0x6e, 0x74, 0x65, 0x72, 0x76, 0x61, 0x6c, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x44, - 0x61, 0x79, 0x4e, 0x61, 0x6e, 0x6f, 0x12, 0x16, 0x0a, 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73, 0x12, 0x12, - 0x0a, 0x04, 0x64, 0x61, 0x79, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x64, 0x61, - 0x79, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, - 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, - 0x6f, 0x6e, 0x64, 0x73, 0x22, 0x2c, 0x0a, 0x0a, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x31, - 0x32, 0x38, 0x12, 0x0e, 0x0a, 0x02, 0x68, 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, - 0x68, 0x69, 0x12, 0x0e, 0x0a, 0x02, 0x6c, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, - 0x6c, 0x6f, 0x22, 0x6d, 0x0a, 0x17, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, - 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x46, 0x0a, - 0x0c, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, - 0x31, 0x2e, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, - 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x48, 0x00, 0x52, 0x0b, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, - 0x6c, 0x54, 0x79, 0x70, 0x65, 0x42, 0x0a, 0x0a, 0x08, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x65, 0x78, - 0x74, 0x22, 0x4a, 0x0a, 0x14, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x54, 0x79, 0x70, 0x65, - 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x72, 0x65, - 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x70, 0x72, - 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x14, 0x0a, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x2a, 0x31, 0x0a, - 0x0c, 0x53, 0x65, 0x6d, 0x61, 0x6e, 0x74, 0x69, 0x63, 0x54, 0x79, 0x70, 0x65, 0x12, 0x07, 0x0a, - 0x03, 0x54, 0x41, 0x47, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x46, 0x49, 0x45, 0x4c, 0x44, 0x10, - 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x02, - 0x2a, 0xb8, 0x04, 0x0a, 0x0e, 0x43, 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, - 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x42, 0x4f, 0x4f, 0x4c, 0x45, 0x41, 0x4e, 0x10, 0x00, - 0x12, 0x08, 0x0a, 0x04, 0x49, 0x4e, 0x54, 0x38, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, - 0x54, 0x31, 0x36, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x33, 0x32, 0x10, 0x03, - 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x36, 0x34, 0x10, 0x04, 0x12, 0x09, 0x0a, 0x05, 0x55, - 0x49, 0x4e, 0x54, 0x38, 0x10, 0x05, 0x12, 0x0a, 0x0a, 0x06, 0x55, 0x49, 0x4e, 0x54, 0x31, 0x36, - 0x10, 0x06, 0x12, 0x0a, 0x0a, 0x06, 0x55, 0x49, 0x4e, 0x54, 0x33, 0x32, 0x10, 0x07, 0x12, 0x0a, - 0x0a, 0x06, 0x55, 0x49, 0x4e, 0x54, 0x36, 0x34, 0x10, 0x08, 0x12, 0x0b, 0x0a, 0x07, 0x46, 0x4c, - 0x4f, 0x41, 0x54, 0x33, 0x32, 0x10, 0x09, 0x12, 0x0b, 0x0a, 0x07, 0x46, 0x4c, 0x4f, 0x41, 0x54, - 0x36, 0x34, 0x10, 0x0a, 0x12, 0x0a, 0x0a, 0x06, 0x42, 0x49, 0x4e, 0x41, 0x52, 0x59, 0x10, 0x0b, - 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x54, 0x52, 0x49, 0x4e, 0x47, 0x10, 0x0c, 0x12, 0x08, 0x0a, 0x04, - 0x44, 0x41, 0x54, 0x45, 0x10, 0x0d, 0x12, 0x0c, 0x0a, 0x08, 0x44, 0x41, 0x54, 0x45, 0x54, 0x49, - 0x4d, 0x45, 0x10, 0x0e, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, - 0x50, 0x5f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x0f, 0x12, 0x19, 0x0a, 0x15, 0x54, 0x49, - 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, 0x53, 0x45, 0x43, - 0x4f, 0x4e, 0x44, 0x10, 0x10, 0x12, 0x19, 0x0a, 0x15, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, - 0x4d, 0x50, 0x5f, 0x4d, 0x49, 0x43, 0x52, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x11, - 0x12, 0x18, 0x0a, 0x14, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x5f, 0x4e, 0x41, - 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x12, 0x12, 0x0f, 0x0a, 0x0b, 0x54, 0x49, - 0x4d, 0x45, 0x5f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x13, 0x12, 0x14, 0x0a, 0x10, 0x54, - 0x49, 0x4d, 0x45, 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, - 0x14, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x4d, 0x49, 0x43, 0x52, 0x4f, 0x53, - 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x15, 0x12, 0x13, 0x0a, 0x0f, 0x54, 0x49, 0x4d, 0x45, 0x5f, - 0x4e, 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x16, 0x12, 0x17, 0x0a, 0x13, - 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f, 0x59, 0x45, 0x41, 0x52, 0x5f, 0x4d, 0x4f, - 0x4e, 0x54, 0x48, 0x10, 0x17, 0x12, 0x15, 0x0a, 0x11, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, - 0x4c, 0x5f, 0x44, 0x41, 0x59, 0x5f, 0x54, 0x49, 0x4d, 0x45, 0x10, 0x18, 0x12, 0x1b, 0x0a, 0x17, - 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f, 0x4d, 0x4f, 0x4e, 0x54, 0x48, 0x5f, 0x44, - 0x41, 0x59, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x10, 0x19, 0x12, 0x13, 0x0a, 0x0f, 0x44, 0x55, 0x52, - 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x1a, 0x12, 0x18, - 0x0a, 0x14, 0x44, 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, - 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x1b, 0x12, 0x18, 0x0a, 0x14, 0x44, 0x55, 0x52, 0x41, - 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x4d, 0x49, 0x43, 0x52, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, - 0x10, 0x1c, 0x12, 0x17, 0x0a, 0x13, 0x44, 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x4e, - 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x1d, 0x12, 0x0e, 0x0a, 0x0a, 0x44, - 0x45, 0x43, 0x49, 0x4d, 0x41, 0x4c, 0x31, 0x32, 0x38, 0x10, 0x1e, 0x42, 0x4f, 0x0a, 0x0e, 0x69, - 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x06, 0x43, - 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 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, + 0x01, 0x20, 0x01, 0x28, 0x0d, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0xd8, 0x01, 0x0a, + 0x0e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x12, + 0x3e, 0x0a, 0x0d, 0x61, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x77, 0x73, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, + 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, + 0x73, 0x52, 0x0c, 0x61, 0x66, 0x66, 0x65, 0x63, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12, + 0x48, 0x0a, 0x09, 0x65, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x03, + 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, + 0x2e, 0x46, 0x6c, 0x69, 0x67, 0x68, 0x74, 0x4d, 0x65, 0x74, 0x61, 0x64, 0x61, 0x74, 0x61, 0x2e, + 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x09, + 0x65, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x1a, 0x3c, 0x0a, 0x0e, 0x45, 0x78, 0x74, + 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 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, 0x64, 0x0a, 0x14, 0x49, 0x6e, 0x74, 0x65, 0x72, + 0x76, 0x61, 0x6c, 0x4d, 0x6f, 0x6e, 0x74, 0x68, 0x44, 0x61, 0x79, 0x4e, 0x61, 0x6e, 0x6f, 0x12, + 0x16, 0x0a, 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, + 0x06, 0x6d, 0x6f, 0x6e, 0x74, 0x68, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x79, 0x73, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x64, 0x61, 0x79, 0x73, 0x12, 0x20, 0x0a, 0x0b, 0x6e, + 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, + 0x52, 0x0b, 0x6e, 0x61, 0x6e, 0x6f, 0x73, 0x65, 0x63, 0x6f, 0x6e, 0x64, 0x73, 0x22, 0x2c, 0x0a, + 0x0a, 0x44, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x31, 0x32, 0x38, 0x12, 0x0e, 0x0a, 0x02, 0x68, + 0x69, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x68, 0x69, 0x12, 0x0e, 0x0a, 0x02, 0x6c, + 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x02, 0x6c, 0x6f, 0x22, 0x6d, 0x0a, 0x17, 0x43, + 0x6f, 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, + 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x46, 0x0a, 0x0c, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, + 0x6c, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, + 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x65, 0x63, 0x69, 0x6d, + 0x61, 0x6c, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, 0x6f, 0x6e, 0x48, + 0x00, 0x52, 0x0b, 0x64, 0x65, 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x54, 0x79, 0x70, 0x65, 0x42, 0x0a, + 0x0a, 0x08, 0x74, 0x79, 0x70, 0x65, 0x5f, 0x65, 0x78, 0x74, 0x22, 0x4a, 0x0a, 0x14, 0x44, 0x65, + 0x63, 0x69, 0x6d, 0x61, 0x6c, 0x54, 0x79, 0x70, 0x65, 0x45, 0x78, 0x74, 0x65, 0x6e, 0x73, 0x69, + 0x6f, 0x6e, 0x12, 0x1c, 0x0a, 0x09, 0x70, 0x72, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, 0x18, + 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x70, 0x72, 0x65, 0x63, 0x69, 0x73, 0x69, 0x6f, 0x6e, + 0x12, 0x14, 0x0a, 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, + 0x05, 0x73, 0x63, 0x61, 0x6c, 0x65, 0x2a, 0x31, 0x0a, 0x0c, 0x53, 0x65, 0x6d, 0x61, 0x6e, 0x74, + 0x69, 0x63, 0x54, 0x79, 0x70, 0x65, 0x12, 0x07, 0x0a, 0x03, 0x54, 0x41, 0x47, 0x10, 0x00, 0x12, + 0x09, 0x0a, 0x05, 0x46, 0x49, 0x45, 0x4c, 0x44, 0x10, 0x01, 0x12, 0x0d, 0x0a, 0x09, 0x54, 0x49, + 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x10, 0x02, 0x2a, 0xb8, 0x04, 0x0a, 0x0e, 0x43, 0x6f, + 0x6c, 0x75, 0x6d, 0x6e, 0x44, 0x61, 0x74, 0x61, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0b, 0x0a, 0x07, + 0x42, 0x4f, 0x4f, 0x4c, 0x45, 0x41, 0x4e, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x49, 0x4e, 0x54, + 0x38, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x31, 0x36, 0x10, 0x02, 0x12, 0x09, + 0x0a, 0x05, 0x49, 0x4e, 0x54, 0x33, 0x32, 0x10, 0x03, 0x12, 0x09, 0x0a, 0x05, 0x49, 0x4e, 0x54, + 0x36, 0x34, 0x10, 0x04, 0x12, 0x09, 0x0a, 0x05, 0x55, 0x49, 0x4e, 0x54, 0x38, 0x10, 0x05, 0x12, + 0x0a, 0x0a, 0x06, 0x55, 0x49, 0x4e, 0x54, 0x31, 0x36, 0x10, 0x06, 0x12, 0x0a, 0x0a, 0x06, 0x55, + 0x49, 0x4e, 0x54, 0x33, 0x32, 0x10, 0x07, 0x12, 0x0a, 0x0a, 0x06, 0x55, 0x49, 0x4e, 0x54, 0x36, + 0x34, 0x10, 0x08, 0x12, 0x0b, 0x0a, 0x07, 0x46, 0x4c, 0x4f, 0x41, 0x54, 0x33, 0x32, 0x10, 0x09, + 0x12, 0x0b, 0x0a, 0x07, 0x46, 0x4c, 0x4f, 0x41, 0x54, 0x36, 0x34, 0x10, 0x0a, 0x12, 0x0a, 0x0a, + 0x06, 0x42, 0x49, 0x4e, 0x41, 0x52, 0x59, 0x10, 0x0b, 0x12, 0x0a, 0x0a, 0x06, 0x53, 0x54, 0x52, + 0x49, 0x4e, 0x47, 0x10, 0x0c, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x41, 0x54, 0x45, 0x10, 0x0d, 0x12, + 0x0c, 0x0a, 0x08, 0x44, 0x41, 0x54, 0x45, 0x54, 0x49, 0x4d, 0x45, 0x10, 0x0e, 0x12, 0x14, 0x0a, + 0x10, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x5f, 0x53, 0x45, 0x43, 0x4f, 0x4e, + 0x44, 0x10, 0x0f, 0x12, 0x19, 0x0a, 0x15, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, + 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x10, 0x12, 0x19, + 0x0a, 0x15, 0x54, 0x49, 0x4d, 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x5f, 0x4d, 0x49, 0x43, 0x52, + 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x11, 0x12, 0x18, 0x0a, 0x14, 0x54, 0x49, 0x4d, + 0x45, 0x53, 0x54, 0x41, 0x4d, 0x50, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, + 0x44, 0x10, 0x12, 0x12, 0x0f, 0x0a, 0x0b, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x53, 0x45, 0x43, 0x4f, + 0x4e, 0x44, 0x10, 0x13, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x4d, 0x49, 0x4c, + 0x4c, 0x49, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x14, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x49, + 0x4d, 0x45, 0x5f, 0x4d, 0x49, 0x43, 0x52, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x15, + 0x12, 0x13, 0x0a, 0x0f, 0x54, 0x49, 0x4d, 0x45, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, + 0x4f, 0x4e, 0x44, 0x10, 0x16, 0x12, 0x17, 0x0a, 0x13, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, + 0x4c, 0x5f, 0x59, 0x45, 0x41, 0x52, 0x5f, 0x4d, 0x4f, 0x4e, 0x54, 0x48, 0x10, 0x17, 0x12, 0x15, + 0x0a, 0x11, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, 0x4c, 0x5f, 0x44, 0x41, 0x59, 0x5f, 0x54, + 0x49, 0x4d, 0x45, 0x10, 0x18, 0x12, 0x1b, 0x0a, 0x17, 0x49, 0x4e, 0x54, 0x45, 0x52, 0x56, 0x41, + 0x4c, 0x5f, 0x4d, 0x4f, 0x4e, 0x54, 0x48, 0x5f, 0x44, 0x41, 0x59, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, + 0x10, 0x19, 0x12, 0x13, 0x0a, 0x0f, 0x44, 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x53, + 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x1a, 0x12, 0x18, 0x0a, 0x14, 0x44, 0x55, 0x52, 0x41, 0x54, + 0x49, 0x4f, 0x4e, 0x5f, 0x4d, 0x49, 0x4c, 0x4c, 0x49, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, + 0x1b, 0x12, 0x18, 0x0a, 0x14, 0x44, 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x4d, 0x49, + 0x43, 0x52, 0x4f, 0x53, 0x45, 0x43, 0x4f, 0x4e, 0x44, 0x10, 0x1c, 0x12, 0x17, 0x0a, 0x13, 0x44, + 0x55, 0x52, 0x41, 0x54, 0x49, 0x4f, 0x4e, 0x5f, 0x4e, 0x41, 0x4e, 0x4f, 0x53, 0x45, 0x43, 0x4f, + 0x4e, 0x44, 0x10, 0x1d, 0x12, 0x0e, 0x0a, 0x0a, 0x44, 0x45, 0x43, 0x49, 0x4d, 0x41, 0x4c, 0x31, + 0x32, 0x38, 0x10, 0x1e, 0x42, 0x4f, 0x0a, 0x0e, 0x69, 0x6f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, + 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x06, 0x43, 0x6f, 0x6d, 0x6d, 0x6f, 0x6e, 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 ( @@ -1058,7 +1074,7 @@ func file_greptime_v1_common_proto_rawDescGZIP() []byte { } var file_greptime_v1_common_proto_enumTypes = make([]protoimpl.EnumInfo, 2) -var file_greptime_v1_common_proto_msgTypes = make([]protoimpl.MessageInfo, 13) +var file_greptime_v1_common_proto_msgTypes = make([]protoimpl.MessageInfo, 14) var file_greptime_v1_common_proto_goTypes = []interface{}{ (SemanticType)(0), // 0: greptime.v1.SemanticType (ColumnDataType)(0), // 1: greptime.v1.ColumnDataType @@ -1075,6 +1091,7 @@ var file_greptime_v1_common_proto_goTypes = []interface{}{ (*ColumnDataTypeExtension)(nil), // 12: greptime.v1.ColumnDataTypeExtension (*DecimalTypeExtension)(nil), // 13: greptime.v1.DecimalTypeExtension nil, // 14: greptime.v1.RequestHeader.TracingContextEntry + nil, // 15: greptime.v1.FlightMetadata.ExtensionEntry } var file_greptime_v1_common_proto_depIdxs = []int32{ 5, // 0: greptime.v1.RequestHeader.authorization:type_name -> greptime.v1.AuthHeader @@ -1083,12 +1100,13 @@ var file_greptime_v1_common_proto_depIdxs = []int32{ 6, // 3: greptime.v1.AuthHeader.basic:type_name -> greptime.v1.Basic 7, // 4: greptime.v1.AuthHeader.token:type_name -> greptime.v1.Token 8, // 5: greptime.v1.FlightMetadata.affected_rows:type_name -> greptime.v1.AffectedRows - 13, // 6: greptime.v1.ColumnDataTypeExtension.decimal_type:type_name -> greptime.v1.DecimalTypeExtension - 7, // [7:7] is the sub-list for method output_type - 7, // [7:7] is the sub-list for method input_type - 7, // [7:7] is the sub-list for extension type_name - 7, // [7:7] is the sub-list for extension extendee - 0, // [0:7] is the sub-list for field type_name + 15, // 6: greptime.v1.FlightMetadata.extension:type_name -> greptime.v1.FlightMetadata.ExtensionEntry + 13, // 7: greptime.v1.ColumnDataTypeExtension.decimal_type:type_name -> greptime.v1.DecimalTypeExtension + 8, // [8:8] is the sub-list for method output_type + 8, // [8:8] is the sub-list for method input_type + 8, // [8:8] is the sub-list for extension type_name + 8, // [8:8] is the sub-list for extension extendee + 0, // [0:8] is the sub-list for field type_name } func init() { file_greptime_v1_common_proto_init() } @@ -1255,7 +1273,7 @@ func file_greptime_v1_common_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: file_greptime_v1_common_proto_rawDesc, NumEnums: 2, - NumMessages: 13, + NumMessages: 14, NumExtensions: 0, NumServices: 0, }, diff --git a/java/src/main/java/io/greptime/v1/Common.java b/java/src/main/java/io/greptime/v1/Common.java index 24d0b947..f710ad69 100644 --- a/java/src/main/java/io/greptime/v1/Common.java +++ b/java/src/main/java/io/greptime/v1/Common.java @@ -6178,6 +6178,42 @@ public interface FlightMetadataOrBuilder extends * .greptime.v1.AffectedRows affected_rows = 1; */ io.greptime.v1.Common.AffectedRowsOrBuilder getAffectedRowsOrBuilder(); + + /** + * map<string, string> extension = 2; + */ + int getExtensionCount(); + /** + * map<string, string> extension = 2; + */ + boolean containsExtension( + java.lang.String key); + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Deprecated + java.util.Map + getExtension(); + /** + * map<string, string> extension = 2; + */ + java.util.Map + getExtensionMap(); + /** + * map<string, string> extension = 2; + */ + + /* nullable */ +java.lang.String getExtensionOrDefault( + java.lang.String key, + /* nullable */ +java.lang.String defaultValue); + /** + * map<string, string> extension = 2; + */ + + java.lang.String getExtensionOrThrow( + java.lang.String key); } /** * Protobuf type {@code greptime.v1.FlightMetadata} @@ -6214,6 +6250,7 @@ private FlightMetadata( if (extensionRegistry == null) { throw new java.lang.NullPointerException(); } + int mutable_bitField0_ = 0; com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder(); try { @@ -6237,6 +6274,19 @@ private FlightMetadata( break; } + case 18: { + if (!((mutable_bitField0_ & 0x00000001) != 0)) { + extension_ = com.google.protobuf.MapField.newMapField( + ExtensionDefaultEntryHolder.defaultEntry); + mutable_bitField0_ |= 0x00000001; + } + com.google.protobuf.MapEntry + extension__ = input.readMessage( + ExtensionDefaultEntryHolder.defaultEntry.getParserForType(), extensionRegistry); + extension_.getMutableMap().put( + extension__.getKey(), extension__.getValue()); + break; + } default: { if (!parseUnknownField( input, unknownFields, extensionRegistry, tag)) { @@ -6263,6 +6313,18 @@ private FlightMetadata( return io.greptime.v1.Common.internal_static_greptime_v1_FlightMetadata_descriptor; } + @SuppressWarnings({"rawtypes"}) + @java.lang.Override + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 2: + return internalGetExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -6297,6 +6359,87 @@ public io.greptime.v1.Common.AffectedRowsOrBuilder getAffectedRowsOrBuilder() { return getAffectedRows(); } + public static final int EXTENSION_FIELD_NUMBER = 2; + private static final class ExtensionDefaultEntryHolder { + static final com.google.protobuf.MapEntry< + java.lang.String, java.lang.String> defaultEntry = + com.google.protobuf.MapEntry + .newDefaultInstance( + io.greptime.v1.Common.internal_static_greptime_v1_FlightMetadata_ExtensionEntry_descriptor, + com.google.protobuf.WireFormat.FieldType.STRING, + "", + com.google.protobuf.WireFormat.FieldType.STRING, + ""); + } + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> extension_; + private com.google.protobuf.MapField + internalGetExtension() { + if (extension_ == null) { + return com.google.protobuf.MapField.emptyMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + return extension_; + } + + public int getExtensionCount() { + return internalGetExtension().getMap().size(); + } + /** + * map<string, string> extension = 2; + */ + + @java.lang.Override + public boolean containsExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetExtension().getMap().containsKey(key); + } + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getExtension() { + return getExtensionMap(); + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.util.Map getExtensionMap() { + return internalGetExtension().getMap(); + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.lang.String getExtensionOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.lang.String getExtensionOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + private byte memoizedIsInitialized = -1; @java.lang.Override public final boolean isInitialized() { @@ -6314,6 +6457,12 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) if (affectedRows_ != null) { output.writeMessage(1, getAffectedRows()); } + com.google.protobuf.GeneratedMessageV3 + .serializeStringMapTo( + output, + internalGetExtension(), + ExtensionDefaultEntryHolder.defaultEntry, + 2); unknownFields.writeTo(output); } @@ -6327,6 +6476,16 @@ public int getSerializedSize() { size += com.google.protobuf.CodedOutputStream .computeMessageSize(1, getAffectedRows()); } + for (java.util.Map.Entry entry + : internalGetExtension().getMap().entrySet()) { + com.google.protobuf.MapEntry + extension__ = ExtensionDefaultEntryHolder.defaultEntry.newBuilderForType() + .setKey(entry.getKey()) + .setValue(entry.getValue()) + .build(); + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(2, extension__); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -6347,6 +6506,8 @@ public boolean equals(final java.lang.Object obj) { if (!getAffectedRows() .equals(other.getAffectedRows())) return false; } + if (!internalGetExtension().equals( + other.internalGetExtension())) return false; if (!unknownFields.equals(other.unknownFields)) return false; return true; } @@ -6362,6 +6523,10 @@ public int hashCode() { hash = (37 * hash) + AFFECTED_ROWS_FIELD_NUMBER; hash = (53 * hash) + getAffectedRows().hashCode(); } + if (!internalGetExtension().getMap().isEmpty()) { + hash = (37 * hash) + EXTENSION_FIELD_NUMBER; + hash = (53 * hash) + internalGetExtension().hashCode(); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -6469,6 +6634,28 @@ public static final class Builder extends return io.greptime.v1.Common.internal_static_greptime_v1_FlightMetadata_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 2: + return internalGetExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMutableMapField( + int number) { + switch (number) { + case 2: + return internalGetMutableExtension(); + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } @java.lang.Override protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { @@ -6501,6 +6688,7 @@ public Builder clear() { affectedRows_ = null; affectedRowsBuilder_ = null; } + internalGetMutableExtension().clear(); return this; } @@ -6527,11 +6715,14 @@ public io.greptime.v1.Common.FlightMetadata build() { @java.lang.Override public io.greptime.v1.Common.FlightMetadata buildPartial() { io.greptime.v1.Common.FlightMetadata result = new io.greptime.v1.Common.FlightMetadata(this); + int from_bitField0_ = bitField0_; if (affectedRowsBuilder_ == null) { result.affectedRows_ = affectedRows_; } else { result.affectedRows_ = affectedRowsBuilder_.build(); } + result.extension_ = internalGetExtension(); + result.extension_.makeImmutable(); onBuilt(); return result; } @@ -6583,6 +6774,8 @@ public Builder mergeFrom(io.greptime.v1.Common.FlightMetadata other) { if (other.hasAffectedRows()) { mergeAffectedRows(other.getAffectedRows()); } + internalGetMutableExtension().mergeFrom( + other.internalGetExtension()); this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -6611,6 +6804,7 @@ public Builder mergeFrom( } return this; } + private int bitField0_; private io.greptime.v1.Common.AffectedRows affectedRows_; private com.google.protobuf.SingleFieldBuilderV3< @@ -6730,6 +6924,137 @@ public io.greptime.v1.Common.AffectedRowsOrBuilder getAffectedRowsOrBuilder() { } return affectedRowsBuilder_; } + + private com.google.protobuf.MapField< + java.lang.String, java.lang.String> extension_; + private com.google.protobuf.MapField + internalGetExtension() { + if (extension_ == null) { + return com.google.protobuf.MapField.emptyMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + return extension_; + } + private com.google.protobuf.MapField + internalGetMutableExtension() { + onChanged();; + if (extension_ == null) { + extension_ = com.google.protobuf.MapField.newMapField( + ExtensionDefaultEntryHolder.defaultEntry); + } + if (!extension_.isMutable()) { + extension_ = extension_.copy(); + } + return extension_; + } + + public int getExtensionCount() { + return internalGetExtension().getMap().size(); + } + /** + * map<string, string> extension = 2; + */ + + @java.lang.Override + public boolean containsExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + return internalGetExtension().getMap().containsKey(key); + } + /** + * Use {@link #getExtensionMap()} instead. + */ + @java.lang.Override + @java.lang.Deprecated + public java.util.Map getExtension() { + return getExtensionMap(); + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.util.Map getExtensionMap() { + return internalGetExtension().getMap(); + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.lang.String getExtensionOrDefault( + java.lang.String key, + java.lang.String defaultValue) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + return map.containsKey(key) ? map.get(key) : defaultValue; + } + /** + * map<string, string> extension = 2; + */ + @java.lang.Override + + public java.lang.String getExtensionOrThrow( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + java.util.Map map = + internalGetExtension().getMap(); + if (!map.containsKey(key)) { + throw new java.lang.IllegalArgumentException(); + } + return map.get(key); + } + + public Builder clearExtension() { + internalGetMutableExtension().getMutableMap() + .clear(); + return this; + } + /** + * map<string, string> extension = 2; + */ + + public Builder removeExtension( + java.lang.String key) { + if (key == null) { throw new NullPointerException("map key"); } + internalGetMutableExtension().getMutableMap() + .remove(key); + return this; + } + /** + * Use alternate mutation accessors instead. + */ + @java.lang.Deprecated + public java.util.Map + getMutableExtension() { + return internalGetMutableExtension().getMutableMap(); + } + /** + * map<string, string> extension = 2; + */ + public Builder putExtension( + java.lang.String key, + java.lang.String value) { + if (key == null) { throw new NullPointerException("map key"); } + if (value == null) { + throw new NullPointerException("map value"); +} + + internalGetMutableExtension().getMutableMap() + .put(key, value); + return this; + } + /** + * map<string, string> extension = 2; + */ + + public Builder putAllExtension( + java.util.Map values) { + internalGetMutableExtension().getMutableMap() + .putAll(values); + return this; + } @java.lang.Override public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { @@ -9318,6 +9643,11 @@ public io.greptime.v1.Common.DecimalTypeExtension getDefaultInstanceForType() { private static final com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internal_static_greptime_v1_FlightMetadata_fieldAccessorTable; + private static final com.google.protobuf.Descriptors.Descriptor + internal_static_greptime_v1_FlightMetadata_ExtensionEntry_descriptor; + private static final + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable + internal_static_greptime_v1_FlightMetadata_ExtensionEntry_fieldAccessorTable; private static final com.google.protobuf.Descriptors.Descriptor internal_static_greptime_v1_IntervalMonthDayNano_descriptor; private static final @@ -9361,33 +9691,36 @@ public io.greptime.v1.Common.DecimalTypeExtension getDefaultInstanceForType() { "token\030\002 \001(\0132\022.greptime.v1.TokenH\000B\r\n\013aut" + "h_scheme\"+\n\005Basic\022\020\n\010username\030\001 \001(\t\022\020\n\010p" + "assword\030\002 \001(\t\"\026\n\005Token\022\r\n\005token\030\001 \001(\t\"\035\n" + - "\014AffectedRows\022\r\n\005value\030\001 \001(\r\"B\n\016FlightMe" + - "tadata\0220\n\raffected_rows\030\001 \001(\0132\031.greptime" + - ".v1.AffectedRows\"I\n\024IntervalMonthDayNano" + - "\022\016\n\006months\030\001 \001(\005\022\014\n\004days\030\002 \001(\005\022\023\n\013nanose" + - "conds\030\003 \001(\003\"$\n\nDecimal128\022\n\n\002hi\030\001 \001(\003\022\n\n" + - "\002lo\030\002 \001(\003\"`\n\027ColumnDataTypeExtension\0229\n\014" + - "decimal_type\030\001 \001(\0132!.greptime.v1.Decimal" + - "TypeExtensionH\000B\n\n\010type_ext\"8\n\024DecimalTy" + - "peExtension\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030" + - "\002 \001(\005*1\n\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020" + - "\001\022\r\n\tTIMESTAMP\020\002*\270\004\n\016ColumnDataType\022\013\n\007B" + - "OOLEAN\020\000\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003" + - "\022\t\n\005INT64\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UI" + - "NT32\020\007\022\n\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT" + - "64\020\n\022\n\n\006BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014" + - "\n\010DATETIME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TI" + - "MESTAMP_MILLISECOND\020\020\022\031\n\025TIMESTAMP_MICRO" + - "SECOND\020\021\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TI" + - "ME_SECOND\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIM" + - "E_MICROSECOND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023" + - "INTERVAL_YEAR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TI" + - "ME\020\030\022\033\n\027INTERVAL_MONTH_DAY_NANO\020\031\022\023\n\017DUR" + - "ATION_SECOND\020\032\022\030\n\024DURATION_MILLISECOND\020\033" + - "\022\030\n\024DURATION_MICROSECOND\020\034\022\027\n\023DURATION_N" + - "ANOSECOND\020\035\022\016\n\nDECIMAL128\020\036BO\n\016io.grepti" + - "me.v1B\006CommonZ5github.com/GreptimeTeam/g" + - "reptime-proto/go/greptime/v1b\006proto3" + "\014AffectedRows\022\r\n\005value\030\001 \001(\r\"\263\001\n\016FlightM" + + "etadata\0220\n\raffected_rows\030\001 \001(\0132\031.greptim" + + "e.v1.AffectedRows\022=\n\textension\030\002 \003(\0132*.g" + + "reptime.v1.FlightMetadata.ExtensionEntry" + + "\0320\n\016ExtensionEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value" + + "\030\002 \001(\t:\0028\001\"I\n\024IntervalMonthDayNano\022\016\n\006mo" + + "nths\030\001 \001(\005\022\014\n\004days\030\002 \001(\005\022\023\n\013nanoseconds\030" + + "\003 \001(\003\"$\n\nDecimal128\022\n\n\002hi\030\001 \001(\003\022\n\n\002lo\030\002 " + + "\001(\003\"`\n\027ColumnDataTypeExtension\0229\n\014decima" + + "l_type\030\001 \001(\0132!.greptime.v1.DecimalTypeEx" + + "tensionH\000B\n\n\010type_ext\"8\n\024DecimalTypeExte" + + "nsion\022\021\n\tprecision\030\001 \001(\005\022\r\n\005scale\030\002 \001(\005*" + + "1\n\014SemanticType\022\007\n\003TAG\020\000\022\t\n\005FIELD\020\001\022\r\n\tT" + + "IMESTAMP\020\002*\270\004\n\016ColumnDataType\022\013\n\007BOOLEAN" + + "\020\000\022\010\n\004INT8\020\001\022\t\n\005INT16\020\002\022\t\n\005INT32\020\003\022\t\n\005IN" + + "T64\020\004\022\t\n\005UINT8\020\005\022\n\n\006UINT16\020\006\022\n\n\006UINT32\020\007" + + "\022\n\n\006UINT64\020\010\022\013\n\007FLOAT32\020\t\022\013\n\007FLOAT64\020\n\022\n" + + "\n\006BINARY\020\013\022\n\n\006STRING\020\014\022\010\n\004DATE\020\r\022\014\n\010DATE" + + "TIME\020\016\022\024\n\020TIMESTAMP_SECOND\020\017\022\031\n\025TIMESTAM" + + "P_MILLISECOND\020\020\022\031\n\025TIMESTAMP_MICROSECOND" + + "\020\021\022\030\n\024TIMESTAMP_NANOSECOND\020\022\022\017\n\013TIME_SEC" + + "OND\020\023\022\024\n\020TIME_MILLISECOND\020\024\022\024\n\020TIME_MICR" + + "OSECOND\020\025\022\023\n\017TIME_NANOSECOND\020\026\022\027\n\023INTERV" + + "AL_YEAR_MONTH\020\027\022\025\n\021INTERVAL_DAY_TIME\020\030\022\033" + + "\n\027INTERVAL_MONTH_DAY_NANO\020\031\022\023\n\017DURATION_" + + "SECOND\020\032\022\030\n\024DURATION_MILLISECOND\020\033\022\030\n\024DU" + + "RATION_MICROSECOND\020\034\022\027\n\023DURATION_NANOSEC" + + "OND\020\035\022\016\n\nDECIMAL128\020\036BO\n\016io.greptime.v1B" + + "\006CommonZ5github.com/GreptimeTeam/greptim" + + "e-proto/go/greptime/v1b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor .internalBuildGeneratedFileFrom(descriptorData, @@ -9446,7 +9779,13 @@ public io.greptime.v1.Common.DecimalTypeExtension getDefaultInstanceForType() { internal_static_greptime_v1_FlightMetadata_fieldAccessorTable = new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( internal_static_greptime_v1_FlightMetadata_descriptor, - new java.lang.String[] { "AffectedRows", }); + new java.lang.String[] { "AffectedRows", "Extension", }); + internal_static_greptime_v1_FlightMetadata_ExtensionEntry_descriptor = + internal_static_greptime_v1_FlightMetadata_descriptor.getNestedTypes().get(0); + internal_static_greptime_v1_FlightMetadata_ExtensionEntry_fieldAccessorTable = new + com.google.protobuf.GeneratedMessageV3.FieldAccessorTable( + internal_static_greptime_v1_FlightMetadata_ExtensionEntry_descriptor, + new java.lang.String[] { "Key", "Value", }); internal_static_greptime_v1_IntervalMonthDayNano_descriptor = getDescriptor().getMessageTypes().get(8); internal_static_greptime_v1_IntervalMonthDayNano_fieldAccessorTable = new diff --git a/proto/greptime/v1/common.proto b/proto/greptime/v1/common.proto index 0fe8cd23..ffb2ccfb 100644 --- a/proto/greptime/v1/common.proto +++ b/proto/greptime/v1/common.proto @@ -58,7 +58,10 @@ message Token { string token = 1; } message AffectedRows { uint32 value = 1; } -message FlightMetadata { AffectedRows affected_rows = 1; } +message FlightMetadata { + AffectedRows affected_rows = 1; + map extension = 2; +} enum SemanticType { TAG = 0; @@ -114,9 +117,7 @@ message Decimal128 { // Type extension for some complex types message ColumnDataTypeExtension { - oneof type_ext { - DecimalTypeExtension decimal_type = 1; - } + oneof type_ext { DecimalTypeExtension decimal_type = 1; } } message DecimalTypeExtension {