Dima/orion_greptime_proto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: handle multiple InsertRequests in GRPC method (#47)

Browse Source 
* feat: make InsertRequest in a batch

* feat: make InsertRequest in a batch

* feat: make InsertRequest in a batch
This commit is contained in:
LFC
2023-06-02 16:37:45 +08:00
committed by GitHub
parent 52dcb43b5d
commit 4398d20c56
7 changed files with 1209 additions and 248 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/src/main/java/io/greptime/v1/Columns.java
+6
View File
@@ -477,6 +477,8 @@ public final class Columns {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1400,6 +1402,8 @@ public final class Columns {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -5889,6 +5893,8 @@ public final class Columns {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
java/src/main/java/io/greptime/v1/Common.java
+18 -2
View File
@@ -74,6 +74,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -613,6 +615,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1791,6 +1795,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -2358,8 +2364,9 @@ public final class Common {
} else {
if (authSchemeCase_ == 1) {
basicBuilder_.mergeFrom(value);
} else {
basicBuilder_.setMessage(value);
}
basicBuilder_.setMessage(value);
}
authSchemeCase_ = 1;
return this;
@@ -2499,8 +2506,9 @@ public final class Common {
} else {
if (authSchemeCase_ == 2) {
tokenBuilder_.mergeFrom(value);
} else {
tokenBuilder_.setMessage(value);
}
tokenBuilder_.setMessage(value);
}
authSchemeCase_ = 2;
return this;
@@ -2716,6 +2724,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -3415,6 +3425,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -3975,6 +3987,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -4480,6 +4494,8 @@ public final class Common {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
java/src/main/java/io/greptime/v1/Database.java
+944 -120
View File
File diff suppressed because it is too large Load Diff
java/src/main/java/io/greptime/v1/Ddl.java
+46 -10
View File
@@ -228,6 +228,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -979,8 +981,9 @@ public final class Ddl {
} else {
if (exprCase_ == 1) {
createDatabaseBuilder_.mergeFrom(value);
} else {
createDatabaseBuilder_.setMessage(value);
}
createDatabaseBuilder_.setMessage(value);
}
exprCase_ = 1;
return this;
@@ -1120,8 +1123,9 @@ public final class Ddl {
} else {
if (exprCase_ == 2) {
createTableBuilder_.mergeFrom(value);
} else {
createTableBuilder_.setMessage(value);
}
createTableBuilder_.setMessage(value);
}
exprCase_ = 2;
return this;
@@ -1261,8 +1265,9 @@ public final class Ddl {
} else {
if (exprCase_ == 3) {
alterBuilder_.mergeFrom(value);
} else {
alterBuilder_.setMessage(value);
}
alterBuilder_.setMessage(value);
}
exprCase_ = 3;
return this;
@@ -1402,8 +1407,9 @@ public final class Ddl {
} else {
if (exprCase_ == 4) {
dropTableBuilder_.mergeFrom(value);
} else {
dropTableBuilder_.setMessage(value);
}
dropTableBuilder_.setMessage(value);
}
exprCase_ = 4;
return this;
@@ -1543,8 +1549,9 @@ public final class Ddl {
} else {
if (exprCase_ == 5) {
flushTableBuilder_.mergeFrom(value);
} else {
flushTableBuilder_.setMessage(value);
}
flushTableBuilder_.setMessage(value);
}
exprCase_ = 5;
return this;
@@ -1805,9 +1812,11 @@ public final class Ddl {
* <code>map&lt;string, string&gt; table_options = 9;</code>
*/
java.lang.String getTableOptionsOrDefault(
/* nullable */
java.lang.String getTableOptionsOrDefault(
java.lang.String key,
java.lang.String defaultValue);
/* nullable */
java.lang.String defaultValue);
/**
* <code>map&lt;string, string&gt; table_options = 9;</code>
*/
@@ -2031,6 +2040,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -4566,6 +4577,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -5585,8 +5598,9 @@ public final class Ddl {
} else {
if (kindCase_ == 4) {
addColumnsBuilder_.mergeFrom(value);
} else {
addColumnsBuilder_.setMessage(value);
}
addColumnsBuilder_.setMessage(value);
}
kindCase_ = 4;
return this;
@@ -5726,8 +5740,9 @@ public final class Ddl {
} else {
if (kindCase_ == 5) {
dropColumnsBuilder_.mergeFrom(value);
} else {
dropColumnsBuilder_.setMessage(value);
}
dropColumnsBuilder_.setMessage(value);
}
kindCase_ = 5;
return this;
@@ -5867,8 +5882,9 @@ public final class Ddl {
} else {
if (kindCase_ == 6) {
renameTableBuilder_.mergeFrom(value);
} else {
renameTableBuilder_.setMessage(value);
}
renameTableBuilder_.setMessage(value);
}
kindCase_ = 6;
return this;
@@ -6103,6 +6119,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -6988,6 +7006,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -7925,6 +7945,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -8597,6 +8619,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -9390,6 +9414,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -10167,6 +10193,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -10783,6 +10811,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -10901,6 +10931,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -12413,6 +12445,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -12973,6 +13007,8 @@ public final class Ddl {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
java/src/main/java/io/greptime/v1/Prometheus.java
+12 -2
View File
@@ -162,6 +162,8 @@ public final class Prometheus {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -904,8 +906,9 @@ public final class Prometheus {
} else {
if (promqlCase_ == 2) {
instantQueryBuilder_.mergeFrom(value);
} else {
instantQueryBuilder_.setMessage(value);
}
instantQueryBuilder_.setMessage(value);
}
promqlCase_ = 2;
return this;
@@ -1045,8 +1048,9 @@ public final class Prometheus {
} else {
if (promqlCase_ == 3) {
rangeQueryBuilder_.mergeFrom(value);
} else {
rangeQueryBuilder_.setMessage(value);
}
rangeQueryBuilder_.setMessage(value);
}
promqlCase_ = 3;
return this;
@@ -1268,6 +1272,8 @@ public final class Prometheus {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -1977,6 +1983,8 @@ public final class Prometheus {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);
@@ -2733,6 +2741,8 @@ public final class Prometheus {
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
throw e.setUnfinishedMessage(this);
} catch (com.google.protobuf.UninitializedMessageException e) {
throw e.asInvalidProtocolBufferException().setUnfinishedMessage(this);
} catch (java.io.IOException e) {
throw new com.google.protobuf.InvalidProtocolBufferException(
e).setUnfinishedMessage(this);