From f7e0daeb5395402dd7a14553dc6eb75587c21b6d Mon Sep 17 00:00:00 2001 From: Dennis Zhuang Date: Tue, 7 May 2024 15:47:51 +0800 Subject: [PATCH] feat: adds view_info to CreateViewTask --- c++/greptime/v1/meta/ddl.pb.cc | 133 ++++++++---- c++/greptime/v1/meta/ddl.pb.h | 66 ++++++ go/greptime/v1/meta/ddl.pb.go | 203 ++++++++++--------- java/src/main/java/greptime/v1/meta/Ddl.java | 146 +++++++++---- proto/greptime/v1/meta/ddl.proto | 1 + 5 files changed, 374 insertions(+), 175 deletions(-) diff --git a/c++/greptime/v1/meta/ddl.pb.cc b/c++/greptime/v1/meta/ddl.pb.cc index 94948ddd..3408916f 100644 --- a/c++/greptime/v1/meta/ddl.pb.cc +++ b/c++/greptime/v1/meta/ddl.pb.cc @@ -170,7 +170,8 @@ struct DropFlowTaskDefaultTypeInternal { PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DropFlowTaskDefaultTypeInternal _DropFlowTask_default_instance_; PROTOBUF_CONSTEXPR CreateViewTask::CreateViewTask( ::_pbi::ConstantInitialized): _impl_{ - /*decltype(_impl_.create_view_)*/nullptr + /*decltype(_impl_.view_info_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}} + , /*decltype(_impl_.create_view_)*/nullptr , /*decltype(_impl_._cached_size_)*/{}} {} struct CreateViewTaskDefaultTypeInternal { PROTOBUF_CONSTEXPR CreateViewTaskDefaultTypeInternal() @@ -320,6 +321,7 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fddl_2eproto::offsets[] PROTOBU ~0u, // no _weak_field_map_ ~0u, // no _inlined_string_donated_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::CreateViewTask, _impl_.create_view_), + PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::CreateViewTask, _impl_.view_info_), ~0u, // no _has_bits_ PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::DropViewTask, _internal_metadata_), ~0u, // no _extensions_ @@ -373,9 +375,9 @@ static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protode { 65, -1, -1, sizeof(::greptime::v1::meta::CreateFlowTask)}, { 72, -1, -1, sizeof(::greptime::v1::meta::DropFlowTask)}, { 79, -1, -1, sizeof(::greptime::v1::meta::CreateViewTask)}, - { 86, -1, -1, sizeof(::greptime::v1::meta::DropViewTask)}, - { 93, -1, -1, sizeof(::greptime::v1::meta::DdlTaskRequest)}, - { 115, -1, -1, sizeof(::greptime::v1::meta::DdlTaskResponse)}, + { 87, -1, -1, sizeof(::greptime::v1::meta::DropViewTask)}, + { 94, -1, -1, sizeof(::greptime::v1::meta::DdlTaskRequest)}, + { 116, -1, -1, sizeof(::greptime::v1::meta::DdlTaskResponse)}, }; static const ::_pb::Message* const file_default_instances[] = { @@ -421,42 +423,42 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fddl_2eproto[] PROTOB ".v1.DropDatabaseExpr\"B\n\016CreateFlowTask\0220" "\n\013create_flow\030\001 \001(\0132\033.greptime.v1.Create" "FlowExpr\"<\n\014DropFlowTask\022,\n\tdrop_flow\030\001 " - "\001(\0132\031.greptime.v1.DropFlowExpr\"B\n\016Create" + "\001(\0132\031.greptime.v1.DropFlowExpr\"U\n\016Create" "ViewTask\0220\n\013create_view\030\001 \001(\0132\033.greptime" - ".v1.CreateViewExpr\"<\n\014DropViewTask\022,\n\tdr" - "op_view\030\001 \001(\0132\031.greptime.v1.DropViewExpr" - "\"\261\007\n\016DdlTaskRequest\022/\n\006header\030\001 \001(\0132\037.gr" - "eptime.v1.meta.RequestHeader\0220\n\rquery_co" - "ntext\030@ \001(\0132\031.greptime.v1.QueryContext\022>" - "\n\021create_table_task\030\002 \001(\0132!.greptime.v1." - "meta.CreateTableTaskH\000\022:\n\017drop_table_tas" - "k\030\003 \001(\0132\037.greptime.v1.meta.DropTableTask" - "H\000\022<\n\020alter_table_task\030\004 \001(\0132 .greptime." - "v1.meta.AlterTableTaskH\000\022B\n\023truncate_tab" - "le_task\030\005 \001(\0132#.greptime.v1.meta.Truncat" - "eTableTaskH\000\022@\n\022create_table_tasks\030\006 \001(\013" - "2\".greptime.v1.meta.CreateTableTasksH\000\022<" - "\n\020drop_table_tasks\030\007 \001(\0132 .greptime.v1.m" - "eta.DropTableTasksH\000\022>\n\021alter_table_task" - "s\030\010 \001(\0132!.greptime.v1.meta.AlterTableTas" - "ksH\000\022@\n\022drop_database_task\030\t \001(\0132\".grept" - "ime.v1.meta.DropDatabaseTaskH\000\022D\n\024create" - "_database_task\030\n \001(\0132$.greptime.v1.meta." - "CreateDatabaseTaskH\000\022<\n\020create_flow_task" - "\030\013 \001(\0132 .greptime.v1.meta.CreateFlowTask" - "H\000\0228\n\016drop_flow_task\030\014 \001(\0132\036.greptime.v1" - ".meta.DropFlowTaskH\000\022<\n\020create_view_task" - "\030\r \001(\0132 .greptime.v1.meta.CreateViewTask" - "H\000\0228\n\016drop_view_task\030\016 \001(\0132\036.greptime.v1" - ".meta.DropViewTaskH\000B\006\n\004task\"\312\001\n\017DdlTask" - "Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m" - "eta.ResponseHeader\022*\n\003pid\030\002 \001(\0132\035.grepti" - "me.v1.meta.ProcedureId\022+\n\010table_id\030\004 \001(\013" - "2\031.greptime.v1.meta.TableId\022,\n\ttable_ids" - "\030\005 \003(\0132\031.greptime.v1.meta.TableId*#\n\013Ddl" - "TaskType\022\n\n\006Create\020\000\022\010\n\004Drop\020\001B\n\021create_table_task\030\002" + " \001(\0132!.greptime.v1.meta.CreateTableTaskH" + "\000\022:\n\017drop_table_task\030\003 \001(\0132\037.greptime.v1" + ".meta.DropTableTaskH\000\022<\n\020alter_table_tas" + "k\030\004 \001(\0132 .greptime.v1.meta.AlterTableTas" + "kH\000\022B\n\023truncate_table_task\030\005 \001(\0132#.grept" + "ime.v1.meta.TruncateTableTaskH\000\022@\n\022creat" + "e_table_tasks\030\006 \001(\0132\".greptime.v1.meta.C" + "reateTableTasksH\000\022<\n\020drop_table_tasks\030\007 " + "\001(\0132 .greptime.v1.meta.DropTableTasksH\000\022" + ">\n\021alter_table_tasks\030\010 \001(\0132!.greptime.v1" + ".meta.AlterTableTasksH\000\022@\n\022drop_database" + "_task\030\t \001(\0132\".greptime.v1.meta.DropDatab" + "aseTaskH\000\022D\n\024create_database_task\030\n \001(\0132" + "$.greptime.v1.meta.CreateDatabaseTaskH\000\022" + "<\n\020create_flow_task\030\013 \001(\0132 .greptime.v1." + "meta.CreateFlowTaskH\000\0228\n\016drop_flow_task\030" + "\014 \001(\0132\036.greptime.v1.meta.DropFlowTaskH\000\022" + "<\n\020create_view_task\030\r \001(\0132 .greptime.v1." + "meta.CreateViewTaskH\000\0228\n\016drop_view_task\030" + "\016 \001(\0132\036.greptime.v1.meta.DropViewTaskH\000B" + "\006\n\004task\"\312\001\n\017DdlTaskResponse\0220\n\006header\030\001 " + "\001(\0132 .greptime.v1.meta.ResponseHeader\022*\n" + "\003pid\030\002 \001(\0132\035.greptime.v1.meta.ProcedureI" + "d\022+\n\010table_id\030\004 \001(\0132\031.greptime.v1.meta.T" + "ableId\022,\n\ttable_ids\030\005 \003(\0132\031.greptime.v1." + "meta.TableId*#\n\013DdlTaskType\022\n\n\006Create\020\000\022" + "\010\n\004Drop\020\001B(from._internal_metadata_); + _impl_.view_info_.InitDefault(); + #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.view_info_.Set("", GetArenaForAllocation()); + #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + if (!from._internal_view_info().empty()) { + _this->_impl_.view_info_.Set(from._internal_view_info(), + _this->GetArenaForAllocation()); + } if (from._internal_has_create_view()) { _this->_impl_.create_view_ = new ::greptime::v1::CreateViewExpr(*from._impl_.create_view_); } @@ -2770,9 +2781,14 @@ inline void CreateViewTask::SharedCtor( (void)arena; (void)is_message_owned; new (&_impl_) Impl_{ - decltype(_impl_.create_view_){nullptr} + decltype(_impl_.view_info_){} + , decltype(_impl_.create_view_){nullptr} , /*decltype(_impl_._cached_size_)*/{} }; + _impl_.view_info_.InitDefault(); + #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + _impl_.view_info_.Set("", GetArenaForAllocation()); + #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING } CreateViewTask::~CreateViewTask() { @@ -2786,6 +2802,7 @@ CreateViewTask::~CreateViewTask() { inline void CreateViewTask::SharedDtor() { GOOGLE_DCHECK(GetArenaForAllocation() == nullptr); + _impl_.view_info_.Destroy(); if (this != internal_default_instance()) delete _impl_.create_view_; } @@ -2799,6 +2816,7 @@ void CreateViewTask::Clear() { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + _impl_.view_info_.ClearToEmpty(); if (GetArenaForAllocation() == nullptr && _impl_.create_view_ != nullptr) { delete _impl_.create_view_; } @@ -2820,6 +2838,15 @@ const char* CreateViewTask::_InternalParse(const char* ptr, ::_pbi::ParseContext } else goto handle_unusual; continue; + // bytes view_info = 2; + case 2: + if (PROTOBUF_PREDICT_TRUE(static_cast(tag) == 18)) { + auto str = _internal_mutable_view_info(); + ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx); + CHK_(ptr); + } else + goto handle_unusual; + continue; default: goto handle_unusual; } // switch @@ -2856,6 +2883,12 @@ uint8_t* CreateViewTask::_InternalSerialize( _Internal::create_view(this).GetCachedSize(), target, stream); } + // bytes view_info = 2; + if (!this->_internal_view_info().empty()) { + target = stream->WriteBytesMaybeAliased( + 2, this->_internal_view_info(), 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); @@ -2872,6 +2905,13 @@ size_t CreateViewTask::ByteSizeLong() const { // Prevent compiler warnings about cached_has_bits being unused (void) cached_has_bits; + // bytes view_info = 2; + if (!this->_internal_view_info().empty()) { + total_size += 1 + + ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::BytesSize( + this->_internal_view_info()); + } + // .greptime.v1.CreateViewExpr create_view = 1; if (this->_internal_has_create_view()) { total_size += 1 + @@ -2897,6 +2937,9 @@ void CreateViewTask::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const : uint32_t cached_has_bits = 0; (void) cached_has_bits; + if (!from._internal_view_info().empty()) { + _this->_internal_set_view_info(from._internal_view_info()); + } if (from._internal_has_create_view()) { _this->_internal_mutable_create_view()->::greptime::v1::CreateViewExpr::MergeFrom( from._internal_create_view()); @@ -2917,7 +2960,13 @@ bool CreateViewTask::IsInitialized() const { void CreateViewTask::InternalSwap(CreateViewTask* other) { using std::swap; + auto* lhs_arena = GetArenaForAllocation(); + auto* rhs_arena = other->GetArenaForAllocation(); _internal_metadata_.InternalSwap(&other->_internal_metadata_); + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap( + &_impl_.view_info_, lhs_arena, + &other->_impl_.view_info_, rhs_arena + ); swap(_impl_.create_view_, other->_impl_.create_view_); } diff --git a/c++/greptime/v1/meta/ddl.pb.h b/c++/greptime/v1/meta/ddl.pb.h index 957b87b4..66e2a8ed 100644 --- a/c++/greptime/v1/meta/ddl.pb.h +++ b/c++/greptime/v1/meta/ddl.pb.h @@ -2032,8 +2032,23 @@ class CreateViewTask final : // accessors ------------------------------------------------------- enum : int { + kViewInfoFieldNumber = 2, kCreateViewFieldNumber = 1, }; + // bytes view_info = 2; + void clear_view_info(); + const std::string& view_info() const; + template + void set_view_info(ArgT0&& arg0, ArgT... args); + std::string* mutable_view_info(); + PROTOBUF_NODISCARD std::string* release_view_info(); + void set_allocated_view_info(std::string* view_info); + private: + const std::string& _internal_view_info() const; + inline PROTOBUF_ALWAYS_INLINE void _internal_set_view_info(const std::string& value); + std::string* _internal_mutable_view_info(); + public: + // .greptime.v1.CreateViewExpr create_view = 1; bool has_create_view() const; private: @@ -2060,6 +2075,7 @@ class CreateViewTask final : typedef void InternalArenaConstructable_; typedef void DestructorSkippable_; struct Impl_ { + ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr view_info_; ::greptime::v1::CreateViewExpr* create_view_; mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_; }; @@ -3945,6 +3961,56 @@ inline void CreateViewTask::set_allocated_create_view(::greptime::v1::CreateView // @@protoc_insertion_point(field_set_allocated:greptime.v1.meta.CreateViewTask.create_view) } +// bytes view_info = 2; +inline void CreateViewTask::clear_view_info() { + _impl_.view_info_.ClearToEmpty(); +} +inline const std::string& CreateViewTask::view_info() const { + // @@protoc_insertion_point(field_get:greptime.v1.meta.CreateViewTask.view_info) + return _internal_view_info(); +} +template +inline PROTOBUF_ALWAYS_INLINE +void CreateViewTask::set_view_info(ArgT0&& arg0, ArgT... args) { + + _impl_.view_info_.SetBytes(static_cast(arg0), args..., GetArenaForAllocation()); + // @@protoc_insertion_point(field_set:greptime.v1.meta.CreateViewTask.view_info) +} +inline std::string* CreateViewTask::mutable_view_info() { + std::string* _s = _internal_mutable_view_info(); + // @@protoc_insertion_point(field_mutable:greptime.v1.meta.CreateViewTask.view_info) + return _s; +} +inline const std::string& CreateViewTask::_internal_view_info() const { + return _impl_.view_info_.Get(); +} +inline void CreateViewTask::_internal_set_view_info(const std::string& value) { + + _impl_.view_info_.Set(value, GetArenaForAllocation()); +} +inline std::string* CreateViewTask::_internal_mutable_view_info() { + + return _impl_.view_info_.Mutable(GetArenaForAllocation()); +} +inline std::string* CreateViewTask::release_view_info() { + // @@protoc_insertion_point(field_release:greptime.v1.meta.CreateViewTask.view_info) + return _impl_.view_info_.Release(); +} +inline void CreateViewTask::set_allocated_view_info(std::string* view_info) { + if (view_info != nullptr) { + + } else { + + } + _impl_.view_info_.SetAllocated(view_info, GetArenaForAllocation()); +#ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING + if (_impl_.view_info_.IsDefault()) { + _impl_.view_info_.Set("", GetArenaForAllocation()); + } +#endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING + // @@protoc_insertion_point(field_set_allocated:greptime.v1.meta.CreateViewTask.view_info) +} + // ------------------------------------------------------------------- // DropViewTask diff --git a/go/greptime/v1/meta/ddl.pb.go b/go/greptime/v1/meta/ddl.pb.go index 7e9f5c25..8da92e8c 100644 --- a/go/greptime/v1/meta/ddl.pb.go +++ b/go/greptime/v1/meta/ddl.pb.go @@ -621,6 +621,7 @@ type CreateViewTask struct { unknownFields protoimpl.UnknownFields CreateView *v1.CreateViewExpr `protobuf:"bytes,1,opt,name=create_view,json=createView,proto3" json:"create_view,omitempty"` + ViewInfo []byte `protobuf:"bytes,2,opt,name=view_info,json=viewInfo,proto3" json:"view_info,omitempty"` } func (x *CreateViewTask) Reset() { @@ -662,6 +663,13 @@ func (x *CreateViewTask) GetCreateView() *v1.CreateViewExpr { return nil } +func (x *CreateViewTask) GetViewInfo() []byte { + if x != nil { + return x.ViewInfo + } + return nil +} + // Drop a view task type DropViewTask struct { state protoimpl.MessageState @@ -1109,112 +1117,113 @@ var file_greptime_v1_meta_ddl_proto_rawDesc = []byte{ 0x70, 0x5f, 0x66, 0x6c, 0x6f, 0x77, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x46, 0x6c, 0x6f, 0x77, 0x45, 0x78, 0x70, 0x72, 0x52, 0x08, 0x64, 0x72, 0x6f, 0x70, 0x46, 0x6c, 0x6f, - 0x77, 0x22, 0x4e, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x56, 0x69, 0x65, 0x77, 0x54, + 0x77, 0x22, 0x6b, 0x0a, 0x0e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x3c, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1b, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x56, 0x69, 0x65, 0x77, 0x45, 0x78, 0x70, 0x72, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x56, 0x69, 0x65, - 0x77, 0x22, 0x46, 0x0a, 0x0c, 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, - 0x6b, 0x12, 0x36, 0x0a, 0x09, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x01, - 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x45, 0x78, 0x70, 0x72, 0x52, - 0x08, 0x64, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x22, 0x9f, 0x09, 0x0a, 0x0e, 0x44, 0x64, - 0x6c, 0x54, 0x61, 0x73, 0x6b, 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, + 0x77, 0x12, 0x1b, 0x0a, 0x09, 0x76, 0x69, 0x65, 0x77, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x0c, 0x52, 0x08, 0x76, 0x69, 0x65, 0x77, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x46, + 0x0a, 0x0c, 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x36, + 0x0a, 0x09, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x45, 0x78, 0x70, 0x72, 0x52, 0x08, 0x64, 0x72, + 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x22, 0x9f, 0x09, 0x0a, 0x0e, 0x44, 0x64, 0x6c, 0x54, 0x61, + 0x73, 0x6b, 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, 0x12, 0x3e, 0x0a, 0x0d, 0x71, 0x75, 0x65, 0x72, 0x79, 0x5f, 0x63, 0x6f, 0x6e, 0x74, + 0x65, 0x78, 0x74, 0x18, 0x40, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, 0x43, 0x6f, 0x6e, + 0x74, 0x65, 0x78, 0x74, 0x52, 0x0c, 0x71, 0x75, 0x65, 0x72, 0x79, 0x43, 0x6f, 0x6e, 0x74, 0x65, + 0x78, 0x74, 0x12, 0x4f, 0x0a, 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, + 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, + 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, + 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, + 0x48, 0x00, 0x52, 0x0f, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, + 0x61, 0x73, 0x6b, 0x12, 0x49, 0x0a, 0x0f, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x74, 0x61, 0x62, 0x6c, + 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x03, 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, 0x12, 0x3e, 0x0a, 0x0d, 0x71, 0x75, 0x65, 0x72, 0x79, 0x5f, 0x63, - 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, 0x18, 0x40, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, - 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x51, 0x75, 0x65, 0x72, 0x79, - 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, 0x52, 0x0c, 0x71, 0x75, 0x65, 0x72, 0x79, 0x43, 0x6f, - 0x6e, 0x74, 0x65, 0x78, 0x74, 0x12, 0x4f, 0x0a, 0x11, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, - 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, + 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, + 0x0d, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, + 0x0a, 0x10, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, + 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, + 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, + 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0e, 0x61, 0x6c, + 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x55, 0x0a, 0x13, + 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, + 0x61, 0x73, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x72, 0x75, + 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, + 0x52, 0x11, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, + 0x61, 0x73, 0x6b, 0x12, 0x52, 0x0a, 0x12, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, + 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, + 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, + 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, + 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, + 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4c, 0x0a, 0x10, 0x64, 0x72, 0x6f, 0x70, 0x5f, + 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, + 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, + 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, + 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0e, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, + 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4f, 0x0a, 0x11, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74, + 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, - 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, - 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0f, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, - 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x49, 0x0a, 0x0f, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x74, - 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x1f, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, - 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, - 0x48, 0x00, 0x52, 0x0d, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, - 0x6b, 0x12, 0x4c, 0x0a, 0x10, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, - 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, - 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, - 0x0e, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, - 0x55, 0x0a, 0x13, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x61, 0x62, 0x6c, - 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x23, 0x2e, 0x67, - 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, - 0x54, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, - 0x6b, 0x48, 0x00, 0x52, 0x11, 0x74, 0x72, 0x75, 0x6e, 0x63, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, - 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x52, 0x0a, 0x12, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, - 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x06, 0x20, 0x01, + 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, + 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0f, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, + 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x52, 0x0a, 0x12, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x64, + 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, - 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x54, 0x61, 0x62, 0x6c, - 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, - 0x54, 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4c, 0x0a, 0x10, 0x64, 0x72, - 0x6f, 0x70, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x07, + 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, + 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x10, 0x64, 0x72, 0x6f, 0x70, 0x44, 0x61, + 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x58, 0x0a, 0x14, 0x63, 0x72, + 0x65, 0x61, 0x74, 0x65, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x61, + 0x73, 0x6b, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, + 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, + 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, + 0x52, 0x12, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, + 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, 0x0a, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x66, + 0x6c, 0x6f, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, + 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, + 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, 0x73, 0x6b, + 0x48, 0x00, 0x52, 0x0e, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, + 0x73, 0x6b, 0x12, 0x46, 0x0a, 0x0e, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x66, 0x6c, 0x6f, 0x77, 0x5f, + 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, + 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, + 0x6f, 0x70, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0c, 0x64, 0x72, + 0x6f, 0x70, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, 0x0a, 0x10, 0x63, 0x72, + 0x65, 0x61, 0x74, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, - 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x54, 0x61, 0x62, 0x6c, - 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0e, 0x64, 0x72, 0x6f, 0x70, 0x54, 0x61, - 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x4f, 0x0a, 0x11, 0x61, 0x6c, 0x74, 0x65, - 0x72, 0x5f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x73, 0x18, 0x08, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x21, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, - 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x41, 0x6c, 0x74, 0x65, 0x72, 0x54, 0x61, 0x62, 0x6c, - 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x48, 0x00, 0x52, 0x0f, 0x61, 0x6c, 0x74, 0x65, 0x72, 0x54, - 0x61, 0x62, 0x6c, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x73, 0x12, 0x52, 0x0a, 0x12, 0x64, 0x72, 0x6f, - 0x70, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, - 0x09, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x22, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, - 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x44, 0x61, 0x74, - 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x10, 0x64, 0x72, 0x6f, - 0x70, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x58, 0x0a, - 0x14, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x64, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, - 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x67, 0x72, - 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, - 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, - 0x6b, 0x48, 0x00, 0x52, 0x12, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x44, 0x61, 0x74, 0x61, 0x62, - 0x61, 0x73, 0x65, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, 0x0a, 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, - 0x65, 0x5f, 0x66, 0x6c, 0x6f, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0b, 0x20, 0x01, 0x28, - 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, - 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x46, 0x6c, 0x6f, 0x77, 0x54, - 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0e, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x46, 0x6c, 0x6f, - 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x46, 0x0a, 0x0e, 0x64, 0x72, 0x6f, 0x70, 0x5f, 0x66, 0x6c, - 0x6f, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, - 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, - 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, - 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x46, 0x6c, 0x6f, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x4c, 0x0a, - 0x10, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x73, - 0x6b, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, - 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, - 0x65, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0e, 0x63, 0x72, 0x65, - 0x61, 0x74, 0x65, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x46, 0x0a, 0x0e, 0x64, - 0x72, 0x6f, 0x70, 0x5f, 0x76, 0x69, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0e, 0x20, - 0x01, 0x28, 0x0b, 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, - 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, - 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, - 0x61, 0x73, 0x6b, 0x42, 0x06, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x22, 0xea, 0x01, 0x0a, 0x0f, - 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 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, 0x2f, 0x0a, 0x03, 0x70, 0x69, 0x64, - 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, - 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, - 0x75, 0x72, 0x65, 0x49, 0x64, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x34, 0x0a, 0x08, 0x74, 0x61, - 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, + 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x56, 0x69, + 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x48, 0x00, 0x52, 0x0e, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, + 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, 0x12, 0x46, 0x0a, 0x0e, 0x64, 0x72, 0x6f, 0x70, + 0x5f, 0x76, 0x69, 0x65, 0x77, 0x5f, 0x74, 0x61, 0x73, 0x6b, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x0b, + 0x32, 0x1e, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, + 0x65, 0x74, 0x61, 0x2e, 0x44, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, + 0x48, 0x00, 0x52, 0x0c, 0x64, 0x72, 0x6f, 0x70, 0x56, 0x69, 0x65, 0x77, 0x54, 0x61, 0x73, 0x6b, + 0x42, 0x06, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x22, 0xea, 0x01, 0x0a, 0x0f, 0x44, 0x64, 0x6c, + 0x54, 0x61, 0x73, 0x6b, 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, - 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, - 0x12, 0x36, 0x0a, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, - 0x03, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, - 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x08, - 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b, 0x44, 0x64, 0x6c, 0x54, - 0x61, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61, 0x74, - 0x65, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10, 0x01, 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, 0x2f, 0x0a, 0x03, 0x70, 0x69, 0x64, 0x18, 0x02, 0x20, + 0x01, 0x28, 0x0b, 0x32, 0x1d, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, + 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x50, 0x72, 0x6f, 0x63, 0x65, 0x64, 0x75, 0x72, 0x65, + 0x49, 0x64, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x34, 0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, + 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, + 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, 0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, + 0x6c, 0x65, 0x49, 0x64, 0x52, 0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x36, 0x0a, + 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, + 0x32, 0x19, 0x2e, 0x67, 0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x6d, + 0x65, 0x74, 0x61, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52, 0x08, 0x74, 0x61, 0x62, + 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b, 0x44, 0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, + 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x10, 0x00, + 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10, 0x01, 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/Ddl.java b/java/src/main/java/greptime/v1/meta/Ddl.java index 29f3a80e..8e23c6be 100644 --- a/java/src/main/java/greptime/v1/meta/Ddl.java +++ b/java/src/main/java/greptime/v1/meta/Ddl.java @@ -7958,6 +7958,12 @@ public interface CreateViewTaskOrBuilder extends * .greptime.v1.CreateViewExpr create_view = 1; */ io.greptime.v1.Ddl.CreateViewExprOrBuilder getCreateViewOrBuilder(); + + /** + * bytes view_info = 2; + * @return The viewInfo. + */ + com.google.protobuf.ByteString getViewInfo(); } /** * 
@@ -7976,6 +7982,7 @@ private CreateViewTask(com.google.protobuf.GeneratedMessageV3.Builder builder
       super(builder);
     }
     private CreateViewTask() {
+      viewInfo_ = com.google.protobuf.ByteString.EMPTY;
     }
 
     @java.lang.Override
@@ -8021,6 +8028,11 @@ private CreateViewTask(
 
               break;
             }
+            case 18: {
+
+              viewInfo_ = input.readBytes();
+              break;
+            }
             default: {
               if (!parseUnknownField(
                   input, unknownFields, extensionRegistry, tag)) {
@@ -8081,6 +8093,17 @@ public io.greptime.v1.Ddl.CreateViewExprOrBuilder getCreateViewOrBuilder() {
       return getCreateView();
     }
 
+    public static final int VIEW_INFO_FIELD_NUMBER = 2;
+    private com.google.protobuf.ByteString viewInfo_;
+    /**
+     * bytes view_info = 2;
+     * @return The viewInfo.
+     */
+    @java.lang.Override
+    public com.google.protobuf.ByteString getViewInfo() {
+      return viewInfo_;
+    }
+
     private byte memoizedIsInitialized = -1;
     @java.lang.Override
     public final boolean isInitialized() {
@@ -8098,6 +8121,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (createView_ != null) {
         output.writeMessage(1, getCreateView());
       }
+      if (!viewInfo_.isEmpty()) {
+        output.writeBytes(2, viewInfo_);
+      }
       unknownFields.writeTo(output);
     }
 
@@ -8111,6 +8137,10 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(1, getCreateView());
       }
+      if (!viewInfo_.isEmpty()) {
+        size += com.google.protobuf.CodedOutputStream
+          .computeBytesSize(2, viewInfo_);
+      }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
       return size;
@@ -8131,6 +8161,8 @@ public boolean equals(final java.lang.Object obj) {
         if (!getCreateView()
             .equals(other.getCreateView())) return false;
       }
+      if (!getViewInfo()
+          .equals(other.getViewInfo())) return false;
       if (!unknownFields.equals(other.unknownFields)) return false;
       return true;
     }
@@ -8146,6 +8178,8 @@ public int hashCode() {
         hash = (37 * hash) + CREATE_VIEW_FIELD_NUMBER;
         hash = (53 * hash) + getCreateView().hashCode();
       }
+      hash = (37 * hash) + VIEW_INFO_FIELD_NUMBER;
+      hash = (53 * hash) + getViewInfo().hashCode();
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
       return hash;
@@ -8289,6 +8323,8 @@ public Builder clear() {
           createView_ = null;
           createViewBuilder_ = null;
         }
+        viewInfo_ = com.google.protobuf.ByteString.EMPTY;
+
         return this;
       }
 
@@ -8320,6 +8356,7 @@ public greptime.v1.meta.Ddl.CreateViewTask buildPartial() {
         } else {
           result.createView_ = createViewBuilder_.build();
         }
+        result.viewInfo_ = viewInfo_;
         onBuilt();
         return result;
       }
@@ -8371,6 +8408,9 @@ public Builder mergeFrom(greptime.v1.meta.Ddl.CreateViewTask other) {
         if (other.hasCreateView()) {
           mergeCreateView(other.getCreateView());
         }
+        if (other.getViewInfo() != com.google.protobuf.ByteString.EMPTY) {
+          setViewInfo(other.getViewInfo());
+        }
         this.mergeUnknownFields(other.unknownFields);
         onChanged();
         return this;
@@ -8518,6 +8558,40 @@ public io.greptime.v1.Ddl.CreateViewExprOrBuilder getCreateViewOrBuilder() {
         }
         return createViewBuilder_;
       }
+
+      private com.google.protobuf.ByteString viewInfo_ = com.google.protobuf.ByteString.EMPTY;
+      /**
+       * bytes view_info = 2;
+       * @return The viewInfo.
+       */
+      @java.lang.Override
+      public com.google.protobuf.ByteString getViewInfo() {
+        return viewInfo_;
+      }
+      /**
+       * bytes view_info = 2;
+       * @param value The viewInfo to set.
+       * @return This builder for chaining.
+       */
+      public Builder setViewInfo(com.google.protobuf.ByteString value) {
+        if (value == null) {
+    throw new NullPointerException();
+  }
+  
+        viewInfo_ = value;
+        onChanged();
+        return this;
+      }
+      /**
+       * bytes view_info = 2;
+       * @return This builder for chaining.
+       */
+      public Builder clearViewInfo() {
+        
+        viewInfo_ = getDefaultInstance().getViewInfo();
+        onChanged();
+        return this;
+      }
       @java.lang.Override
       public final Builder setUnknownFields(
           final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -14788,42 +14862,42 @@ public greptime.v1.meta.Ddl.DdlTaskResponse getDefaultInstanceForType() {
       ".v1.DropDatabaseExpr\"B\n\016CreateFlowTask\0220" +
       "\n\013create_flow\030\001 \001(\0132\033.greptime.v1.Create" +
       "FlowExpr\"<\n\014DropFlowTask\022,\n\tdrop_flow\030\001 " +
-      "\001(\0132\031.greptime.v1.DropFlowExpr\"B\n\016Create" +
+      "\001(\0132\031.greptime.v1.DropFlowExpr\"U\n\016Create" +
       "ViewTask\0220\n\013create_view\030\001 \001(\0132\033.greptime" +
-      ".v1.CreateViewExpr\"<\n\014DropViewTask\022,\n\tdr" +
-      "op_view\030\001 \001(\0132\031.greptime.v1.DropViewExpr" +
-      "\"\261\007\n\016DdlTaskRequest\022/\n\006header\030\001 \001(\0132\037.gr" +
-      "eptime.v1.meta.RequestHeader\0220\n\rquery_co" +
-      "ntext\030@ \001(\0132\031.greptime.v1.QueryContext\022>" +
-      "\n\021create_table_task\030\002 \001(\0132!.greptime.v1." +
-      "meta.CreateTableTaskH\000\022:\n\017drop_table_tas" +
-      "k\030\003 \001(\0132\037.greptime.v1.meta.DropTableTask" +
-      "H\000\022<\n\020alter_table_task\030\004 \001(\0132 .greptime." +
-      "v1.meta.AlterTableTaskH\000\022B\n\023truncate_tab" +
-      "le_task\030\005 \001(\0132#.greptime.v1.meta.Truncat" +
-      "eTableTaskH\000\022@\n\022create_table_tasks\030\006 \001(\013" +
-      "2\".greptime.v1.meta.CreateTableTasksH\000\022<" +
-      "\n\020drop_table_tasks\030\007 \001(\0132 .greptime.v1.m" +
-      "eta.DropTableTasksH\000\022>\n\021alter_table_task" +
-      "s\030\010 \001(\0132!.greptime.v1.meta.AlterTableTas" +
-      "ksH\000\022@\n\022drop_database_task\030\t \001(\0132\".grept" +
-      "ime.v1.meta.DropDatabaseTaskH\000\022D\n\024create" +
-      "_database_task\030\n \001(\0132$.greptime.v1.meta." +
-      "CreateDatabaseTaskH\000\022<\n\020create_flow_task" +
-      "\030\013 \001(\0132 .greptime.v1.meta.CreateFlowTask" +
-      "H\000\0228\n\016drop_flow_task\030\014 \001(\0132\036.greptime.v1" +
-      ".meta.DropFlowTaskH\000\022<\n\020create_view_task" +
-      "\030\r \001(\0132 .greptime.v1.meta.CreateViewTask" +
-      "H\000\0228\n\016drop_view_task\030\016 \001(\0132\036.greptime.v1" +
-      ".meta.DropViewTaskH\000B\006\n\004task\"\312\001\n\017DdlTask" +
-      "Response\0220\n\006header\030\001 \001(\0132 .greptime.v1.m" +
-      "eta.ResponseHeader\022*\n\003pid\030\002 \001(\0132\035.grepti" +
-      "me.v1.meta.ProcedureId\022+\n\010table_id\030\004 \001(\013" +
-      "2\031.greptime.v1.meta.TableId\022,\n\ttable_ids" +
-      "\030\005 \003(\0132\031.greptime.v1.meta.TableId*#\n\013Ddl" +
-      "TaskType\022\n\n\006Create\020\000\022\010\n\004Drop\020\001B\n\021create_table_task\030\002" +
+      " \001(\0132!.greptime.v1.meta.CreateTableTaskH" +
+      "\000\022:\n\017drop_table_task\030\003 \001(\0132\037.greptime.v1" +
+      ".meta.DropTableTaskH\000\022<\n\020alter_table_tas" +
+      "k\030\004 \001(\0132 .greptime.v1.meta.AlterTableTas" +
+      "kH\000\022B\n\023truncate_table_task\030\005 \001(\0132#.grept" +
+      "ime.v1.meta.TruncateTableTaskH\000\022@\n\022creat" +
+      "e_table_tasks\030\006 \001(\0132\".greptime.v1.meta.C" +
+      "reateTableTasksH\000\022<\n\020drop_table_tasks\030\007 " +
+      "\001(\0132 .greptime.v1.meta.DropTableTasksH\000\022" +
+      ">\n\021alter_table_tasks\030\010 \001(\0132!.greptime.v1" +
+      ".meta.AlterTableTasksH\000\022@\n\022drop_database" +
+      "_task\030\t \001(\0132\".greptime.v1.meta.DropDatab" +
+      "aseTaskH\000\022D\n\024create_database_task\030\n \001(\0132" +
+      "$.greptime.v1.meta.CreateDatabaseTaskH\000\022" +
+      "<\n\020create_flow_task\030\013 \001(\0132 .greptime.v1." +
+      "meta.CreateFlowTaskH\000\0228\n\016drop_flow_task\030" +
+      "\014 \001(\0132\036.greptime.v1.meta.DropFlowTaskH\000\022" +
+      "<\n\020create_view_task\030\r \001(\0132 .greptime.v1." +
+      "meta.CreateViewTaskH\000\0228\n\016drop_view_task\030" +
+      "\016 \001(\0132\036.greptime.v1.meta.DropViewTaskH\000B" +
+      "\006\n\004task\"\312\001\n\017DdlTaskResponse\0220\n\006header\030\001 " +
+      "\001(\0132 .greptime.v1.meta.ResponseHeader\022*\n" +
+      "\003pid\030\002 \001(\0132\035.greptime.v1.meta.ProcedureI" +
+      "d\022+\n\010table_id\030\004 \001(\0132\031.greptime.v1.meta.T" +
+      "ableId\022,\n\ttable_ids\030\005 \003(\0132\031.greptime.v1." +
+      "meta.TableId*#\n\013DdlTaskType\022\n\n\006Create\020\000\022" +
+      "\010\n\004Drop\020\001B