refactor: remove the table in ddl response (#175)

c++/greptime/v1/meta/ddl.pb.cc

@@ -216,7 +216,6 @@ PROTOBUF_CONSTEXPR DdlTaskResponse::DdlTaskResponse(
     /*decltype(_impl_.table_ids_)*/{}
   , /*decltype(_impl_.header_)*/nullptr
   , /*decltype(_impl_.pid_)*/nullptr
-  , /*decltype(_impl_.table_id_)*/nullptr
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct DdlTaskResponseDefaultTypeInternal {
   PROTOBUF_CONSTEXPR DdlTaskResponseDefaultTypeInternal()
@@ -359,7 +358,6 @@ const uint32_t TableStruct_greptime_2fv1_2fmeta_2fddl_2eproto::offsets[] PROTOBU
   ~0u,  // no _inlined_string_donated_
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::DdlTaskResponse, _impl_.header_),
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::DdlTaskResponse, _impl_.pid_),
-  PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::DdlTaskResponse, _impl_.table_id_),
   PROTOBUF_FIELD_OFFSET(::greptime::v1::meta::DdlTaskResponse, _impl_.table_ids_),
 };
 static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
@@ -451,10 +449,9 @@ const char descriptor_table_protodef_greptime_2fv1_2fmeta_2fddl_2eproto[] PROTOB
   "<\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\"\300\001\n\017DdlTaskResponse\0220\n\006header\030\001 "
+  "\006\n\004task\"\230\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\024.greptime.v1.TableI"
   "d\022\'\n\ttable_ids\030\005 \003(\0132\024.greptime.v1.Table"
   "Id*#\n\013DdlTaskType\022\n\n\006Create\020\000\022\010\n\004Drop\020\001B"
   "<Z:github.com/GreptimeTeam/greptime-prot"
@@ -468,7 +465,7 @@ static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fmet
 };
 static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fmeta_2fddl_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fmeta_2fddl_2eproto = {
-    false, false, 2389, descriptor_table_protodef_greptime_2fv1_2fmeta_2fddl_2eproto,
+    false, false, 2349, descriptor_table_protodef_greptime_2fv1_2fmeta_2fddl_2eproto,
     "greptime/v1/meta/ddl.proto",
     &descriptor_table_greptime_2fv1_2fmeta_2fddl_2eproto_once, descriptor_table_greptime_2fv1_2fmeta_2fddl_2eproto_deps, 4, 15,
     schemas, file_default_instances, TableStruct_greptime_2fv1_2fmeta_2fddl_2eproto::offsets,
@@ -4224,7 +4221,6 @@ class DdlTaskResponse::_Internal {
  public:
   static const ::greptime::v1::meta::ResponseHeader& header(const DdlTaskResponse* msg);
   static const ::greptime::v1::meta::ProcedureId& pid(const DdlTaskResponse* msg);
-  static const ::greptime::v1::TableId& table_id(const DdlTaskResponse* msg);
 };
 
 const ::greptime::v1::meta::ResponseHeader&
@@ -4235,10 +4231,6 @@ const ::greptime::v1::meta::ProcedureId&
 DdlTaskResponse::_Internal::pid(const DdlTaskResponse* msg) {
   return *msg->_impl_.pid_;
 }
-const ::greptime::v1::TableId&
-DdlTaskResponse::_Internal::table_id(const DdlTaskResponse* msg) {
-  return *msg->_impl_.table_id_;
-}
 void DdlTaskResponse::clear_header() {
   if (GetArenaForAllocation() == nullptr && _impl_.header_ != nullptr) {
     delete _impl_.header_;
@@ -4251,12 +4243,6 @@ void DdlTaskResponse::clear_pid() {
   }
   _impl_.pid_ = nullptr;
 }
-void DdlTaskResponse::clear_table_id() {
-  if (GetArenaForAllocation() == nullptr && _impl_.table_id_ != nullptr) {
-    delete _impl_.table_id_;
-  }
-  _impl_.table_id_ = nullptr;
-}
 void DdlTaskResponse::clear_table_ids() {
   _impl_.table_ids_.Clear();
 }
@@ -4273,7 +4259,6 @@ DdlTaskResponse::DdlTaskResponse(const DdlTaskResponse& from)
       decltype(_impl_.table_ids_){from._impl_.table_ids_}
     , decltype(_impl_.header_){nullptr}
     , decltype(_impl_.pid_){nullptr}
-    , decltype(_impl_.table_id_){nullptr}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
@@ -4283,9 +4268,6 @@ DdlTaskResponse::DdlTaskResponse(const DdlTaskResponse& from)
   if (from._internal_has_pid()) {
     _this->_impl_.pid_ = new ::greptime::v1::meta::ProcedureId(*from._impl_.pid_);
   }
-  if (from._internal_has_table_id()) {
-    _this->_impl_.table_id_ = new ::greptime::v1::TableId(*from._impl_.table_id_);
-  }
   // @@protoc_insertion_point(copy_constructor:greptime.v1.meta.DdlTaskResponse)
 }
 
@@ -4297,7 +4279,6 @@ inline void DdlTaskResponse::SharedCtor(
       decltype(_impl_.table_ids_){arena}
     , decltype(_impl_.header_){nullptr}
     , decltype(_impl_.pid_){nullptr}
-    , decltype(_impl_.table_id_){nullptr}
     , /*decltype(_impl_._cached_size_)*/{}
   };
 }
@@ -4316,7 +4297,6 @@ inline void DdlTaskResponse::SharedDtor() {
   _impl_.table_ids_.~RepeatedPtrField();
   if (this != internal_default_instance()) delete _impl_.header_;
   if (this != internal_default_instance()) delete _impl_.pid_;
-  if (this != internal_default_instance()) delete _impl_.table_id_;
 }
 
 void DdlTaskResponse::SetCachedSize(int size) const {
@@ -4338,10 +4318,6 @@ void DdlTaskResponse::Clear() {
     delete _impl_.pid_;
   }
   _impl_.pid_ = nullptr;
-  if (GetArenaForAllocation() == nullptr && _impl_.table_id_ != nullptr) {
-    delete _impl_.table_id_;
-  }
-  _impl_.table_id_ = nullptr;
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
 
@@ -4367,14 +4343,6 @@ const char* DdlTaskResponse::_InternalParse(const char* ptr, ::_pbi::ParseContex
         } else
           goto handle_unusual;
         continue;
-      // .greptime.v1.TableId table_id = 4;
-      case 4:
-        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 34)) {
-          ptr = ctx->ParseMessage(_internal_mutable_table_id(), ptr);
-          CHK_(ptr);
-        } else
-          goto handle_unusual;
-        continue;
       // repeated .greptime.v1.TableId table_ids = 5;
       case 5:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 42)) {
@@ -4431,13 +4399,6 @@ uint8_t* DdlTaskResponse::_InternalSerialize(
         _Internal::pid(this).GetCachedSize(), target, stream);
   }
 
-  // .greptime.v1.TableId table_id = 4;
-  if (this->_internal_has_table_id()) {
-    target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-      InternalWriteMessage(4, _Internal::table_id(this),
-        _Internal::table_id(this).GetCachedSize(), target, stream);
-  }
-
   // repeated .greptime.v1.TableId table_ids = 5;
   for (unsigned i = 0,
       n = static_cast<unsigned>(this->_internal_table_ids_size()); i < n; i++) {
@@ -4483,13 +4444,6 @@ size_t DdlTaskResponse::ByteSizeLong() const {
         *_impl_.pid_);
   }
 
-  // .greptime.v1.TableId table_id = 4;
-  if (this->_internal_has_table_id()) {
-    total_size += 1 +
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
-        *_impl_.table_id_);
-  }
-
   return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
 }
 
@@ -4517,10 +4471,6 @@ void DdlTaskResponse::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const
     _this->_internal_mutable_pid()->::greptime::v1::meta::ProcedureId::MergeFrom(
         from._internal_pid());
   }
-  if (from._internal_has_table_id()) {
-    _this->_internal_mutable_table_id()->::greptime::v1::TableId::MergeFrom(
-        from._internal_table_id());
-  }
   _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
 }
 
@@ -4540,8 +4490,8 @@ void DdlTaskResponse::InternalSwap(DdlTaskResponse* other) {
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
   _impl_.table_ids_.InternalSwap(&other->_impl_.table_ids_);
   ::PROTOBUF_NAMESPACE_ID::internal::memswap<
-      PROTOBUF_FIELD_OFFSET(DdlTaskResponse, _impl_.table_id_)
+      PROTOBUF_FIELD_OFFSET(DdlTaskResponse, _impl_.pid_)
-      + sizeof(DdlTaskResponse::_impl_.table_id_)
+      + sizeof(DdlTaskResponse::_impl_.pid_)
       - PROTOBUF_FIELD_OFFSET(DdlTaskResponse, _impl_.header_)>(
           reinterpret_cast<char*>(&_impl_.header_),
           reinterpret_cast<char*>(&other->_impl_.header_));

c++/greptime/v1/meta/ddl.pb.h

@@ -2843,7 +2843,6 @@ class DdlTaskResponse final :
     kTableIdsFieldNumber = 5,
     kHeaderFieldNumber = 1,
     kPidFieldNumber = 2,
-    kTableIdFieldNumber = 4,
   };
   // repeated .greptime.v1.TableId table_ids = 5;
   int table_ids_size() const;
@@ -2899,24 +2898,6 @@ class DdlTaskResponse final :
       ::greptime::v1::meta::ProcedureId* pid);
   ::greptime::v1::meta::ProcedureId* unsafe_arena_release_pid();
 
-  // .greptime.v1.TableId table_id = 4;
-  bool has_table_id() const;
-  private:
-  bool _internal_has_table_id() const;
-  public:
-  void clear_table_id();
-  const ::greptime::v1::TableId& table_id() const;
-  PROTOBUF_NODISCARD ::greptime::v1::TableId* release_table_id();
-  ::greptime::v1::TableId* mutable_table_id();
-  void set_allocated_table_id(::greptime::v1::TableId* table_id);
-  private:
-  const ::greptime::v1::TableId& _internal_table_id() const;
-  ::greptime::v1::TableId* _internal_mutable_table_id();
-  public:
-  void unsafe_arena_set_allocated_table_id(
-      ::greptime::v1::TableId* table_id);
-  ::greptime::v1::TableId* unsafe_arena_release_table_id();
-
   // @@protoc_insertion_point(class_scope:greptime.v1.meta.DdlTaskResponse)
  private:
   class _Internal;
@@ -2928,7 +2909,6 @@ class DdlTaskResponse final :
     ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::TableId > table_ids_;
     ::greptime::v1::meta::ResponseHeader* header_;
     ::greptime::v1::meta::ProcedureId* pid_;
-    ::greptime::v1::TableId* table_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
   union { Impl_ _impl_; };
@@ -5419,91 +5399,6 @@ inline void DdlTaskResponse::set_allocated_pid(::greptime::v1::meta::ProcedureId
   // @@protoc_insertion_point(field_set_allocated:greptime.v1.meta.DdlTaskResponse.pid)
 }
 
-// .greptime.v1.TableId table_id = 4;
-inline bool DdlTaskResponse::_internal_has_table_id() const {
-  return this != internal_default_instance() && _impl_.table_id_ != nullptr;
-}
-inline bool DdlTaskResponse::has_table_id() const {
-  return _internal_has_table_id();
-}
-inline const ::greptime::v1::TableId& DdlTaskResponse::_internal_table_id() const {
-  const ::greptime::v1::TableId* p = _impl_.table_id_;
-  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::TableId&>(
-      ::greptime::v1::_TableId_default_instance_);
-}
-inline const ::greptime::v1::TableId& DdlTaskResponse::table_id() const {
-  // @@protoc_insertion_point(field_get:greptime.v1.meta.DdlTaskResponse.table_id)
-  return _internal_table_id();
-}
-inline void DdlTaskResponse::unsafe_arena_set_allocated_table_id(
-    ::greptime::v1::TableId* table_id) {
-  if (GetArenaForAllocation() == nullptr) {
-    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.table_id_);
-  }
-  _impl_.table_id_ = table_id;
-  if (table_id) {
-    
-  } else {
-    
-  }
-  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.meta.DdlTaskResponse.table_id)
-}
-inline ::greptime::v1::TableId* DdlTaskResponse::release_table_id() {
-  
-  ::greptime::v1::TableId* temp = _impl_.table_id_;
-  _impl_.table_id_ = nullptr;
-#ifdef PROTOBUF_FORCE_COPY_IN_RELEASE
-  auto* old =  reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(temp);
-  temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
-  if (GetArenaForAllocation() == nullptr) { delete old; }
-#else  // PROTOBUF_FORCE_COPY_IN_RELEASE
-  if (GetArenaForAllocation() != nullptr) {
-    temp = ::PROTOBUF_NAMESPACE_ID::internal::DuplicateIfNonNull(temp);
-  }
-#endif  // !PROTOBUF_FORCE_COPY_IN_RELEASE
-  return temp;
-}
-inline ::greptime::v1::TableId* DdlTaskResponse::unsafe_arena_release_table_id() {
-  // @@protoc_insertion_point(field_release:greptime.v1.meta.DdlTaskResponse.table_id)
-  
-  ::greptime::v1::TableId* temp = _impl_.table_id_;
-  _impl_.table_id_ = nullptr;
-  return temp;
-}
-inline ::greptime::v1::TableId* DdlTaskResponse::_internal_mutable_table_id() {
-  
-  if (_impl_.table_id_ == nullptr) {
-    auto* p = CreateMaybeMessage<::greptime::v1::TableId>(GetArenaForAllocation());
-    _impl_.table_id_ = p;
-  }
-  return _impl_.table_id_;
-}
-inline ::greptime::v1::TableId* DdlTaskResponse::mutable_table_id() {
-  ::greptime::v1::TableId* _msg = _internal_mutable_table_id();
-  // @@protoc_insertion_point(field_mutable:greptime.v1.meta.DdlTaskResponse.table_id)
-  return _msg;
-}
-inline void DdlTaskResponse::set_allocated_table_id(::greptime::v1::TableId* table_id) {
-  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
-  if (message_arena == nullptr) {
-    delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.table_id_);
-  }
-  if (table_id) {
-    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
-        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
-                reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(table_id));
-    if (message_arena != submessage_arena) {
-      table_id = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
-          message_arena, table_id, submessage_arena);
-    }
-    
-  } else {
-    
-  }
-  _impl_.table_id_ = table_id;
-  // @@protoc_insertion_point(field_set_allocated:greptime.v1.meta.DdlTaskResponse.table_id)
-}
-
 // repeated .greptime.v1.TableId table_ids = 5;
 inline int DdlTaskResponse::_internal_table_ids_size() const {
   return _impl_.table_ids_.size();

go/greptime/v1/meta/ddl.pb.go

@@ -976,9 +976,6 @@ type DdlTaskResponse struct {
 
 	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
 	Pid    *ProcedureId    `protobuf:"bytes,2,opt,name=pid,proto3" json:"pid,omitempty"`
-	// Returns if table created.
-	// TODO(jeremy): remove it?
-	TableId *v1.TableId `protobuf:"bytes,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
 	// Returns if the tables created.
 	TableIds []*v1.TableId `protobuf:"bytes,5,rep,name=table_ids,json=tableIds,proto3" json:"table_ids,omitempty"`
 }
@@ -1029,13 +1026,6 @@ func (x *DdlTaskResponse) GetPid() *ProcedureId {
 	return nil
 }
 
-func (x *DdlTaskResponse) GetTableId() *v1.TableId {
-	if x != nil {
-		return x.TableId
-	}
-	return nil
-}
-
 func (x *DdlTaskResponse) GetTableIds() []*v1.TableId {
 	if x != nil {
 		return x.TableIds
@@ -1202,7 +1192,7 @@ var file_greptime_v1_meta_ddl_proto_rawDesc = []byte{
 	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, 0xe0, 0x01, 0x0a, 0x0f, 0x44, 0x64, 0x6c,
+	0x42, 0x06, 0x0a, 0x04, 0x74, 0x61, 0x73, 0x6b, 0x22, 0xaf, 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,
@@ -1210,20 +1200,17 @@ var file_greptime_v1_meta_ddl_proto_rawDesc = []byte{
 	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, 0x2f, 0x0a, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65,
+	0x49, 0x64, 0x52, 0x03, 0x70, 0x69, 0x64, 0x12, 0x31, 0x0a, 0x09, 0x74, 0x61, 0x62, 0x6c, 0x65,
-	0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, 0x65, 0x70,
+	0x5f, 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72, 0x65,
-	0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x52,
+	0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64,
-	0x07, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x12, 0x31, 0x0a, 0x09, 0x74, 0x61, 0x62, 0x6c,
+	0x52, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b, 0x44, 0x64,
-	0x65, 0x5f, 0x69, 0x64, 0x73, 0x18, 0x05, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x14, 0x2e, 0x67, 0x72,
+	0x6c, 0x54, 0x61, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x72, 0x65,
-	0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x49,
+	0x61, 0x74, 0x65, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10, 0x01, 0x42,
-	0x64, 0x52, 0x08, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x49, 0x64, 0x73, 0x2a, 0x23, 0x0a, 0x0b, 0x44,
+	0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47, 0x72,
-	0x64, 0x6c, 0x54, 0x61, 0x73, 0x6b, 0x54, 0x79, 0x70, 0x65, 0x12, 0x0a, 0x0a, 0x06, 0x43, 0x72,
+	0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70, 0x74,
-	0x65, 0x61, 0x74, 0x65, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x44, 0x72, 0x6f, 0x70, 0x10, 0x01,
+	0x69, 0x6d, 0x65, 0x2d, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x2f, 0x67, 0x72, 0x65,
-	0x42, 0x3c, 0x5a, 0x3a, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x47,
+	0x70, 0x74, 0x69, 0x6d, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x6d, 0x65, 0x74, 0x61, 0x62, 0x06, 0x70,
-	0x72, 0x65, 0x70, 0x74, 0x69, 0x6d, 0x65, 0x54, 0x65, 0x61, 0x6d, 0x2f, 0x67, 0x72, 0x65, 0x70,
+	0x72, 0x6f, 0x74, 0x6f, 0x33,
-	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 (
@@ -1306,13 +1293,12 @@ var file_greptime_v1_meta_ddl_proto_depIdxs = []int32{
 	13, // 28: greptime.v1.meta.DdlTaskRequest.drop_view_task:type_name -> greptime.v1.meta.DropViewTask
 	29, // 29: greptime.v1.meta.DdlTaskResponse.header:type_name -> greptime.v1.meta.ResponseHeader
 	30, // 30: greptime.v1.meta.DdlTaskResponse.pid:type_name -> greptime.v1.meta.ProcedureId
-	31, // 31: greptime.v1.meta.DdlTaskResponse.table_id:type_name -> greptime.v1.TableId
+	31, // 31: greptime.v1.meta.DdlTaskResponse.table_ids:type_name -> greptime.v1.TableId
-	31, // 32: greptime.v1.meta.DdlTaskResponse.table_ids:type_name -> greptime.v1.TableId
+	32, // [32:32] is the sub-list for method output_type
-	33, // [33:33] is the sub-list for method output_type
+	32, // [32:32] is the sub-list for method input_type
-	33, // [33:33] is the sub-list for method input_type
+	32, // [32:32] is the sub-list for extension type_name
-	33, // [33:33] is the sub-list for extension type_name
+	32, // [32:32] is the sub-list for extension extendee
-	33, // [33:33] is the sub-list for extension extendee
+	0,  // [0:32] is the sub-list for field type_name
-	0,  // [0:33] is the sub-list for field type_name
 }
 
 func init() { file_greptime_v1_meta_ddl_proto_init() }

java/src/main/java/greptime/v1/meta/Ddl.java

@@ -13197,36 +13197,6 @@ public final class Ddl {
      */
     greptime.v1.meta.Common.ProcedureIdOrBuilder getPidOrBuilder();
 
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     * @return Whether the tableId field is set.
-     */
-    boolean hasTableId();
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     * @return The tableId.
-     */
-    io.greptime.v1.Ddl.TableId getTableId();
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     */
-    io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder();
-
     /**
      * <pre>
      * Returns if the tables created.
@@ -13344,19 +13314,6 @@ public final class Ddl {
 
               break;
             }
-            case 34: {
-              io.greptime.v1.Ddl.TableId.Builder subBuilder = null;
-              if (tableId_ != null) {
-                subBuilder = tableId_.toBuilder();
-              }
-              tableId_ = input.readMessage(io.greptime.v1.Ddl.TableId.parser(), extensionRegistry);
-              if (subBuilder != null) {
-                subBuilder.mergeFrom(tableId_);
-                tableId_ = subBuilder.buildPartial();
-              }
-
-              break;
-            }
             case 42: {
               if (!((mutable_bitField0_ & 0x00000001) != 0)) {
                 tableIds_ = new java.util.ArrayList<io.greptime.v1.Ddl.TableId>();
@@ -13455,47 +13412,6 @@ public final class Ddl {
       return getPid();
     }
 
-    public static final int TABLE_ID_FIELD_NUMBER = 4;
-    private io.greptime.v1.Ddl.TableId tableId_;
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     * @return Whether the tableId field is set.
-     */
-    @java.lang.Override
-    public boolean hasTableId() {
-      return tableId_ != null;
-    }
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     * @return The tableId.
-     */
-    @java.lang.Override
-    public io.greptime.v1.Ddl.TableId getTableId() {
-      return tableId_ == null ? io.greptime.v1.Ddl.TableId.getDefaultInstance() : tableId_;
-    }
-    /**
-     * <pre>
-     * Returns if table created.
-     * TODO(jeremy): remove it?
-     * </pre>
-     *
-     * <code>.greptime.v1.TableId table_id = 4;</code>
-     */
-    @java.lang.Override
-    public io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder() {
-      return getTableId();
-    }
-
     public static final int TABLE_IDS_FIELD_NUMBER = 5;
     private java.util.List<io.greptime.v1.Ddl.TableId> tableIds_;
     /**
@@ -13576,9 +13492,6 @@ public final class Ddl {
       if (pid_ != null) {
         output.writeMessage(2, getPid());
       }
-      if (tableId_ != null) {
-        output.writeMessage(4, getTableId());
-      }
       for (int i = 0; i < tableIds_.size(); i++) {
         output.writeMessage(5, tableIds_.get(i));
       }
@@ -13599,10 +13512,6 @@ public final class Ddl {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(2, getPid());
       }
-      if (tableId_ != null) {
-        size += com.google.protobuf.CodedOutputStream
-          .computeMessageSize(4, getTableId());
-      }
       for (int i = 0; i < tableIds_.size(); i++) {
         size += com.google.protobuf.CodedOutputStream
           .computeMessageSize(5, tableIds_.get(i));
@@ -13632,11 +13541,6 @@ public final class Ddl {
         if (!getPid()
             .equals(other.getPid())) return false;
       }
-      if (hasTableId() != other.hasTableId()) return false;
-      if (hasTableId()) {
-        if (!getTableId()
-            .equals(other.getTableId())) return false;
-      }
       if (!getTableIdsList()
           .equals(other.getTableIdsList())) return false;
       if (!unknownFields.equals(other.unknownFields)) return false;
@@ -13658,10 +13562,6 @@ public final class Ddl {
         hash = (37 * hash) + PID_FIELD_NUMBER;
         hash = (53 * hash) + getPid().hashCode();
       }
-      if (hasTableId()) {
-        hash = (37 * hash) + TABLE_ID_FIELD_NUMBER;
-        hash = (53 * hash) + getTableId().hashCode();
-      }
       if (getTableIdsCount() > 0) {
         hash = (37 * hash) + TABLE_IDS_FIELD_NUMBER;
         hash = (53 * hash) + getTableIdsList().hashCode();
@@ -13812,12 +13712,6 @@ public final class Ddl {
           pid_ = null;
           pidBuilder_ = null;
         }
-        if (tableIdBuilder_ == null) {
-          tableId_ = null;
-        } else {
-          tableId_ = null;
-          tableIdBuilder_ = null;
-        }
         if (tableIdsBuilder_ == null) {
           tableIds_ = java.util.Collections.emptyList();
           bitField0_ = (bitField0_ & ~0x00000001);
@@ -13861,11 +13755,6 @@ public final class Ddl {
         } else {
           result.pid_ = pidBuilder_.build();
         }
-        if (tableIdBuilder_ == null) {
-          result.tableId_ = tableId_;
-        } else {
-          result.tableId_ = tableIdBuilder_.build();
-        }
         if (tableIdsBuilder_ == null) {
           if (((bitField0_ & 0x00000001) != 0)) {
             tableIds_ = java.util.Collections.unmodifiableList(tableIds_);
@@ -13929,9 +13818,6 @@ public final class Ddl {
         if (other.hasPid()) {
           mergePid(other.getPid());
         }
-        if (other.hasTableId()) {
-          mergeTableId(other.getTableId());
-        }
         if (tableIdsBuilder_ == null) {
           if (!other.tableIds_.isEmpty()) {
             if (tableIds_.isEmpty()) {
@@ -14226,170 +14112,6 @@ public final class Ddl {
         return pidBuilder_;
       }
 
-      private io.greptime.v1.Ddl.TableId tableId_;
-      private com.google.protobuf.SingleFieldBuilderV3<
-          io.greptime.v1.Ddl.TableId, io.greptime.v1.Ddl.TableId.Builder, io.greptime.v1.Ddl.TableIdOrBuilder> tableIdBuilder_;
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       * @return Whether the tableId field is set.
-       */
-      public boolean hasTableId() {
-        return tableIdBuilder_ != null || tableId_ != null;
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       * @return The tableId.
-       */
-      public io.greptime.v1.Ddl.TableId getTableId() {
-        if (tableIdBuilder_ == null) {
-          return tableId_ == null ? io.greptime.v1.Ddl.TableId.getDefaultInstance() : tableId_;
-        } else {
-          return tableIdBuilder_.getMessage();
-        }
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public Builder setTableId(io.greptime.v1.Ddl.TableId value) {
-        if (tableIdBuilder_ == null) {
-          if (value == null) {
-            throw new NullPointerException();
-          }
-          tableId_ = value;
-          onChanged();
-        } else {
-          tableIdBuilder_.setMessage(value);
-        }
-
-        return this;
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public Builder setTableId(
-          io.greptime.v1.Ddl.TableId.Builder builderForValue) {
-        if (tableIdBuilder_ == null) {
-          tableId_ = builderForValue.build();
-          onChanged();
-        } else {
-          tableIdBuilder_.setMessage(builderForValue.build());
-        }
-
-        return this;
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public Builder mergeTableId(io.greptime.v1.Ddl.TableId value) {
-        if (tableIdBuilder_ == null) {
-          if (tableId_ != null) {
-            tableId_ =
-              io.greptime.v1.Ddl.TableId.newBuilder(tableId_).mergeFrom(value).buildPartial();
-          } else {
-            tableId_ = value;
-          }
-          onChanged();
-        } else {
-          tableIdBuilder_.mergeFrom(value);
-        }
-
-        return this;
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public Builder clearTableId() {
-        if (tableIdBuilder_ == null) {
-          tableId_ = null;
-          onChanged();
-        } else {
-          tableId_ = null;
-          tableIdBuilder_ = null;
-        }
-
-        return this;
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public io.greptime.v1.Ddl.TableId.Builder getTableIdBuilder() {
-        
-        onChanged();
-        return getTableIdFieldBuilder().getBuilder();
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      public io.greptime.v1.Ddl.TableIdOrBuilder getTableIdOrBuilder() {
-        if (tableIdBuilder_ != null) {
-          return tableIdBuilder_.getMessageOrBuilder();
-        } else {
-          return tableId_ == null ?
-              io.greptime.v1.Ddl.TableId.getDefaultInstance() : tableId_;
-        }
-      }
-      /**
-       * <pre>
-       * Returns if table created.
-       * TODO(jeremy): remove it?
-       * </pre>
-       *
-       * <code>.greptime.v1.TableId table_id = 4;</code>
-       */
-      private com.google.protobuf.SingleFieldBuilderV3<
-          io.greptime.v1.Ddl.TableId, io.greptime.v1.Ddl.TableId.Builder, io.greptime.v1.Ddl.TableIdOrBuilder> 
-          getTableIdFieldBuilder() {
-        if (tableIdBuilder_ == null) {
-          tableIdBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
-              io.greptime.v1.Ddl.TableId, io.greptime.v1.Ddl.TableId.Builder, io.greptime.v1.Ddl.TableIdOrBuilder>(
-                  getTableId(),
-                  getParentForChildren(),
-                  isClean());
-          tableId_ = null;
-        }
-        return tableIdBuilder_;
-      }
-
       private java.util.List<io.greptime.v1.Ddl.TableId> tableIds_ =
         java.util.Collections.emptyList();
       private void ensureTableIdsIsMutable() {
@@ -14890,10 +14612,9 @@ public final class Ddl {
       "<\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\"\300\001\n\017DdlTaskResponse\0220\n\006header\030\001 " +
+      "\006\n\004task\"\230\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\024.greptime.v1.TableI" +
       "d\022\'\n\ttable_ids\030\005 \003(\0132\024.greptime.v1.Table" +
       "Id*#\n\013DdlTaskType\022\n\n\006Create\020\000\022\010\n\004Drop\020\001B" +
       "<Z:github.com/GreptimeTeam/greptime-prot" +
@@ -14996,7 +14717,7 @@ public final class Ddl {
     internal_static_greptime_v1_meta_DdlTaskResponse_fieldAccessorTable = new
       com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
         internal_static_greptime_v1_meta_DdlTaskResponse_descriptor,
-        new java.lang.String[] { "Header", "Pid", "TableId", "TableIds", });
+        new java.lang.String[] { "Header", "Pid", "TableIds", });
     greptime.v1.meta.Common.getDescriptor();
     greptime.v1.meta.Route.getDescriptor();
     io.greptime.v1.Ddl.getDescriptor();

proto/greptime/v1/meta/ddl.proto

@@ -104,9 +104,6 @@ message DdlTaskResponse {
     ResponseHeader header = 1;
     ProcedureId pid = 2;
 
-    // Returns if table created.
-    // TODO(jeremy): remove it?
-    TableId table_id = 4;
     // Returns if the tables created.
     repeated TableId table_ids = 5;
 }