feat: add bulk insert request type (#228)

* add bulk insert request type * fix: rename
2025-04-10 20:06:41 +08:00
parent dd4a199698
commit 583daa3fbb
4 changed files with 3207 additions and 166 deletions
@@ -53,6 +53,7 @@ message RegionRequest {
    CreateRequests creates = 13;
    DropRequests drops = 14;
    AlterRequests alters = 15;
+    BulkInsertRequests bulk_inserts = 16;
  }
 }

@@ -182,3 +183,16 @@ message RegionColumnDef {
  ColumnDef column_def = 1;
  uint32 column_id = 2;
 }
+
+// Request of bulk ingestion API.
+message BulkInsertRequests { repeated BulkInsertRequest requests = 1; }
+
+enum BulkInsertType {
+  ARROW_IPC = 0;
+}
+
+message BulkInsertRequest {
+  uint64 region_id = 1;
+  BulkInsertType payload_type = 2;
+  bytes payload = 3;
+}