diff --git a/c++/greptime/v1/region/server.grpc.pb.cc b/c++/greptime/v1/region/server.grpc.pb.cc
index 37efdc4d..7a392015 100644
--- a/c++/greptime/v1/region/server.grpc.pb.cc
+++ b/c++/greptime/v1/region/server.grpc.pb.cc
@@ -25,7 +25,6 @@ namespace region {
 
 static const char* Region_method_names[] = {
   "/greptime.v1.region.Region/Handle",
-  "/greptime.v1.region.Region/HandleRequests",
 };
 
 std::unique_ptr< Region::Stub> Region::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) {
@@ -36,7 +35,6 @@ std::unique_ptr< Region::Stub> Region::NewStub(const std::shared_ptr< ::grpc::Ch
 
 Region::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options)
   : channel_(channel), rpcmethod_Handle_(Region_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel)
-  , rpcmethod_HandleRequests_(Region_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::CLIENT_STREAMING, channel)
   {}
 
 ::grpc::Status Region::Stub::Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::greptime::v1::region::RegionResponse* response) {
@@ -62,22 +60,6 @@ ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>* Regi
   return result;
 }
 
-::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-  return ::grpc::internal::ClientWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), rpcmethod_HandleRequests_, context, response);
-}
-
-void Region::Stub::async::HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) {
-  ::grpc::internal::ClientCallbackWriterFactory< ::greptime::v1::region::RegionRequest>::Create(stub_->channel_.get(), stub_->rpcmethod_HandleRequests_, context, response, reactor);
-}
-
-::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-  return ::grpc::internal::ClientAsyncWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), cq, rpcmethod_HandleRequests_, context, response, true, tag);
-}
-
-::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* Region::Stub::PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-  return ::grpc::internal::ClientAsyncWriterFactory< ::greptime::v1::region::RegionRequest>::Create(channel_.get(), cq, rpcmethod_HandleRequests_, context, response, false, nullptr);
-}
-
 Region::Service::Service() {
   AddMethod(new ::grpc::internal::RpcServiceMethod(
       Region_method_names[0],
@@ -89,16 +71,6 @@ Region::Service::Service() {
              ::greptime::v1::region::RegionResponse* resp) {
                return service->Handle(ctx, req, resp);
              }, this)));
-  AddMethod(new ::grpc::internal::RpcServiceMethod(
-      Region_method_names[1],
-      ::grpc::internal::RpcMethod::CLIENT_STREAMING,
-      new ::grpc::internal::ClientStreamingHandler< Region::Service, ::greptime::v1::region::RegionRequest, ::greptime::v1::region::RegionResponse>(
-          [](Region::Service* service,
-             ::grpc::ServerContext* ctx,
-             ::grpc::ServerReader<::greptime::v1::region::RegionRequest>* reader,
-             ::greptime::v1::region::RegionResponse* resp) {
-               return service->HandleRequests(ctx, reader, resp);
-             }, this)));
 }
 
 Region::Service::~Service() {
@@ -111,13 +83,6 @@ ::grpc::Status Region::Service::Handle(::grpc::ServerContext* context, const ::g
   return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
 }
 
-::grpc::Status Region::Service::HandleRequests(::grpc::ServerContext* context, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* reader, ::greptime::v1::region::RegionResponse* response) {
-  (void) context;
-  (void) reader;
-  (void) response;
-  return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-}
-
 
 }  // namespace greptime
 }  // namespace v1
diff --git a/c++/greptime/v1/region/server.grpc.pb.h b/c++/greptime/v1/region/server.grpc.pb.h
index c62bd035..d2e36af9 100644
--- a/c++/greptime/v1/region/server.grpc.pb.h
+++ b/c++/greptime/v1/region/server.grpc.pb.h
@@ -59,21 +59,11 @@ class Region final {
     std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>> PrepareAsyncHandle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) {
       return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>>(PrepareAsyncHandleRaw(context, request, cq));
     }
-    std::unique_ptr< ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>> HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-      return std::unique_ptr< ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>>(HandleRequestsRaw(context, response));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>> AsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>>(AsyncHandleRequestsRaw(context, response, cq, tag));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>> PrepareAsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>>(PrepareAsyncHandleRequestsRaw(context, response, cq));
-    }
     class async_interface {
      public:
       virtual ~async_interface() {}
       virtual void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, std::function<void(::grpc::Status)>) = 0;
       virtual void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientUnaryReactor* reactor) = 0;
-      virtual void HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) = 0;
     };
     typedef class async_interface experimental_async_interface;
     virtual class async_interface* async() { return nullptr; }
@@ -81,9 +71,6 @@ class Region final {
    private:
     virtual ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>* AsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) = 0;
     virtual ::grpc::ClientAsyncResponseReaderInterface< ::greptime::v1::region::RegionResponse>* PrepareAsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) = 0;
-    virtual ::grpc::ClientWriterInterface< ::greptime::v1::region::RegionRequest>* HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) = 0;
-    virtual ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>* AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) = 0;
-    virtual ::grpc::ClientAsyncWriterInterface< ::greptime::v1::region::RegionRequest>* PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) = 0;
   };
   class Stub final : public StubInterface {
    public:
@@ -95,21 +82,11 @@ class Region final {
     std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>> PrepareAsyncHandle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) {
       return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>>(PrepareAsyncHandleRaw(context, request, cq));
     }
-    std::unique_ptr< ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>> HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) {
-      return std::unique_ptr< ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>>(HandleRequestsRaw(context, response));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>> AsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>>(AsyncHandleRequestsRaw(context, response, cq, tag));
-    }
-    std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>> PrepareAsyncHandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) {
-      return std::unique_ptr< ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>>(PrepareAsyncHandleRequestsRaw(context, response, cq));
-    }
     class async final :
       public StubInterface::async_interface {
      public:
       void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, std::function<void(::grpc::Status)>) override;
       void Handle(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientUnaryReactor* reactor) override;
-      void HandleRequests(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::ClientWriteReactor< ::greptime::v1::region::RegionRequest>* reactor) override;
      private:
       friend class Stub;
       explicit async(Stub* stub): stub_(stub) { }
@@ -123,11 +100,7 @@ class Region final {
     class async async_stub_{this};
     ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>* AsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) override;
     ::grpc::ClientAsyncResponseReader< ::greptime::v1::region::RegionResponse>* PrepareAsyncHandleRaw(::grpc::ClientContext* context, const ::greptime::v1::region::RegionRequest& request, ::grpc::CompletionQueue* cq) override;
-    ::grpc::ClientWriter< ::greptime::v1::region::RegionRequest>* HandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response) override;
-    ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* AsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq, void* tag) override;
-    ::grpc::ClientAsyncWriter< ::greptime::v1::region::RegionRequest>* PrepareAsyncHandleRequestsRaw(::grpc::ClientContext* context, ::greptime::v1::region::RegionResponse* response, ::grpc::CompletionQueue* cq) override;
     const ::grpc::internal::RpcMethod rpcmethod_Handle_;
-    const ::grpc::internal::RpcMethod rpcmethod_HandleRequests_;
   };
   static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
 
@@ -136,7 +109,6 @@ class Region final {
     Service();
     virtual ~Service();
     virtual ::grpc::Status Handle(::grpc::ServerContext* context, const ::greptime::v1::region::RegionRequest* request, ::greptime::v1::region::RegionResponse* response);
-    virtual ::grpc::Status HandleRequests(::grpc::ServerContext* context, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* reader, ::greptime::v1::region::RegionResponse* response);
   };
   template <class BaseClass>
   class WithAsyncMethod_Handle : public BaseClass {
@@ -158,27 +130,7 @@ class Region final {
       ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
     }
   };
-  template <class BaseClass>
-  class WithAsyncMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithAsyncMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodAsync(1);
-    }
-    ~WithAsyncMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    void RequestHandleRequests(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::greptime::v1::region::RegionResponse, ::greptime::v1::region::RegionRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
-      ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag);
-    }
-  };
-  typedef WithAsyncMethod_Handle<WithAsyncMethod_HandleRequests<Service > > AsyncService;
+  typedef WithAsyncMethod_Handle<Service > AsyncService;
   template <class BaseClass>
   class WithCallbackMethod_Handle : public BaseClass {
    private:
@@ -206,29 +158,7 @@ class Region final {
     virtual ::grpc::ServerUnaryReactor* Handle(
       ::grpc::CallbackServerContext* /*context*/, const ::greptime::v1::region::RegionRequest* /*request*/, ::greptime::v1::region::RegionResponse* /*response*/)  { return nullptr; }
   };
-  template <class BaseClass>
-  class WithCallbackMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithCallbackMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodCallback(1,
-          new ::grpc::internal::CallbackClientStreamingHandler< ::greptime::v1::region::RegionRequest, ::greptime::v1::region::RegionResponse>(
-            [this](
-                   ::grpc::CallbackServerContext* context, ::greptime::v1::region::RegionResponse* response) { return this->HandleRequests(context, response); }));
-    }
-    ~WithCallbackMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    virtual ::grpc::ServerReadReactor< ::greptime::v1::region::RegionRequest>* HandleRequests(
-      ::grpc::CallbackServerContext* /*context*/, ::greptime::v1::region::RegionResponse* /*response*/)  { return nullptr; }
-  };
-  typedef WithCallbackMethod_Handle<WithCallbackMethod_HandleRequests<Service > > CallbackService;
+  typedef WithCallbackMethod_Handle<Service > CallbackService;
   typedef CallbackService ExperimentalCallbackService;
   template <class BaseClass>
   class WithGenericMethod_Handle : public BaseClass {
@@ -248,23 +178,6 @@ class Region final {
     }
   };
   template <class BaseClass>
-  class WithGenericMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithGenericMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodGeneric(1);
-    }
-    ~WithGenericMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-  };
-  template <class BaseClass>
   class WithRawMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -285,26 +198,6 @@ class Region final {
     }
   };
   template <class BaseClass>
-  class WithRawMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithRawMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodRaw(1);
-    }
-    ~WithRawMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    void RequestHandleRequests(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::ByteBuffer, ::grpc::ByteBuffer>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
-      ::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag);
-    }
-  };
-  template <class BaseClass>
   class WithRawCallbackMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
@@ -327,28 +220,6 @@ class Region final {
       ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/)  { return nullptr; }
   };
   template <class BaseClass>
-  class WithRawCallbackMethod_HandleRequests : public BaseClass {
-   private:
-    void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
-   public:
-    WithRawCallbackMethod_HandleRequests() {
-      ::grpc::Service::MarkMethodRawCallback(1,
-          new ::grpc::internal::CallbackClientStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
-            [this](
-                   ::grpc::CallbackServerContext* context, ::grpc::ByteBuffer* response) { return this->HandleRequests(context, response); }));
-    }
-    ~WithRawCallbackMethod_HandleRequests() override {
-      BaseClassMustBeDerivedFromService(this);
-    }
-    // disable synchronous version of this method
-    ::grpc::Status HandleRequests(::grpc::ServerContext* /*context*/, ::grpc::ServerReader< ::greptime::v1::region::RegionRequest>* /*reader*/, ::greptime::v1::region::RegionResponse* /*response*/) override {
-      abort();
-      return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
-    }
-    virtual ::grpc::ServerReadReactor< ::grpc::ByteBuffer>* HandleRequests(
-      ::grpc::CallbackServerContext* /*context*/, ::grpc::ByteBuffer* /*response*/)  { return nullptr; }
-  };
-  template <class BaseClass>
   class WithStreamedUnaryMethod_Handle : public BaseClass {
    private:
     void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
diff --git a/c++/greptime/v1/region/server.pb.cc b/c++/greptime/v1/region/server.pb.cc
index dc1a7201..ae5712f8 100644
--- a/c++/greptime/v1/region/server.pb.cc
+++ b/c++/greptime/v1/region/server.pb.cc
@@ -80,7 +80,7 @@ struct DeleteRequestsDefaultTypeInternal {
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 DeleteRequestsDefaultTypeInternal _DeleteRequests_default_instance_;
 PROTOBUF_CONSTEXPR InsertRequest::InsertRequest(
     ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.rows_)*/{}
+    /*decltype(_impl_.rows_)*/nullptr
   , /*decltype(_impl_.region_id_)*/uint64_t{0u}
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct InsertRequestDefaultTypeInternal {
@@ -94,7 +94,7 @@ struct InsertRequestDefaultTypeInternal {
 PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 InsertRequestDefaultTypeInternal _InsertRequest_default_instance_;
 PROTOBUF_CONSTEXPR DeleteRequest::DeleteRequest(
     ::_pbi::ConstantInitialized): _impl_{
-    /*decltype(_impl_.rows_)*/{}
+    /*decltype(_impl_.rows_)*/nullptr
   , /*decltype(_impl_.region_id_)*/uint64_t{0u}
   , /*decltype(_impl_._cached_size_)*/{}} {}
 struct DeleteRequestDefaultTypeInternal {
@@ -485,40 +485,38 @@ const char descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto[] P
   "s\030\002 \001(\004\"E\n\016InsertRequests\0223\n\010requests\030\001 "
   "\003(\0132!.greptime.v1.region.InsertRequest\"E"
   "\n\016DeleteRequests\0223\n\010requests\030\001 \003(\0132!.gre"
-  "ptime.v1.region.DeleteRequest\"B\n\rInsertR"
-  "equest\022\021\n\tregion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132"
-  "\020.greptime.v1.Row\"B\n\rDeleteRequest\022\021\n\tre"
-  "gion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132\020.greptime.v"
-  "1.Row\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001(\004"
-  "\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tregi"
-  "on_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_de"
-  "fs\030\003 \003(\0132\035.greptime.v1.region.ColumnDef\022"
-  "\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_ex"
-  "ists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022\?\n\007option"
-  "s\030\007 \003(\0132..greptime.v1.region.CreateReque"
-  "st.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key\030\001"
-  " \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest\022\021"
-  "\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\treg"
-  "ion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion_d"
-  "ir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v1."
-  "region.OpenRequest.OptionsEntry\032.\n\014Optio"
-  "nsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\""
-  "!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Al"
-  "terRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014FlushRe"
-  "quest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReque"
-  "st\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n\004n"
-  "ame\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010datatype"
-  "\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n\013i"
-  "s_nullable\030\004 \001(\010\022\032\n\022default_constraint\030\005"
-  " \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime.v"
-  "1.SemanticType2\264\001\n\006Region\022O\n\006Handle\022!.gr"
-  "eptime.v1.region.RegionRequest\032\".greptim"
-  "e.v1.region.RegionResponse\022Y\n\016HandleRequ"
-  "ests\022!.greptime.v1.region.RegionRequest\032"
-  "\".greptime.v1.region.RegionResponse(\001B]\n"
-  "\025io.greptime.v1.regionB\006ServerZ<github.c"
-  "om/GreptimeTeam/greptime-proto/go/grepti"
-  "me/v1/regionb\006proto3"
+  "ptime.v1.region.DeleteRequest\"C\n\rInsertR"
+  "equest\022\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132"
+  "\021.greptime.v1.Rows\"C\n\rDeleteRequest\022\021\n\tr"
+  "egion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime."
+  "v1.Rows\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001"
+  "(\004\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tre"
+  "gion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_"
+  "defs\030\003 \003(\0132\035.greptime.v1.region.ColumnDe"
+  "f\022\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_"
+  "exists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022\?\n\007opti"
+  "ons\030\007 \003(\0132..greptime.v1.region.CreateReq"
+  "uest.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key"
+  "\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest"
+  "\022\021\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\tr"
+  "egion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion"
+  "_dir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v"
+  "1.region.OpenRequest.OptionsEntry\032.\n\014Opt"
+  "ionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028"
+  "\001\"!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014"
+  "AlterRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Flush"
+  "Request\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReq"
+  "uest\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n"
+  "\004name\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010dataty"
+  "pe\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n"
+  "\013is_nullable\030\004 \001(\010\022\032\n\022default_constraint"
+  "\030\005 \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime"
+  ".v1.SemanticType2Y\n\006Region\022O\n\006Handle\022!.g"
+  "reptime.v1.region.RegionRequest\032\".grepti"
+  "me.v1.region.RegionResponseB]\n\025io.grepti"
+  "me.v1.regionB\006ServerZ<github.com/Greptim"
+  "eTeam/greptime-proto/go/greptime/v1/regi"
+  "onb\006proto3"
   ;
 static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps[2] = {
   &::descriptor_table_greptime_2fv1_2fcommon_2eproto,
@@ -526,7 +524,7 @@ static const ::_pbi::DescriptorTable* const descriptor_table_greptime_2fv1_2freg
 };
 static ::_pbi::once_flag descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once;
 const ::_pbi::DescriptorTable descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto = {
-    false, false, 2180, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
+    false, false, 2090, descriptor_table_protodef_greptime_2fv1_2fregion_2fserver_2eproto,
     "greptime/v1/region/server.proto",
     &descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_once, descriptor_table_greptime_2fv1_2fregion_2fserver_2eproto_deps, 2, 17,
     schemas, file_default_instances, TableStruct_greptime_2fv1_2fregion_2fserver_2eproto::offsets,
@@ -1906,10 +1904,18 @@ ::PROTOBUF_NAMESPACE_ID::Metadata DeleteRequests::GetMetadata() const {
 
 class InsertRequest::_Internal {
  public:
+  static const ::greptime::v1::Rows& rows(const InsertRequest* msg);
 };
 
+const ::greptime::v1::Rows&
+InsertRequest::_Internal::rows(const InsertRequest* msg) {
+  return *msg->_impl_.rows_;
+}
 void InsertRequest::clear_rows() {
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
 }
 InsertRequest::InsertRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
@@ -1921,11 +1927,14 @@ InsertRequest::InsertRequest(const InsertRequest& from)
   : ::PROTOBUF_NAMESPACE_ID::Message() {
   InsertRequest* const _this = this; (void)_this;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){from._impl_.rows_}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  if (from._internal_has_rows()) {
+    _this->_impl_.rows_ = new ::greptime::v1::Rows(*from._impl_.rows_);
+  }
   _this->_impl_.region_id_ = from._impl_.region_id_;
   // @@protoc_insertion_point(copy_constructor:greptime.v1.region.InsertRequest)
 }
@@ -1935,7 +1944,7 @@ inline void InsertRequest::SharedCtor(
   (void)arena;
   (void)is_message_owned;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){arena}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){uint64_t{0u}}
     , /*decltype(_impl_._cached_size_)*/{}
   };
@@ -1952,7 +1961,7 @@ InsertRequest::~InsertRequest() {
 
 inline void InsertRequest::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
-  _impl_.rows_.~RepeatedPtrField();
+  if (this != internal_default_instance()) delete _impl_.rows_;
 }
 
 void InsertRequest::SetCachedSize(int size) const {
@@ -1965,7 +1974,10 @@ void InsertRequest::Clear() {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
   _impl_.region_id_ = uint64_t{0u};
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
@@ -1984,16 +1996,11 @@ const char* InsertRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext*
         } else
           goto handle_unusual;
         continue;
-      // repeated .greptime.v1.Row rows = 2;
+      // .greptime.v1.Rows rows = 2;
       case 2:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
-          ptr -= 1;
-          do {
-            ptr += 1;
-            ptr = ctx->ParseMessage(_internal_add_rows(), ptr);
-            CHK_(ptr);
-            if (!ctx->DataAvailable(ptr)) break;
-          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
+          ptr = ctx->ParseMessage(_internal_mutable_rows(), ptr);
+          CHK_(ptr);
         } else
           goto handle_unusual;
         continue;
@@ -2032,12 +2039,11 @@ uint8_t* InsertRequest::_InternalSerialize(
     target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target);
   }
 
-  // repeated .greptime.v1.Row rows = 2;
-  for (unsigned i = 0,
-      n = static_cast<unsigned>(this->_internal_rows_size()); i < n; i++) {
-    const auto& repfield = this->_internal_rows(i);
+  // .greptime.v1.Rows rows = 2;
+  if (this->_internal_has_rows()) {
     target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-        InternalWriteMessage(2, repfield, repfield.GetCachedSize(), target, stream);
+      InternalWriteMessage(2, _Internal::rows(this),
+        _Internal::rows(this).GetCachedSize(), target, stream);
   }
 
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
@@ -2056,11 +2062,11 @@ size_t InsertRequest::ByteSizeLong() const {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  // repeated .greptime.v1.Row rows = 2;
-  total_size += 1UL * this->_internal_rows_size();
-  for (const auto& msg : this->_impl_.rows_) {
-    total_size +=
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
+  // .greptime.v1.Rows rows = 2;
+  if (this->_internal_has_rows()) {
+    total_size += 1 +
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
+        *_impl_.rows_);
   }
 
   // uint64 region_id = 1;
@@ -2086,7 +2092,10 @@ void InsertRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
-  _this->_impl_.rows_.MergeFrom(from._impl_.rows_);
+  if (from._internal_has_rows()) {
+    _this->_internal_mutable_rows()->::greptime::v1::Rows::MergeFrom(
+        from._internal_rows());
+  }
   if (from._internal_region_id() != 0) {
     _this->_internal_set_region_id(from._internal_region_id());
   }
@@ -2107,8 +2116,12 @@ bool InsertRequest::IsInitialized() const {
 void InsertRequest::InternalSwap(InsertRequest* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
-  _impl_.rows_.InternalSwap(&other->_impl_.rows_);
-  swap(_impl_.region_id_, other->_impl_.region_id_);
+  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
+      PROTOBUF_FIELD_OFFSET(InsertRequest, _impl_.region_id_)
+      + sizeof(InsertRequest::_impl_.region_id_)
+      - PROTOBUF_FIELD_OFFSET(InsertRequest, _impl_.rows_)>(
+          reinterpret_cast<char*>(&_impl_.rows_),
+          reinterpret_cast<char*>(&other->_impl_.rows_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata InsertRequest::GetMetadata() const {
@@ -2121,10 +2134,18 @@ ::PROTOBUF_NAMESPACE_ID::Metadata InsertRequest::GetMetadata() const {
 
 class DeleteRequest::_Internal {
  public:
+  static const ::greptime::v1::Rows& rows(const DeleteRequest* msg);
 };
 
+const ::greptime::v1::Rows&
+DeleteRequest::_Internal::rows(const DeleteRequest* msg) {
+  return *msg->_impl_.rows_;
+}
 void DeleteRequest::clear_rows() {
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
 }
 DeleteRequest::DeleteRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
                          bool is_message_owned)
@@ -2136,11 +2157,14 @@ DeleteRequest::DeleteRequest(const DeleteRequest& from)
   : ::PROTOBUF_NAMESPACE_ID::Message() {
   DeleteRequest* const _this = this; (void)_this;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){from._impl_.rows_}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){}
     , /*decltype(_impl_._cached_size_)*/{}};
 
   _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
+  if (from._internal_has_rows()) {
+    _this->_impl_.rows_ = new ::greptime::v1::Rows(*from._impl_.rows_);
+  }
   _this->_impl_.region_id_ = from._impl_.region_id_;
   // @@protoc_insertion_point(copy_constructor:greptime.v1.region.DeleteRequest)
 }
@@ -2150,7 +2174,7 @@ inline void DeleteRequest::SharedCtor(
   (void)arena;
   (void)is_message_owned;
   new (&_impl_) Impl_{
-      decltype(_impl_.rows_){arena}
+      decltype(_impl_.rows_){nullptr}
     , decltype(_impl_.region_id_){uint64_t{0u}}
     , /*decltype(_impl_._cached_size_)*/{}
   };
@@ -2167,7 +2191,7 @@ DeleteRequest::~DeleteRequest() {
 
 inline void DeleteRequest::SharedDtor() {
   GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
-  _impl_.rows_.~RepeatedPtrField();
+  if (this != internal_default_instance()) delete _impl_.rows_;
 }
 
 void DeleteRequest::SetCachedSize(int size) const {
@@ -2180,7 +2204,10 @@ void DeleteRequest::Clear() {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  _impl_.rows_.Clear();
+  if (GetArenaForAllocation() == nullptr && _impl_.rows_ != nullptr) {
+    delete _impl_.rows_;
+  }
+  _impl_.rows_ = nullptr;
   _impl_.region_id_ = uint64_t{0u};
   _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
 }
@@ -2199,16 +2226,11 @@ const char* DeleteRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext*
         } else
           goto handle_unusual;
         continue;
-      // repeated .greptime.v1.Row rows = 2;
+      // .greptime.v1.Rows rows = 2;
       case 2:
         if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
-          ptr -= 1;
-          do {
-            ptr += 1;
-            ptr = ctx->ParseMessage(_internal_add_rows(), ptr);
-            CHK_(ptr);
-            if (!ctx->DataAvailable(ptr)) break;
-          } while (::PROTOBUF_NAMESPACE_ID::internal::ExpectTag<18>(ptr));
+          ptr = ctx->ParseMessage(_internal_mutable_rows(), ptr);
+          CHK_(ptr);
         } else
           goto handle_unusual;
         continue;
@@ -2247,12 +2269,11 @@ uint8_t* DeleteRequest::_InternalSerialize(
     target = ::_pbi::WireFormatLite::WriteUInt64ToArray(1, this->_internal_region_id(), target);
   }
 
-  // repeated .greptime.v1.Row rows = 2;
-  for (unsigned i = 0,
-      n = static_cast<unsigned>(this->_internal_rows_size()); i < n; i++) {
-    const auto& repfield = this->_internal_rows(i);
+  // .greptime.v1.Rows rows = 2;
+  if (this->_internal_has_rows()) {
     target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
-        InternalWriteMessage(2, repfield, repfield.GetCachedSize(), target, stream);
+      InternalWriteMessage(2, _Internal::rows(this),
+        _Internal::rows(this).GetCachedSize(), target, stream);
   }
 
   if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
@@ -2271,11 +2292,11 @@ size_t DeleteRequest::ByteSizeLong() const {
   // Prevent compiler warnings about cached_has_bits being unused
   (void) cached_has_bits;
 
-  // repeated .greptime.v1.Row rows = 2;
-  total_size += 1UL * this->_internal_rows_size();
-  for (const auto& msg : this->_impl_.rows_) {
-    total_size +=
-      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(msg);
+  // .greptime.v1.Rows rows = 2;
+  if (this->_internal_has_rows()) {
+    total_size += 1 +
+      ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize(
+        *_impl_.rows_);
   }
 
   // uint64 region_id = 1;
@@ -2301,7 +2322,10 @@ void DeleteRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::
   uint32_t cached_has_bits = 0;
   (void) cached_has_bits;
 
-  _this->_impl_.rows_.MergeFrom(from._impl_.rows_);
+  if (from._internal_has_rows()) {
+    _this->_internal_mutable_rows()->::greptime::v1::Rows::MergeFrom(
+        from._internal_rows());
+  }
   if (from._internal_region_id() != 0) {
     _this->_internal_set_region_id(from._internal_region_id());
   }
@@ -2322,8 +2346,12 @@ bool DeleteRequest::IsInitialized() const {
 void DeleteRequest::InternalSwap(DeleteRequest* other) {
   using std::swap;
   _internal_metadata_.InternalSwap(&other->_internal_metadata_);
-  _impl_.rows_.InternalSwap(&other->_impl_.rows_);
-  swap(_impl_.region_id_, other->_impl_.region_id_);
+  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
+      PROTOBUF_FIELD_OFFSET(DeleteRequest, _impl_.region_id_)
+      + sizeof(DeleteRequest::_impl_.region_id_)
+      - PROTOBUF_FIELD_OFFSET(DeleteRequest, _impl_.rows_)>(
+          reinterpret_cast<char*>(&_impl_.rows_),
+          reinterpret_cast<char*>(&other->_impl_.rows_));
 }
 
 ::PROTOBUF_NAMESPACE_ID::Metadata DeleteRequest::GetMetadata() const {
diff --git a/c++/greptime/v1/region/server.pb.h b/c++/greptime/v1/region/server.pb.h
index 2d89b2be..553d2328 100644
--- a/c++/greptime/v1/region/server.pb.h
+++ b/c++/greptime/v1/region/server.pb.h
@@ -1107,23 +1107,23 @@ class InsertRequest final :
     kRowsFieldNumber = 2,
     kRegionIdFieldNumber = 1,
   };
-  // repeated .greptime.v1.Row rows = 2;
-  int rows_size() const;
+  // .greptime.v1.Rows rows = 2;
+  bool has_rows() const;
   private:
-  int _internal_rows_size() const;
+  bool _internal_has_rows() const;
   public:
   void clear_rows();
-  ::greptime::v1::Row* mutable_rows(int index);
-  ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
-      mutable_rows();
+  const ::greptime::v1::Rows& rows() const;
+  PROTOBUF_NODISCARD ::greptime::v1::Rows* release_rows();
+  ::greptime::v1::Rows* mutable_rows();
+  void set_allocated_rows(::greptime::v1::Rows* rows);
   private:
-  const ::greptime::v1::Row& _internal_rows(int index) const;
-  ::greptime::v1::Row* _internal_add_rows();
+  const ::greptime::v1::Rows& _internal_rows() const;
+  ::greptime::v1::Rows* _internal_mutable_rows();
   public:
-  const ::greptime::v1::Row& rows(int index) const;
-  ::greptime::v1::Row* add_rows();
-  const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
-      rows() const;
+  void unsafe_arena_set_allocated_rows(
+      ::greptime::v1::Rows* rows);
+  ::greptime::v1::Rows* unsafe_arena_release_rows();
 
   // uint64 region_id = 1;
   void clear_region_id();
@@ -1142,7 +1142,7 @@ class InsertRequest final :
   typedef void InternalArenaConstructable_;
   typedef void DestructorSkippable_;
   struct Impl_ {
-    ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row > rows_;
+    ::greptime::v1::Rows* rows_;
     uint64_t region_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
@@ -1275,23 +1275,23 @@ class DeleteRequest final :
     kRowsFieldNumber = 2,
     kRegionIdFieldNumber = 1,
   };
-  // repeated .greptime.v1.Row rows = 2;
-  int rows_size() const;
+  // .greptime.v1.Rows rows = 2;
+  bool has_rows() const;
   private:
-  int _internal_rows_size() const;
+  bool _internal_has_rows() const;
   public:
   void clear_rows();
-  ::greptime::v1::Row* mutable_rows(int index);
-  ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
-      mutable_rows();
+  const ::greptime::v1::Rows& rows() const;
+  PROTOBUF_NODISCARD ::greptime::v1::Rows* release_rows();
+  ::greptime::v1::Rows* mutable_rows();
+  void set_allocated_rows(::greptime::v1::Rows* rows);
   private:
-  const ::greptime::v1::Row& _internal_rows(int index) const;
-  ::greptime::v1::Row* _internal_add_rows();
+  const ::greptime::v1::Rows& _internal_rows() const;
+  ::greptime::v1::Rows* _internal_mutable_rows();
   public:
-  const ::greptime::v1::Row& rows(int index) const;
-  ::greptime::v1::Row* add_rows();
-  const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
-      rows() const;
+  void unsafe_arena_set_allocated_rows(
+      ::greptime::v1::Rows* rows);
+  ::greptime::v1::Rows* unsafe_arena_release_rows();
 
   // uint64 region_id = 1;
   void clear_region_id();
@@ -1310,7 +1310,7 @@ class DeleteRequest final :
   typedef void InternalArenaConstructable_;
   typedef void DestructorSkippable_;
   struct Impl_ {
-    ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row > rows_;
+    ::greptime::v1::Rows* rows_;
     uint64_t region_id_;
     mutable ::PROTOBUF_NAMESPACE_ID::internal::CachedSize _cached_size_;
   };
@@ -3950,42 +3950,90 @@ inline void InsertRequest::set_region_id(uint64_t value) {
   // @@protoc_insertion_point(field_set:greptime.v1.region.InsertRequest.region_id)
 }
 
-// repeated .greptime.v1.Row rows = 2;
-inline int InsertRequest::_internal_rows_size() const {
-  return _impl_.rows_.size();
+// .greptime.v1.Rows rows = 2;
+inline bool InsertRequest::_internal_has_rows() const {
+  return this != internal_default_instance() && _impl_.rows_ != nullptr;
 }
-inline int InsertRequest::rows_size() const {
-  return _internal_rows_size();
+inline bool InsertRequest::has_rows() const {
+  return _internal_has_rows();
 }
-inline ::greptime::v1::Row* InsertRequest::mutable_rows(int index) {
-  // @@protoc_insertion_point(field_mutable:greptime.v1.region.InsertRequest.rows)
-  return _impl_.rows_.Mutable(index);
-}
-inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
-InsertRequest::mutable_rows() {
-  // @@protoc_insertion_point(field_mutable_list:greptime.v1.region.InsertRequest.rows)
-  return &_impl_.rows_;
-}
-inline const ::greptime::v1::Row& InsertRequest::_internal_rows(int index) const {
-  return _impl_.rows_.Get(index);
+inline const ::greptime::v1::Rows& InsertRequest::_internal_rows() const {
+  const ::greptime::v1::Rows* p = _impl_.rows_;
+  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::Rows&>(
+      ::greptime::v1::_Rows_default_instance_);
 }
-inline const ::greptime::v1::Row& InsertRequest::rows(int index) const {
+inline const ::greptime::v1::Rows& InsertRequest::rows() const {
   // @@protoc_insertion_point(field_get:greptime.v1.region.InsertRequest.rows)
-  return _internal_rows(index);
+  return _internal_rows();
 }
-inline ::greptime::v1::Row* InsertRequest::_internal_add_rows() {
-  return _impl_.rows_.Add();
+inline void InsertRequest::unsafe_arena_set_allocated_rows(
+    ::greptime::v1::Rows* rows) {
+  if (GetArenaForAllocation() == nullptr) {
+    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  _impl_.rows_ = rows;
+  if (rows) {
+    
+  } else {
+    
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.InsertRequest.rows)
 }
-inline ::greptime::v1::Row* InsertRequest::add_rows() {
-  ::greptime::v1::Row* _add = _internal_add_rows();
-  // @@protoc_insertion_point(field_add:greptime.v1.region.InsertRequest.rows)
-  return _add;
+inline ::greptime::v1::Rows* InsertRequest::release_rows() {
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = 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 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
-InsertRequest::rows() const {
-  // @@protoc_insertion_point(field_list:greptime.v1.region.InsertRequest.rows)
+inline ::greptime::v1::Rows* InsertRequest::unsafe_arena_release_rows() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.InsertRequest.rows)
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = nullptr;
+  return temp;
+}
+inline ::greptime::v1::Rows* InsertRequest::_internal_mutable_rows() {
+  
+  if (_impl_.rows_ == nullptr) {
+    auto* p = CreateMaybeMessage<::greptime::v1::Rows>(GetArenaForAllocation());
+    _impl_.rows_ = p;
+  }
   return _impl_.rows_;
 }
+inline ::greptime::v1::Rows* InsertRequest::mutable_rows() {
+  ::greptime::v1::Rows* _msg = _internal_mutable_rows();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.InsertRequest.rows)
+  return _msg;
+}
+inline void InsertRequest::set_allocated_rows(::greptime::v1::Rows* rows) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  if (message_arena == nullptr) {
+    delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  if (rows) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
+                reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rows));
+    if (message_arena != submessage_arena) {
+      rows = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, rows, submessage_arena);
+    }
+    
+  } else {
+    
+  }
+  _impl_.rows_ = rows;
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.InsertRequest.rows)
+}
 
 // -------------------------------------------------------------------
 
@@ -4011,42 +4059,90 @@ inline void DeleteRequest::set_region_id(uint64_t value) {
   // @@protoc_insertion_point(field_set:greptime.v1.region.DeleteRequest.region_id)
 }
 
-// repeated .greptime.v1.Row rows = 2;
-inline int DeleteRequest::_internal_rows_size() const {
-  return _impl_.rows_.size();
+// .greptime.v1.Rows rows = 2;
+inline bool DeleteRequest::_internal_has_rows() const {
+  return this != internal_default_instance() && _impl_.rows_ != nullptr;
 }
-inline int DeleteRequest::rows_size() const {
-  return _internal_rows_size();
+inline bool DeleteRequest::has_rows() const {
+  return _internal_has_rows();
 }
-inline ::greptime::v1::Row* DeleteRequest::mutable_rows(int index) {
-  // @@protoc_insertion_point(field_mutable:greptime.v1.region.DeleteRequest.rows)
-  return _impl_.rows_.Mutable(index);
-}
-inline ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >*
-DeleteRequest::mutable_rows() {
-  // @@protoc_insertion_point(field_mutable_list:greptime.v1.region.DeleteRequest.rows)
-  return &_impl_.rows_;
-}
-inline const ::greptime::v1::Row& DeleteRequest::_internal_rows(int index) const {
-  return _impl_.rows_.Get(index);
+inline const ::greptime::v1::Rows& DeleteRequest::_internal_rows() const {
+  const ::greptime::v1::Rows* p = _impl_.rows_;
+  return p != nullptr ? *p : reinterpret_cast<const ::greptime::v1::Rows&>(
+      ::greptime::v1::_Rows_default_instance_);
 }
-inline const ::greptime::v1::Row& DeleteRequest::rows(int index) const {
+inline const ::greptime::v1::Rows& DeleteRequest::rows() const {
   // @@protoc_insertion_point(field_get:greptime.v1.region.DeleteRequest.rows)
-  return _internal_rows(index);
+  return _internal_rows();
 }
-inline ::greptime::v1::Row* DeleteRequest::_internal_add_rows() {
-  return _impl_.rows_.Add();
+inline void DeleteRequest::unsafe_arena_set_allocated_rows(
+    ::greptime::v1::Rows* rows) {
+  if (GetArenaForAllocation() == nullptr) {
+    delete reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  _impl_.rows_ = rows;
+  if (rows) {
+    
+  } else {
+    
+  }
+  // @@protoc_insertion_point(field_unsafe_arena_set_allocated:greptime.v1.region.DeleteRequest.rows)
 }
-inline ::greptime::v1::Row* DeleteRequest::add_rows() {
-  ::greptime::v1::Row* _add = _internal_add_rows();
-  // @@protoc_insertion_point(field_add:greptime.v1.region.DeleteRequest.rows)
-  return _add;
+inline ::greptime::v1::Rows* DeleteRequest::release_rows() {
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = 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 const ::PROTOBUF_NAMESPACE_ID::RepeatedPtrField< ::greptime::v1::Row >&
-DeleteRequest::rows() const {
-  // @@protoc_insertion_point(field_list:greptime.v1.region.DeleteRequest.rows)
+inline ::greptime::v1::Rows* DeleteRequest::unsafe_arena_release_rows() {
+  // @@protoc_insertion_point(field_release:greptime.v1.region.DeleteRequest.rows)
+  
+  ::greptime::v1::Rows* temp = _impl_.rows_;
+  _impl_.rows_ = nullptr;
+  return temp;
+}
+inline ::greptime::v1::Rows* DeleteRequest::_internal_mutable_rows() {
+  
+  if (_impl_.rows_ == nullptr) {
+    auto* p = CreateMaybeMessage<::greptime::v1::Rows>(GetArenaForAllocation());
+    _impl_.rows_ = p;
+  }
   return _impl_.rows_;
 }
+inline ::greptime::v1::Rows* DeleteRequest::mutable_rows() {
+  ::greptime::v1::Rows* _msg = _internal_mutable_rows();
+  // @@protoc_insertion_point(field_mutable:greptime.v1.region.DeleteRequest.rows)
+  return _msg;
+}
+inline void DeleteRequest::set_allocated_rows(::greptime::v1::Rows* rows) {
+  ::PROTOBUF_NAMESPACE_ID::Arena* message_arena = GetArenaForAllocation();
+  if (message_arena == nullptr) {
+    delete reinterpret_cast< ::PROTOBUF_NAMESPACE_ID::MessageLite*>(_impl_.rows_);
+  }
+  if (rows) {
+    ::PROTOBUF_NAMESPACE_ID::Arena* submessage_arena =
+        ::PROTOBUF_NAMESPACE_ID::Arena::InternalGetOwningArena(
+                reinterpret_cast<::PROTOBUF_NAMESPACE_ID::MessageLite*>(rows));
+    if (message_arena != submessage_arena) {
+      rows = ::PROTOBUF_NAMESPACE_ID::internal::GetOwnedMessage(
+          message_arena, rows, submessage_arena);
+    }
+    
+  } else {
+    
+  }
+  _impl_.rows_ = rows;
+  // @@protoc_insertion_point(field_set_allocated:greptime.v1.region.DeleteRequest.rows)
+}
 
 // -------------------------------------------------------------------
 
diff --git a/java/src/main/java/io/greptime/v1/region/Server.java b/java/src/main/java/io/greptime/v1/region/Server.java
index 4468e94c..8e5f5dad 100644
--- a/java/src/main/java/io/greptime/v1/region/Server.java
+++ b/java/src/main/java/io/greptime/v1/region/Server.java
@@ -5073,28 +5073,19 @@ public interface InsertRequestOrBuilder extends
     long getRegionId();
 
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return Whether the rows field is set.
      */
-    java.util.List<io.greptime.v1.RowData.Row> 
-        getRowsList();
+    boolean hasRows();
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return The rows.
      */
-    io.greptime.v1.RowData.Row getRows(int index);
+    io.greptime.v1.RowData.Rows getRows();
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
      */
-    int getRowsCount();
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-        getRowsOrBuilderList();
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-        int index);
+    io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder();
   }
   /**
    * Protobuf type {@code greptime.v1.region.InsertRequest}
@@ -5109,7 +5100,6 @@ private InsertRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)
       super(builder);
     }
     private InsertRequest() {
-      rows_ = java.util.Collections.emptyList();
     }
 
     @java.lang.Override
@@ -5132,7 +5122,6 @@ private InsertRequest(
       if (extensionRegistry == null) {
         throw new java.lang.NullPointerException();
       }
-      int mutable_bitField0_ = 0;
       com.google.protobuf.UnknownFieldSet.Builder unknownFields =
           com.google.protobuf.UnknownFieldSet.newBuilder();
       try {
@@ -5149,12 +5138,16 @@ private InsertRequest(
               break;
             }
             case 18: {
-              if (!((mutable_bitField0_ & 0x00000001) != 0)) {
-                rows_ = new java.util.ArrayList<io.greptime.v1.RowData.Row>();
-                mutable_bitField0_ |= 0x00000001;
+              io.greptime.v1.RowData.Rows.Builder subBuilder = null;
+              if (rows_ != null) {
+                subBuilder = rows_.toBuilder();
               }
-              rows_.add(
-                  input.readMessage(io.greptime.v1.RowData.Row.parser(), extensionRegistry));
+              rows_ = input.readMessage(io.greptime.v1.RowData.Rows.parser(), extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(rows_);
+                rows_ = subBuilder.buildPartial();
+              }
+
               break;
             }
             default: {
@@ -5174,9 +5167,6 @@ private InsertRequest(
         throw new com.google.protobuf.InvalidProtocolBufferException(
             e).setUnfinishedMessage(this);
       } finally {
-        if (((mutable_bitField0_ & 0x00000001) != 0)) {
-          rows_ = java.util.Collections.unmodifiableList(rows_);
-        }
         this.unknownFields = unknownFields.build();
         makeExtensionsImmutable();
       }
@@ -5206,43 +5196,29 @@ public long getRegionId() {
     }
 
     public static final int ROWS_FIELD_NUMBER = 2;
-    private java.util.List<io.greptime.v1.RowData.Row> rows_;
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    @java.lang.Override
-    public java.util.List<io.greptime.v1.RowData.Row> getRowsList() {
-      return rows_;
-    }
+    private io.greptime.v1.RowData.Rows rows_;
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return Whether the rows field is set.
      */
     @java.lang.Override
-    public java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-        getRowsOrBuilderList() {
-      return rows_;
+    public boolean hasRows() {
+      return rows_ != null;
     }
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return The rows.
      */
     @java.lang.Override
-    public int getRowsCount() {
-      return rows_.size();
+    public io.greptime.v1.RowData.Rows getRows() {
+      return rows_ == null ? io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
     }
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
      */
     @java.lang.Override
-    public io.greptime.v1.RowData.Row getRows(int index) {
-      return rows_.get(index);
-    }
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    @java.lang.Override
-    public io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-        int index) {
-      return rows_.get(index);
+    public io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder() {
+      return getRows();
     }
 
     private byte memoizedIsInitialized = -1;
@@ -5262,8 +5238,8 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (regionId_ != 0L) {
         output.writeUInt64(1, regionId_);
       }
-      for (int i = 0; i < rows_.size(); i++) {
-        output.writeMessage(2, rows_.get(i));
+      if (rows_ != null) {
+        output.writeMessage(2, getRows());
       }
       unknownFields.writeTo(output);
     }
@@ -5278,9 +5254,9 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeUInt64Size(1, regionId_);
       }
-      for (int i = 0; i < rows_.size(); i++) {
+      if (rows_ != null) {
         size += com.google.protobuf.CodedOutputStream
-          .computeMessageSize(2, rows_.get(i));
+          .computeMessageSize(2, getRows());
       }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
@@ -5299,8 +5275,11 @@ public boolean equals(final java.lang.Object obj) {
 
       if (getRegionId()
           != other.getRegionId()) return false;
-      if (!getRowsList()
-          .equals(other.getRowsList())) return false;
+      if (hasRows() != other.hasRows()) return false;
+      if (hasRows()) {
+        if (!getRows()
+            .equals(other.getRows())) return false;
+      }
       if (!unknownFields.equals(other.unknownFields)) return false;
       return true;
     }
@@ -5315,9 +5294,9 @@ public int hashCode() {
       hash = (37 * hash) + REGION_ID_FIELD_NUMBER;
       hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
           getRegionId());
-      if (getRowsCount() > 0) {
+      if (hasRows()) {
         hash = (37 * hash) + ROWS_FIELD_NUMBER;
-        hash = (53 * hash) + getRowsList().hashCode();
+        hash = (53 * hash) + getRows().hashCode();
       }
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
@@ -5447,7 +5426,6 @@ private Builder(
       private void maybeForceBuilderInitialization() {
         if (com.google.protobuf.GeneratedMessageV3
                 .alwaysUseFieldBuilders) {
-          getRowsFieldBuilder();
         }
       }
       @java.lang.Override
@@ -5456,10 +5434,10 @@ public Builder clear() {
         regionId_ = 0L;
 
         if (rowsBuilder_ == null) {
-          rows_ = java.util.Collections.emptyList();
-          bitField0_ = (bitField0_ & ~0x00000001);
+          rows_ = null;
         } else {
-          rowsBuilder_.clear();
+          rows_ = null;
+          rowsBuilder_ = null;
         }
         return this;
       }
@@ -5487,13 +5465,8 @@ public io.greptime.v1.region.Server.InsertRequest build() {
       @java.lang.Override
       public io.greptime.v1.region.Server.InsertRequest buildPartial() {
         io.greptime.v1.region.Server.InsertRequest result = new io.greptime.v1.region.Server.InsertRequest(this);
-        int from_bitField0_ = bitField0_;
         result.regionId_ = regionId_;
         if (rowsBuilder_ == null) {
-          if (((bitField0_ & 0x00000001) != 0)) {
-            rows_ = java.util.Collections.unmodifiableList(rows_);
-            bitField0_ = (bitField0_ & ~0x00000001);
-          }
           result.rows_ = rows_;
         } else {
           result.rows_ = rowsBuilder_.build();
@@ -5549,31 +5522,8 @@ public Builder mergeFrom(io.greptime.v1.region.Server.InsertRequest other) {
         if (other.getRegionId() != 0L) {
           setRegionId(other.getRegionId());
         }
-        if (rowsBuilder_ == null) {
-          if (!other.rows_.isEmpty()) {
-            if (rows_.isEmpty()) {
-              rows_ = other.rows_;
-              bitField0_ = (bitField0_ & ~0x00000001);
-            } else {
-              ensureRowsIsMutable();
-              rows_.addAll(other.rows_);
-            }
-            onChanged();
-          }
-        } else {
-          if (!other.rows_.isEmpty()) {
-            if (rowsBuilder_.isEmpty()) {
-              rowsBuilder_.dispose();
-              rowsBuilder_ = null;
-              rows_ = other.rows_;
-              bitField0_ = (bitField0_ & ~0x00000001);
-              rowsBuilder_ = 
-                com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
-                   getRowsFieldBuilder() : null;
-            } else {
-              rowsBuilder_.addAllMessages(other.rows_);
-            }
-          }
+        if (other.hasRows()) {
+          mergeRows(other.getRows());
         }
         this.mergeUnknownFields(other.unknownFields);
         onChanged();
@@ -5603,7 +5553,6 @@ public Builder mergeFrom(
         }
         return this;
       }
-      private int bitField0_;
 
       private long regionId_ ;
       /**
@@ -5636,239 +5585,118 @@ public Builder clearRegionId() {
         return this;
       }
 
-      private java.util.List<io.greptime.v1.RowData.Row> rows_ =
-        java.util.Collections.emptyList();
-      private void ensureRowsIsMutable() {
-        if (!((bitField0_ & 0x00000001) != 0)) {
-          rows_ = new java.util.ArrayList<io.greptime.v1.RowData.Row>(rows_);
-          bitField0_ |= 0x00000001;
-         }
-      }
-
-      private com.google.protobuf.RepeatedFieldBuilderV3<
-          io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder> rowsBuilder_;
-
+      private io.greptime.v1.RowData.Rows rows_;
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder> rowsBuilder_;
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
+       * @return Whether the rows field is set.
        */
-      public java.util.List<io.greptime.v1.RowData.Row> getRowsList() {
-        if (rowsBuilder_ == null) {
-          return java.util.Collections.unmodifiableList(rows_);
-        } else {
-          return rowsBuilder_.getMessageList();
-        }
+      public boolean hasRows() {
+        return rowsBuilder_ != null || rows_ != null;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
+       * @return The rows.
        */
-      public int getRowsCount() {
+      public io.greptime.v1.RowData.Rows getRows() {
         if (rowsBuilder_ == null) {
-          return rows_.size();
+          return rows_ == null ? io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
         } else {
-          return rowsBuilder_.getCount();
+          return rowsBuilder_.getMessage();
         }
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.Row getRows(int index) {
-        if (rowsBuilder_ == null) {
-          return rows_.get(index);
-        } else {
-          return rowsBuilder_.getMessage(index);
-        }
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder setRows(
-          int index, io.greptime.v1.RowData.Row value) {
+      public Builder setRows(io.greptime.v1.RowData.Rows value) {
         if (rowsBuilder_ == null) {
           if (value == null) {
             throw new NullPointerException();
           }
-          ensureRowsIsMutable();
-          rows_.set(index, value);
+          rows_ = value;
           onChanged();
         } else {
-          rowsBuilder_.setMessage(index, value);
+          rowsBuilder_.setMessage(value);
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
       public Builder setRows(
-          int index, io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.set(index, builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.setMessage(index, builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(io.greptime.v1.RowData.Row value) {
+          io.greptime.v1.RowData.Rows.Builder builderForValue) {
         if (rowsBuilder_ == null) {
-          if (value == null) {
-            throw new NullPointerException();
-          }
-          ensureRowsIsMutable();
-          rows_.add(value);
+          rows_ = builderForValue.build();
           onChanged();
         } else {
-          rowsBuilder_.addMessage(value);
+          rowsBuilder_.setMessage(builderForValue.build());
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public Builder addRows(
-          int index, io.greptime.v1.RowData.Row value) {
+      public Builder mergeRows(io.greptime.v1.RowData.Rows value) {
         if (rowsBuilder_ == null) {
-          if (value == null) {
-            throw new NullPointerException();
+          if (rows_ != null) {
+            rows_ =
+              io.greptime.v1.RowData.Rows.newBuilder(rows_).mergeFrom(value).buildPartial();
+          } else {
+            rows_ = value;
           }
-          ensureRowsIsMutable();
-          rows_.add(index, value);
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(index, value);
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(
-          io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.add(builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(
-          int index, io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.add(index, builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(index, builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addAllRows(
-          java.lang.Iterable<? extends io.greptime.v1.RowData.Row> values) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          com.google.protobuf.AbstractMessageLite.Builder.addAll(
-              values, rows_);
           onChanged();
         } else {
-          rowsBuilder_.addAllMessages(values);
+          rowsBuilder_.mergeFrom(value);
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
       public Builder clearRows() {
         if (rowsBuilder_ == null) {
-          rows_ = java.util.Collections.emptyList();
-          bitField0_ = (bitField0_ & ~0x00000001);
-          onChanged();
-        } else {
-          rowsBuilder_.clear();
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder removeRows(int index) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.remove(index);
+          rows_ = null;
           onChanged();
         } else {
-          rowsBuilder_.remove(index);
+          rows_ = null;
+          rowsBuilder_ = null;
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public io.greptime.v1.RowData.Row.Builder getRowsBuilder(
-          int index) {
-        return getRowsFieldBuilder().getBuilder(index);
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-          int index) {
-        if (rowsBuilder_ == null) {
-          return rows_.get(index);  } else {
-          return rowsBuilder_.getMessageOrBuilder(index);
-        }
+      public io.greptime.v1.RowData.Rows.Builder getRowsBuilder() {
+        
+        onChanged();
+        return getRowsFieldBuilder().getBuilder();
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-           getRowsOrBuilderList() {
+      public io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder() {
         if (rowsBuilder_ != null) {
-          return rowsBuilder_.getMessageOrBuilderList();
+          return rowsBuilder_.getMessageOrBuilder();
         } else {
-          return java.util.Collections.unmodifiableList(rows_);
+          return rows_ == null ?
+              io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
         }
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public io.greptime.v1.RowData.Row.Builder addRowsBuilder() {
-        return getRowsFieldBuilder().addBuilder(
-            io.greptime.v1.RowData.Row.getDefaultInstance());
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.Row.Builder addRowsBuilder(
-          int index) {
-        return getRowsFieldBuilder().addBuilder(
-            index, io.greptime.v1.RowData.Row.getDefaultInstance());
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public java.util.List<io.greptime.v1.RowData.Row.Builder> 
-           getRowsBuilderList() {
-        return getRowsFieldBuilder().getBuilderList();
-      }
-      private com.google.protobuf.RepeatedFieldBuilderV3<
-          io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder> 
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder> 
           getRowsFieldBuilder() {
         if (rowsBuilder_ == null) {
-          rowsBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
-              io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder>(
-                  rows_,
-                  ((bitField0_ & 0x00000001) != 0),
+          rowsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+              io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder>(
+                  getRows(),
                   getParentForChildren(),
                   isClean());
           rows_ = null;
@@ -5939,28 +5767,19 @@ public interface DeleteRequestOrBuilder extends
     long getRegionId();
 
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return Whether the rows field is set.
      */
-    java.util.List<io.greptime.v1.RowData.Row> 
-        getRowsList();
+    boolean hasRows();
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return The rows.
      */
-    io.greptime.v1.RowData.Row getRows(int index);
+    io.greptime.v1.RowData.Rows getRows();
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
      */
-    int getRowsCount();
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-        getRowsOrBuilderList();
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-        int index);
+    io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder();
   }
   /**
    * Protobuf type {@code greptime.v1.region.DeleteRequest}
@@ -5975,7 +5794,6 @@ private DeleteRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder)
       super(builder);
     }
     private DeleteRequest() {
-      rows_ = java.util.Collections.emptyList();
     }
 
     @java.lang.Override
@@ -5998,7 +5816,6 @@ private DeleteRequest(
       if (extensionRegistry == null) {
         throw new java.lang.NullPointerException();
       }
-      int mutable_bitField0_ = 0;
       com.google.protobuf.UnknownFieldSet.Builder unknownFields =
           com.google.protobuf.UnknownFieldSet.newBuilder();
       try {
@@ -6015,12 +5832,16 @@ private DeleteRequest(
               break;
             }
             case 18: {
-              if (!((mutable_bitField0_ & 0x00000001) != 0)) {
-                rows_ = new java.util.ArrayList<io.greptime.v1.RowData.Row>();
-                mutable_bitField0_ |= 0x00000001;
+              io.greptime.v1.RowData.Rows.Builder subBuilder = null;
+              if (rows_ != null) {
+                subBuilder = rows_.toBuilder();
               }
-              rows_.add(
-                  input.readMessage(io.greptime.v1.RowData.Row.parser(), extensionRegistry));
+              rows_ = input.readMessage(io.greptime.v1.RowData.Rows.parser(), extensionRegistry);
+              if (subBuilder != null) {
+                subBuilder.mergeFrom(rows_);
+                rows_ = subBuilder.buildPartial();
+              }
+
               break;
             }
             default: {
@@ -6040,9 +5861,6 @@ private DeleteRequest(
         throw new com.google.protobuf.InvalidProtocolBufferException(
             e).setUnfinishedMessage(this);
       } finally {
-        if (((mutable_bitField0_ & 0x00000001) != 0)) {
-          rows_ = java.util.Collections.unmodifiableList(rows_);
-        }
         this.unknownFields = unknownFields.build();
         makeExtensionsImmutable();
       }
@@ -6072,43 +5890,29 @@ public long getRegionId() {
     }
 
     public static final int ROWS_FIELD_NUMBER = 2;
-    private java.util.List<io.greptime.v1.RowData.Row> rows_;
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    @java.lang.Override
-    public java.util.List<io.greptime.v1.RowData.Row> getRowsList() {
-      return rows_;
-    }
+    private io.greptime.v1.RowData.Rows rows_;
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return Whether the rows field is set.
      */
     @java.lang.Override
-    public java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-        getRowsOrBuilderList() {
-      return rows_;
+    public boolean hasRows() {
+      return rows_ != null;
     }
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
+     * @return The rows.
      */
     @java.lang.Override
-    public int getRowsCount() {
-      return rows_.size();
+    public io.greptime.v1.RowData.Rows getRows() {
+      return rows_ == null ? io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
     }
     /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
+     * <code>.greptime.v1.Rows rows = 2;</code>
      */
     @java.lang.Override
-    public io.greptime.v1.RowData.Row getRows(int index) {
-      return rows_.get(index);
-    }
-    /**
-     * <code>repeated .greptime.v1.Row rows = 2;</code>
-     */
-    @java.lang.Override
-    public io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-        int index) {
-      return rows_.get(index);
+    public io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder() {
+      return getRows();
     }
 
     private byte memoizedIsInitialized = -1;
@@ -6128,8 +5932,8 @@ public void writeTo(com.google.protobuf.CodedOutputStream output)
       if (regionId_ != 0L) {
         output.writeUInt64(1, regionId_);
       }
-      for (int i = 0; i < rows_.size(); i++) {
-        output.writeMessage(2, rows_.get(i));
+      if (rows_ != null) {
+        output.writeMessage(2, getRows());
       }
       unknownFields.writeTo(output);
     }
@@ -6144,9 +5948,9 @@ public int getSerializedSize() {
         size += com.google.protobuf.CodedOutputStream
           .computeUInt64Size(1, regionId_);
       }
-      for (int i = 0; i < rows_.size(); i++) {
+      if (rows_ != null) {
         size += com.google.protobuf.CodedOutputStream
-          .computeMessageSize(2, rows_.get(i));
+          .computeMessageSize(2, getRows());
       }
       size += unknownFields.getSerializedSize();
       memoizedSize = size;
@@ -6165,8 +5969,11 @@ public boolean equals(final java.lang.Object obj) {
 
       if (getRegionId()
           != other.getRegionId()) return false;
-      if (!getRowsList()
-          .equals(other.getRowsList())) return false;
+      if (hasRows() != other.hasRows()) return false;
+      if (hasRows()) {
+        if (!getRows()
+            .equals(other.getRows())) return false;
+      }
       if (!unknownFields.equals(other.unknownFields)) return false;
       return true;
     }
@@ -6181,9 +5988,9 @@ public int hashCode() {
       hash = (37 * hash) + REGION_ID_FIELD_NUMBER;
       hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
           getRegionId());
-      if (getRowsCount() > 0) {
+      if (hasRows()) {
         hash = (37 * hash) + ROWS_FIELD_NUMBER;
-        hash = (53 * hash) + getRowsList().hashCode();
+        hash = (53 * hash) + getRows().hashCode();
       }
       hash = (29 * hash) + unknownFields.hashCode();
       memoizedHashCode = hash;
@@ -6313,7 +6120,6 @@ private Builder(
       private void maybeForceBuilderInitialization() {
         if (com.google.protobuf.GeneratedMessageV3
                 .alwaysUseFieldBuilders) {
-          getRowsFieldBuilder();
         }
       }
       @java.lang.Override
@@ -6322,10 +6128,10 @@ public Builder clear() {
         regionId_ = 0L;
 
         if (rowsBuilder_ == null) {
-          rows_ = java.util.Collections.emptyList();
-          bitField0_ = (bitField0_ & ~0x00000001);
+          rows_ = null;
         } else {
-          rowsBuilder_.clear();
+          rows_ = null;
+          rowsBuilder_ = null;
         }
         return this;
       }
@@ -6353,13 +6159,8 @@ public io.greptime.v1.region.Server.DeleteRequest build() {
       @java.lang.Override
       public io.greptime.v1.region.Server.DeleteRequest buildPartial() {
         io.greptime.v1.region.Server.DeleteRequest result = new io.greptime.v1.region.Server.DeleteRequest(this);
-        int from_bitField0_ = bitField0_;
         result.regionId_ = regionId_;
         if (rowsBuilder_ == null) {
-          if (((bitField0_ & 0x00000001) != 0)) {
-            rows_ = java.util.Collections.unmodifiableList(rows_);
-            bitField0_ = (bitField0_ & ~0x00000001);
-          }
           result.rows_ = rows_;
         } else {
           result.rows_ = rowsBuilder_.build();
@@ -6415,31 +6216,8 @@ public Builder mergeFrom(io.greptime.v1.region.Server.DeleteRequest other) {
         if (other.getRegionId() != 0L) {
           setRegionId(other.getRegionId());
         }
-        if (rowsBuilder_ == null) {
-          if (!other.rows_.isEmpty()) {
-            if (rows_.isEmpty()) {
-              rows_ = other.rows_;
-              bitField0_ = (bitField0_ & ~0x00000001);
-            } else {
-              ensureRowsIsMutable();
-              rows_.addAll(other.rows_);
-            }
-            onChanged();
-          }
-        } else {
-          if (!other.rows_.isEmpty()) {
-            if (rowsBuilder_.isEmpty()) {
-              rowsBuilder_.dispose();
-              rowsBuilder_ = null;
-              rows_ = other.rows_;
-              bitField0_ = (bitField0_ & ~0x00000001);
-              rowsBuilder_ = 
-                com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
-                   getRowsFieldBuilder() : null;
-            } else {
-              rowsBuilder_.addAllMessages(other.rows_);
-            }
-          }
+        if (other.hasRows()) {
+          mergeRows(other.getRows());
         }
         this.mergeUnknownFields(other.unknownFields);
         onChanged();
@@ -6469,7 +6247,6 @@ public Builder mergeFrom(
         }
         return this;
       }
-      private int bitField0_;
 
       private long regionId_ ;
       /**
@@ -6502,239 +6279,118 @@ public Builder clearRegionId() {
         return this;
       }
 
-      private java.util.List<io.greptime.v1.RowData.Row> rows_ =
-        java.util.Collections.emptyList();
-      private void ensureRowsIsMutable() {
-        if (!((bitField0_ & 0x00000001) != 0)) {
-          rows_ = new java.util.ArrayList<io.greptime.v1.RowData.Row>(rows_);
-          bitField0_ |= 0x00000001;
-         }
-      }
-
-      private com.google.protobuf.RepeatedFieldBuilderV3<
-          io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder> rowsBuilder_;
-
+      private io.greptime.v1.RowData.Rows rows_;
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder> rowsBuilder_;
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
+       * @return Whether the rows field is set.
        */
-      public java.util.List<io.greptime.v1.RowData.Row> getRowsList() {
-        if (rowsBuilder_ == null) {
-          return java.util.Collections.unmodifiableList(rows_);
-        } else {
-          return rowsBuilder_.getMessageList();
-        }
+      public boolean hasRows() {
+        return rowsBuilder_ != null || rows_ != null;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
+       * @return The rows.
        */
-      public int getRowsCount() {
+      public io.greptime.v1.RowData.Rows getRows() {
         if (rowsBuilder_ == null) {
-          return rows_.size();
+          return rows_ == null ? io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
         } else {
-          return rowsBuilder_.getCount();
+          return rowsBuilder_.getMessage();
         }
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.Row getRows(int index) {
-        if (rowsBuilder_ == null) {
-          return rows_.get(index);
-        } else {
-          return rowsBuilder_.getMessage(index);
-        }
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder setRows(
-          int index, io.greptime.v1.RowData.Row value) {
+      public Builder setRows(io.greptime.v1.RowData.Rows value) {
         if (rowsBuilder_ == null) {
           if (value == null) {
             throw new NullPointerException();
           }
-          ensureRowsIsMutable();
-          rows_.set(index, value);
+          rows_ = value;
           onChanged();
         } else {
-          rowsBuilder_.setMessage(index, value);
+          rowsBuilder_.setMessage(value);
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
       public Builder setRows(
-          int index, io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.set(index, builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.setMessage(index, builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(io.greptime.v1.RowData.Row value) {
+          io.greptime.v1.RowData.Rows.Builder builderForValue) {
         if (rowsBuilder_ == null) {
-          if (value == null) {
-            throw new NullPointerException();
-          }
-          ensureRowsIsMutable();
-          rows_.add(value);
+          rows_ = builderForValue.build();
           onChanged();
         } else {
-          rowsBuilder_.addMessage(value);
+          rowsBuilder_.setMessage(builderForValue.build());
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public Builder addRows(
-          int index, io.greptime.v1.RowData.Row value) {
+      public Builder mergeRows(io.greptime.v1.RowData.Rows value) {
         if (rowsBuilder_ == null) {
-          if (value == null) {
-            throw new NullPointerException();
+          if (rows_ != null) {
+            rows_ =
+              io.greptime.v1.RowData.Rows.newBuilder(rows_).mergeFrom(value).buildPartial();
+          } else {
+            rows_ = value;
           }
-          ensureRowsIsMutable();
-          rows_.add(index, value);
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(index, value);
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(
-          io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.add(builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addRows(
-          int index, io.greptime.v1.RowData.Row.Builder builderForValue) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.add(index, builderForValue.build());
-          onChanged();
-        } else {
-          rowsBuilder_.addMessage(index, builderForValue.build());
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder addAllRows(
-          java.lang.Iterable<? extends io.greptime.v1.RowData.Row> values) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          com.google.protobuf.AbstractMessageLite.Builder.addAll(
-              values, rows_);
           onChanged();
         } else {
-          rowsBuilder_.addAllMessages(values);
+          rowsBuilder_.mergeFrom(value);
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
       public Builder clearRows() {
         if (rowsBuilder_ == null) {
-          rows_ = java.util.Collections.emptyList();
-          bitField0_ = (bitField0_ & ~0x00000001);
-          onChanged();
-        } else {
-          rowsBuilder_.clear();
-        }
-        return this;
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public Builder removeRows(int index) {
-        if (rowsBuilder_ == null) {
-          ensureRowsIsMutable();
-          rows_.remove(index);
+          rows_ = null;
           onChanged();
         } else {
-          rowsBuilder_.remove(index);
+          rows_ = null;
+          rowsBuilder_ = null;
         }
+
         return this;
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public io.greptime.v1.RowData.Row.Builder getRowsBuilder(
-          int index) {
-        return getRowsFieldBuilder().getBuilder(index);
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.RowOrBuilder getRowsOrBuilder(
-          int index) {
-        if (rowsBuilder_ == null) {
-          return rows_.get(index);  } else {
-          return rowsBuilder_.getMessageOrBuilder(index);
-        }
+      public io.greptime.v1.RowData.Rows.Builder getRowsBuilder() {
+        
+        onChanged();
+        return getRowsFieldBuilder().getBuilder();
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public java.util.List<? extends io.greptime.v1.RowData.RowOrBuilder> 
-           getRowsOrBuilderList() {
+      public io.greptime.v1.RowData.RowsOrBuilder getRowsOrBuilder() {
         if (rowsBuilder_ != null) {
-          return rowsBuilder_.getMessageOrBuilderList();
+          return rowsBuilder_.getMessageOrBuilder();
         } else {
-          return java.util.Collections.unmodifiableList(rows_);
+          return rows_ == null ?
+              io.greptime.v1.RowData.Rows.getDefaultInstance() : rows_;
         }
       }
       /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public io.greptime.v1.RowData.Row.Builder addRowsBuilder() {
-        return getRowsFieldBuilder().addBuilder(
-            io.greptime.v1.RowData.Row.getDefaultInstance());
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
+       * <code>.greptime.v1.Rows rows = 2;</code>
        */
-      public io.greptime.v1.RowData.Row.Builder addRowsBuilder(
-          int index) {
-        return getRowsFieldBuilder().addBuilder(
-            index, io.greptime.v1.RowData.Row.getDefaultInstance());
-      }
-      /**
-       * <code>repeated .greptime.v1.Row rows = 2;</code>
-       */
-      public java.util.List<io.greptime.v1.RowData.Row.Builder> 
-           getRowsBuilderList() {
-        return getRowsFieldBuilder().getBuilderList();
-      }
-      private com.google.protobuf.RepeatedFieldBuilderV3<
-          io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder> 
+      private com.google.protobuf.SingleFieldBuilderV3<
+          io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder> 
           getRowsFieldBuilder() {
         if (rowsBuilder_ == null) {
-          rowsBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
-              io.greptime.v1.RowData.Row, io.greptime.v1.RowData.Row.Builder, io.greptime.v1.RowData.RowOrBuilder>(
-                  rows_,
-                  ((bitField0_ & 0x00000001) != 0),
+          rowsBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
+              io.greptime.v1.RowData.Rows, io.greptime.v1.RowData.Rows.Builder, io.greptime.v1.RowData.RowsOrBuilder>(
+                  getRows(),
                   getParentForChildren(),
                   isClean());
           rows_ = null;
@@ -14290,40 +13946,38 @@ public io.greptime.v1.region.Server.ColumnDef getDefaultInstanceForType() {
       "s\030\002 \001(\004\"E\n\016InsertRequests\0223\n\010requests\030\001 " +
       "\003(\0132!.greptime.v1.region.InsertRequest\"E" +
       "\n\016DeleteRequests\0223\n\010requests\030\001 \003(\0132!.gre" +
-      "ptime.v1.region.DeleteRequest\"B\n\rInsertR" +
-      "equest\022\021\n\tregion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132" +
-      "\020.greptime.v1.Row\"B\n\rDeleteRequest\022\021\n\tre" +
-      "gion_id\030\001 \001(\004\022\036\n\004rows\030\002 \003(\0132\020.greptime.v" +
-      "1.Row\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001(\004" +
-      "\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tregi" +
-      "on_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_de" +
-      "fs\030\003 \003(\0132\035.greptime.v1.region.ColumnDef\022" +
-      "\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_ex" +
-      "ists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022?\n\007option" +
-      "s\030\007 \003(\0132..greptime.v1.region.CreateReque" +
-      "st.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key\030\001" +
-      " \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest\022\021" +
-      "\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\treg" +
-      "ion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion_d" +
-      "ir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v1." +
-      "region.OpenRequest.OptionsEntry\032.\n\014Optio" +
-      "nsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"" +
-      "!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Al" +
-      "terRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014FlushRe" +
-      "quest\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReque" +
-      "st\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n\004n" +
-      "ame\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010datatype" +
-      "\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n\013i" +
-      "s_nullable\030\004 \001(\010\022\032\n\022default_constraint\030\005" +
-      " \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime.v" +
-      "1.SemanticType2\264\001\n\006Region\022O\n\006Handle\022!.gr" +
-      "eptime.v1.region.RegionRequest\032\".greptim" +
-      "e.v1.region.RegionResponse\022Y\n\016HandleRequ" +
-      "ests\022!.greptime.v1.region.RegionRequest\032" +
-      "\".greptime.v1.region.RegionResponse(\001B]\n" +
-      "\025io.greptime.v1.regionB\006ServerZ<github.c" +
-      "om/GreptimeTeam/greptime-proto/go/grepti" +
-      "me/v1/regionb\006proto3"
+      "ptime.v1.region.DeleteRequest\"C\n\rInsertR" +
+      "equest\022\021\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132" +
+      "\021.greptime.v1.Rows\"C\n\rDeleteRequest\022\021\n\tr" +
+      "egion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime." +
+      "v1.Rows\"/\n\014QueryRequest\022\021\n\tregion_id\030\001 \001" +
+      "(\004\022\014\n\004plan\030\002 \001(\014\"\236\002\n\rCreateRequest\022\021\n\tre" +
+      "gion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0222\n\013column_" +
+      "defs\030\003 \003(\0132\035.greptime.v1.region.ColumnDe" +
+      "f\022\023\n\013primary_key\030\004 \003(\r\022\034\n\024create_if_not_" +
+      "exists\030\005 \001(\010\022\022\n\nregion_dir\030\006 \001(\t\022?\n\007opti" +
+      "ons\030\007 \003(\0132..greptime.v1.region.CreateReq" +
+      "uest.OptionsEntry\032.\n\014OptionsEntry\022\013\n\003key" +
+      "\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\" \n\013DropRequest" +
+      "\022\021\n\tregion_id\030\001 \001(\004\"\263\001\n\013OpenRequest\022\021\n\tr" +
+      "egion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022\022\n\nregion" +
+      "_dir\030\003 \001(\t\022=\n\007options\030\004 \003(\0132,.greptime.v" +
+      "1.region.OpenRequest.OptionsEntry\032.\n\014Opt" +
+      "ionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028" +
+      "\001\"!\n\014CloseRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014" +
+      "AlterRequest\022\021\n\tregion_id\030\001 \001(\004\"!\n\014Flush" +
+      "Request\022\021\n\tregion_id\030\001 \001(\004\"#\n\016CompactReq" +
+      "uest\022\021\n\tregion_id\030\001 \001(\004\"\276\001\n\tColumnDef\022\014\n" +
+      "\004name\030\001 \001(\t\022\021\n\tcolumn_id\030\002 \001(\r\022-\n\010dataty" +
+      "pe\030\003 \001(\0162\033.greptime.v1.ColumnDataType\022\023\n" +
+      "\013is_nullable\030\004 \001(\010\022\032\n\022default_constraint" +
+      "\030\005 \001(\014\0220\n\rsemantic_type\030\006 \001(\0162\031.greptime" +
+      ".v1.SemanticType2Y\n\006Region\022O\n\006Handle\022!.g" +
+      "reptime.v1.region.RegionRequest\032\".grepti" +
+      "me.v1.region.RegionResponseB]\n\025io.grepti" +
+      "me.v1.regionB\006ServerZ<github.com/Greptim" +
+      "eTeam/greptime-proto/go/greptime/v1/regi" +
+      "onb\006proto3"
     };
     descriptor = com.google.protobuf.Descriptors.FileDescriptor
       .internalBuildGeneratedFileFrom(descriptorData,
diff --git a/proto/greptime/v1/region/server.proto b/proto/greptime/v1/region/server.proto
index 863b5f62..5d683646 100644
--- a/proto/greptime/v1/region/server.proto
+++ b/proto/greptime/v1/region/server.proto
@@ -23,11 +23,7 @@ option go_package = "github.com/GreptimeTeam/greptime-proto/go/greptime/v1/regio
 import "greptime/v1/common.proto";
 import "greptime/v1/row.proto";
 
-service Region {
-  rpc Handle(RegionRequest) returns (RegionResponse);
-
-  rpc HandleRequests(stream RegionRequest) returns (RegionResponse);
-}
+service Region { rpc Handle(RegionRequest) returns (RegionResponse); }
 
 message RegionRequest {
   RequestHeader header = 1;
@@ -56,12 +52,12 @@ message DeleteRequests { repeated DeleteRequest requests = 1; }
 
 message InsertRequest {
   uint64 region_id = 1;
-  repeated Row rows = 2;
+  Rows rows = 2;
 }
 
 message DeleteRequest {
   uint64 region_id = 1;
-  repeated Row rows = 2;
+  Rows rows = 2;
 }
 
 message QueryRequest {