Skip to content

Commit 519b1d0

Browse files
authored
feat: support batch ddl (#135)
* feat: support batch create table * feat: ddl batch * feat: batch ddl task * feat: response table ids
1 parent 65b008f commit 519b1d0

File tree

9 files changed

+15807
-5195
lines changed

9 files changed

+15807
-5195
lines changed

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

Lines changed: 1003 additions & 143 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 1025 additions & 59 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

c++/greptime/v1/region/server.pb.cc

Lines changed: 1094 additions & 275 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

c++/greptime/v1/region/server.pb.h

Lines changed: 964 additions & 55 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 394 additions & 119 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

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

Lines changed: 5071 additions & 1450 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

java/src/main/java/io/greptime/v1/region/Server.java

Lines changed: 6231 additions & 3094 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

proto/greptime/v1/meta/ddl.proto

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,14 +39,20 @@ message CreateTableTask {
3939
bytes table_info = 3;
4040
}
4141

42+
message CreateTableTasks { repeated CreateTableTask tasks = 1; }
43+
4244
message DropTableTask{
4345
DropTableExpr drop_table = 1;
4446
}
4547

48+
message DropTableTasks { repeated DropTableTask tasks = 1; }
49+
4650
message AlterTableTask{
4751
AlterExpr alter_table = 1;
4852
}
4953

54+
message AlterTableTasks { repeated AlterTableTask tasks = 1; }
55+
5056
message TruncateTableTask {
5157
TruncateTableExpr truncate_table = 1;
5258
}
@@ -59,6 +65,9 @@ message SubmitDdlTaskRequest {
5965
DropTableTask drop_table_task = 3;
6066
AlterTableTask alter_table_task = 4;
6167
TruncateTableTask truncate_table_task = 5;
68+
CreateTableTasks create_table_tasks = 6;
69+
DropTableTasks drop_table_tasks = 7;
70+
AlterTableTasks alter_table_tasks = 8;
6271
}
6372
}
6473

@@ -68,5 +77,8 @@ message SubmitDdlTaskResponse {
6877
bytes key = 2;
6978

7079
// Returns if table created.
80+
// TODO(jeremy): remove it?
7181
TableId table_id = 4;
82+
// Returns if the tables created.
83+
repeated TableId table_ids = 5;
7284
}

proto/greptime/v1/region/server.proto

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,9 @@ message RegionRequest {
4747
FlushRequest flush = 10;
4848
CompactRequest compact = 11;
4949
TruncateRequest truncate = 12;
50+
CreateRequests creates = 13;
51+
DropRequests drops = 14;
52+
AlterRequests alters = 15;
5053
}
5154
}
5255

@@ -76,6 +79,11 @@ message QueryRequest {
7679
bytes plan = 3;
7780
}
7881

82+
// Create a batch of regions at once, usually used to create multiple logical regions
83+
// at once. Different engines can choose whether to support this request.
84+
// Metric Engine needs it.
85+
message CreateRequests { repeated CreateRequest requests = 1; }
86+
7987
message CreateRequest {
8088
uint64 region_id = 1;
8189
// Region engine name
@@ -91,6 +99,9 @@ message CreateRequest {
9199
// TODO: add partition def
92100
}
93101

102+
// Same as CreateRequests, but for dropping regions.
103+
message DropRequests { repeated DropRequest requests = 1; }
104+
94105
message DropRequest { uint64 region_id = 1; }
95106

96107
message OpenRequest {
@@ -105,6 +116,8 @@ message OpenRequest {
105116

106117
message CloseRequest { uint64 region_id = 1; }
107118

119+
message AlterRequests { repeated AlterRequest requests = 1; }
120+
108121
message AlterRequest {
109122
uint64 region_id = 1;
110123
oneof kind {

0 commit comments

Comments
 (0)