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

feat: add partition to CreateRequest (#267)

Browse Source
This commit is contained in:
Zhenchi
2025-08-14 05:39:49 +08:00
committed by GitHub
parent 69680846a0
commit 9edc8c4d2a
5 changed files with 1120 additions and 670 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/src/main/java/io/greptime/v1/region/Server.java
+388 -121
View File
@@ -11541,6 +11541,33 @@ java.lang.String defaultValue);
java.lang.String getOptionsOrThrow(
java.lang.String key);
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return Whether the partition field is set.
*/
boolean hasPartition();
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return The partition.
*/
greptime.v1.meta.Route.Partition getPartition();
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
greptime.v1.meta.Route.PartitionOrBuilder getPartitionOrBuilder();
}
/**
* Protobuf type {@code greptime.v1.region.CreateRequest}
@@ -11652,6 +11679,19 @@ java.lang.String defaultValue);
options__.getKey(), options__.getValue());
break;
}
case 58: {
greptime.v1.meta.Route.Partition.Builder subBuilder = null;
if (partition_ != null) {
subBuilder = partition_.toBuilder();
}
partition_ = input.readMessage(greptime.v1.meta.Route.Partition.parser(), extensionRegistry);
if (subBuilder != null) {
subBuilder.mergeFrom(partition_);
partition_ = subBuilder.buildPartial();
}
break;
}
default: {
if (!parseUnknownField(
input, unknownFields, extensionRegistry, tag)) {
@@ -12004,6 +12044,44 @@ java.lang.String defaultValue);
return map.get(key);
}
public static final int PARTITION_FIELD_NUMBER = 7;
private greptime.v1.meta.Route.Partition partition_;
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return Whether the partition field is set.
*/
@java.lang.Override
public boolean hasPartition() {
return partition_ != null;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return The partition.
*/
@java.lang.Override
public greptime.v1.meta.Route.Partition getPartition() {
return partition_ == null ? greptime.v1.meta.Route.Partition.getDefaultInstance() : partition_;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
@java.lang.Override
public greptime.v1.meta.Route.PartitionOrBuilder getPartitionOrBuilder() {
return getPartition();
}
private byte memoizedIsInitialized = -1;
@java.lang.Override
public final boolean isInitialized() {
@@ -12044,6 +12122,9 @@ java.lang.String defaultValue);
internalGetOptions(),
OptionsDefaultEntryHolder.defaultEntry,
6);
if (partition_ != null) {
output.writeMessage(7, getPartition());
}
unknownFields.writeTo(output);
}
@@ -12091,6 +12172,10 @@ java.lang.String defaultValue);
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(6, options__);
}
if (partition_ != null) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(7, getPartition());
}
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -12118,6 +12203,11 @@ java.lang.String defaultValue);
.equals(other.getPath())) return false;
if (!internalGetOptions().equals(
other.internalGetOptions())) return false;
if (hasPartition() != other.hasPartition()) return false;
if (hasPartition()) {
if (!getPartition()
.equals(other.getPartition())) return false;
}
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
}
@@ -12148,6 +12238,10 @@ java.lang.String defaultValue);
hash = (37 * hash) + OPTIONS_FIELD_NUMBER;
hash = (53 * hash) + internalGetOptions().hashCode();
}
if (hasPartition()) {
hash = (37 * hash) + PARTITION_FIELD_NUMBER;
hash = (53 * hash) + getPartition().hashCode();
}
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -12319,6 +12413,12 @@ java.lang.String defaultValue);
path_ = "";
internalGetMutableOptions().clear();
if (partitionBuilder_ == null) {
partition_ = null;
} else {
partition_ = null;
partitionBuilder_ = null;
}
return this;
}
@@ -12365,6 +12465,11 @@ java.lang.String defaultValue);
result.path_ = path_;
result.options_ = internalGetOptions();
result.options_.makeImmutable();
if (partitionBuilder_ == null) {
result.partition_ = partition_;
} else {
result.partition_ = partitionBuilder_.build();
}
onBuilt();
return result;
}
@@ -12462,6 +12567,9 @@ java.lang.String defaultValue);
}
internalGetMutableOptions().mergeFrom(
other.internalGetOptions());
if (other.hasPartition()) {
mergePartition(other.getPartition());
}
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -13292,6 +13400,161 @@ java.lang.String defaultValue);
.putAll(values);
return this;
}
private greptime.v1.meta.Route.Partition partition_;
private com.google.protobuf.SingleFieldBuilderV3<
greptime.v1.meta.Route.Partition, greptime.v1.meta.Route.Partition.Builder, greptime.v1.meta.Route.PartitionOrBuilder> partitionBuilder_;
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return Whether the partition field is set.
*/
public boolean hasPartition() {
return partitionBuilder_ != null || partition_ != null;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
* @return The partition.
*/
public greptime.v1.meta.Route.Partition getPartition() {
if (partitionBuilder_ == null) {
return partition_ == null ? greptime.v1.meta.Route.Partition.getDefaultInstance() : partition_;
} else {
return partitionBuilder_.getMessage();
}
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public Builder setPartition(greptime.v1.meta.Route.Partition value) {
if (partitionBuilder_ == null) {
if (value == null) {
throw new NullPointerException();
}
partition_ = value;
onChanged();
} else {
partitionBuilder_.setMessage(value);
}
return this;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public Builder setPartition(
greptime.v1.meta.Route.Partition.Builder builderForValue) {
if (partitionBuilder_ == null) {
partition_ = builderForValue.build();
onChanged();
} else {
partitionBuilder_.setMessage(builderForValue.build());
}
return this;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public Builder mergePartition(greptime.v1.meta.Route.Partition value) {
if (partitionBuilder_ == null) {
if (partition_ != null) {
partition_ =
greptime.v1.meta.Route.Partition.newBuilder(partition_).mergeFrom(value).buildPartial();
} else {
partition_ = value;
}
onChanged();
} else {
partitionBuilder_.mergeFrom(value);
}
return this;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public Builder clearPartition() {
if (partitionBuilder_ == null) {
partition_ = null;
onChanged();
} else {
partition_ = null;
partitionBuilder_ = null;
}
return this;
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public greptime.v1.meta.Route.Partition.Builder getPartitionBuilder() {
onChanged();
return getPartitionFieldBuilder().getBuilder();
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
public greptime.v1.meta.Route.PartitionOrBuilder getPartitionOrBuilder() {
if (partitionBuilder_ != null) {
return partitionBuilder_.getMessageOrBuilder();
} else {
return partition_ == null ?
greptime.v1.meta.Route.Partition.getDefaultInstance() : partition_;
}
}
/**
* <pre>
* Partition of the created region.
* </pre>
*
* <code>.greptime.v1.meta.Partition partition = 7;</code>
*/
private com.google.protobuf.SingleFieldBuilderV3<
greptime.v1.meta.Route.Partition, greptime.v1.meta.Route.Partition.Builder, greptime.v1.meta.Route.PartitionOrBuilder>
getPartitionFieldBuilder() {
if (partitionBuilder_ == null) {
partitionBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
greptime.v1.meta.Route.Partition, greptime.v1.meta.Route.Partition.Builder, greptime.v1.meta.Route.PartitionOrBuilder>(
getPartition(),
getParentForChildren(),
isClean());
partition_ = null;
}
return partitionBuilder_;
}
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -32909,132 +33172,135 @@ java.lang.String defaultValue);
java.lang.String[] descriptorData = {
"\n\037greptime/v1/region/server.proto\022\022grept" +
"ime.v1.region\032\030greptime/v1/common.proto\032" +
"\025greptime/v1/ddl.proto\032\025greptime/v1/row." +
"proto\"\344\001\n\023RegionRequestHeader\022T\n\017tracing" +
"_context\030\005 \003(\0132;.greptime.v1.region.Regi" +
"onRequestHeader.TracingContextEntry\022\016\n\006d" +
"bname\030\003 \001(\t\0220\n\rquery_context\030\006 \001(\0132\031.gre" +
"ptime.v1.QueryContext\0325\n\023TracingContextE" +
"ntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\256\007\n" +
"\rRegionRequest\0227\n\006header\030\001 \001(\0132\'.greptim" +
"e.v1.region.RegionRequestHeader\0225\n\007inser" +
"ts\030\003 \001(\0132\".greptime.v1.region.InsertRequ" +
"estsH\000\0225\n\007deletes\030\004 \001(\0132\".greptime.v1.re" +
"gion.DeleteRequestsH\000\0223\n\006create\030\005 \001(\0132!." +
"greptime.v1.region.CreateRequestH\000\022/\n\004dr" +
"op\030\006 \001(\0132\037.greptime.v1.region.DropReques" +
"tH\000\022/\n\004open\030\007 \001(\0132\037.greptime.v1.region.O" +
"penRequestH\000\0221\n\005close\030\010 \001(\0132 .greptime.v" +
"1.region.CloseRequestH\000\0221\n\005alter\030\t \001(\0132 " +
".greptime.v1.region.AlterRequestH\000\0221\n\005fl" +
"ush\030\n \001(\0132 .greptime.v1.region.FlushRequ" +
"estH\000\0225\n\007compact\030\013 \001(\0132\".greptime.v1.reg" +
"ion.CompactRequestH\000\0227\n\010truncate\030\014 \001(\0132#" +
".greptime.v1.region.TruncateRequestH\000\0225\n" +
"\007creates\030\r \001(\0132\".greptime.v1.region.Crea" +
"teRequestsH\000\0221\n\005drops\030\016 \001(\0132 .greptime.v" +
"1.region.DropRequestsH\000\0223\n\006alters\030\017 \001(\0132" +
"!.greptime.v1.region.AlterRequestsH\000\022<\n\013" +
"bulk_insert\030\020 \001(\0132%.greptime.v1.region.B" +
"ulkInsertRequestH\000\022/\n\004sync\030\021 \001(\0132\037.grept" +
"ime.v1.region.SyncRequestH\000\022@\n\rlist_meta" +
"data\030\022 \001(\0132\'.greptime.v1.region.ListMeta" +
"dataRequestH\000B\006\n\004body\"\341\001\n\016RegionResponse" +
"\022+\n\006header\030\001 \001(\0132\033.greptime.v1.ResponseH" +
"eader\022\025\n\raffected_rows\030\002 \001(\004\022F\n\nextensio" +
"ns\030\003 \003(\01322.greptime.v1.region.RegionResp" +
"onse.ExtensionsEntry\022\020\n\010metadata\030\004 \001(\014\0321" +
"\n\017ExtensionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030" +
"\002 \001(\014:\0028\001\"E\n\016InsertRequests\0223\n\010requests\030" +
"\001 \003(\0132!.greptime.v1.region.InsertRequest" +
"\"E\n\016DeleteRequests\0223\n\010requests\030\001 \003(\0132!.g" +
"reptime.v1.region.DeleteRequest\"C\n\rInser" +
"tRequest\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" +
"\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptim" +
"e.v1.Rows\"h\n\014QueryRequest\0227\n\006header\030\001 \001(" +
"\0132\'.greptime.v1.region.RegionRequestHead" +
"er\022\021\n\tregion_id\030\002 \001(\004\022\014\n\004plan\030\003 \001(\014\"E\n\016C" +
"reateRequests\0223\n\010requests\030\001 \003(\0132!.grepti" +
"me.v1.region.CreateRequest\"\200\002\n\rCreateReq" +
"uest\022\021\n\tregion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\022" +
"8\n\013column_defs\030\003 \003(\0132#.greptime.v1.regio" +
"n.RegionColumnDef\022\023\n\013primary_key\030\004 \003(\r\022\014" +
"\n\004path\030\005 \001(\t\022?\n\007options\030\006 \003(\0132..greptime" +
".v1.region.CreateRequest.OptionsEntry\032.\n" +
"\014OptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(" +
"\t:\0028\001\"A\n\014DropRequests\0221\n\010requests\030\001 \003(\0132" +
"\037.greptime.v1.region.DropRequest\"3\n\013Drop" +
"Request\022\021\n\tregion_id\030\001 \001(\004\022\021\n\tfast_path\030" +
"\002 \001(\010\"\255\001\n\013OpenRequest\022\021\n\tregion_id\030\001 \001(\004" +
"\022\016\n\006engine\030\002 \001(\t\022\014\n\004path\030\003 \001(\t\022=\n\007option" +
"s\030\004 \003(\0132,.greptime.v1.region.OpenRequest" +
".OptionsEntry\032.\n\014OptionsEntry\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\"C\n\rAlterRequests\0222\n\010req" +
"uests\030\001 \003(\0132 .greptime.v1.region.AlterRe" +
"quest\"\311\005\n\014AlterRequest\022\021\n\tregion_id\030\001 \001(" +
"\004\0225\n\013add_columns\030\002 \001(\0132\036.greptime.v1.reg" +
"ion.AddColumnsH\000\0227\n\014drop_columns\030\003 \001(\0132\037" +
".greptime.v1.region.DropColumnsH\000\022=\n\023mod" +
"ify_column_types\030\005 \001(\0132\036.greptime.v1.Mod" +
"ifyColumnTypesH\000\0229\n\021set_table_options\030\006 " +
"\001(\0132\034.greptime.v1.SetTableOptionsH\000\022=\n\023u" +
"nset_table_options\030\t \001(\0132\036.greptime.v1.U" +
"nsetTableOptionsH\000\022*\n\tset_index\030\n \001(\0132\025." +
"greptime.v1.SetIndexH\000\022.\n\013unset_index\030\013 " +
"\001(\0132\027.greptime.v1.UnsetIndexH\000\0222\n\rdrop_d" +
"efaults\030\014 \001(\0132\031.greptime.v1.DropDefaults" +
"H\000\022.\n\013set_indexes\030\r \001(\0132\027.greptime.v1.Se" +
"tIndexesH\000\0222\n\runset_indexes\030\016 \001(\0132\031.grep" +
"time.v1.UnsetIndexesH\000\0220\n\014set_defaults\030\017" +
" \001(\0132\030.greptime.v1.SetDefaultsH\000\0227\n\014sync" +
"_columns\030\020 \001(\0132\037.greptime.v1.region.Sync" +
"ColumnsH\000\022\026\n\016schema_version\030\004 \001(\004B\006\n\004kin" +
"d\"G\n\013SyncColumns\0228\n\013column_defs\030\001 \003(\0132#." +
"greptime.v1.region.RegionColumnDef\"@\n\nAd" +
"dColumns\0222\n\013add_columns\030\001 \003(\0132\035.greptime" +
".v1.region.AddColumn\"C\n\013DropColumns\0224\n\014d" +
"rop_columns\030\001 \003(\0132\036.greptime.v1.region.D" +
"ropColumn\"v\n\tAddColumn\0227\n\ncolumn_def\030\001 \001" +
"(\0132#.greptime.v1.region.RegionColumnDef\022" +
"0\n\010location\030\003 \001(\0132\036.greptime.v1.AddColum" +
"nLocation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"!\n" +
"\014FlushRequest\022\021\n\tregion_id\030\001 \001(\004\"\t\n\007Regu" +
"lar\"&\n\014StrictWindow\022\026\n\016window_seconds\030\001 " +
"\001(\003\"\231\001\n\016CompactRequest\022\021\n\tregion_id\030\001 \001(" +
"\004\022.\n\007regular\030\002 \001(\0132\033.greptime.v1.region." +
"RegularH\000\0229\n\rstrict_window\030\003 \001(\0132 .grept" +
"ime.v1.region.StrictWindowH\000B\t\n\007options\"" +
"\204\001\n\017TruncateRequest\022\021\n\tregion_id\030\001 \001(\004\022&" +
"\n\003all\030\002 \001(\0132\027.greptime.v1.region.AllH\000\022." +
"\n\013time_ranges\030\003 \001(\0132\027.greptime.v1.TimeRa" +
"ngesH\000B\006\n\004kind\"\005\n\003All\"P\n\017RegionColumnDef" +
"\022*\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.Colum" +
"nDef\022\021\n\tcolumn_id\030\002 \001(\r\"Z\n\021BulkInsertReq" +
"uest\022\021\n\tregion_id\030\001 \001(\004\022*\n\tarrow_ipc\030\002 \001" +
"(\0132\025.greptime.v1.ArrowIpcH\000B\006\n\004body\"1\n\020M" +
"itoManifestInfo\022\035\n\025data_manifest_version" +
"\030\001 \001(\004\"V\n\022MetricManifestInfo\022\035\n\025data_man" +
"ifest_version\030\001 \001(\004\022!\n\031metadata_manifest" +
"_version\030\002 \001(\004\"\275\001\n\013SyncRequest\022\021\n\tregion" +
"_id\030\001 \001(\004\022B\n\022mito_manifest_info\030\002 \001(\0132$." +
"greptime.v1.region.MitoManifestInfoH\000\022F\n" +
"\024metric_manifest_info\030\003 \001(\0132&.greptime.v" +
"1.region.MetricManifestInfoH\000B\017\n\rmanifes" +
"t_info\")\n\023ListMetadataRequest\022\022\n\nregion_" +
"ids\030\001 \003(\0042Y\n\006Region\022O\n\006Handle\022!.greptime" +
".v1.region.RegionRequest\032\".greptime.v1.r" +
"egion.RegionResponseB]\n\025io.greptime.v1.r" +
"egionB\006ServerZ<github.com/GreptimeTeam/g" +
"reptime-proto/go/greptime/v1/regionb\006pro" +
"to3"
"\025greptime/v1/ddl.proto\032\034greptime/v1/meta" +
"/route.proto\032\025greptime/v1/row.proto\"\344\001\n\023" +
"RegionRequestHeader\022T\n\017tracing_context\030\005" +
" \003(\0132;.greptime.v1.region.RegionRequestH" +
"eader.TracingContextEntry\022\016\n\006dbname\030\003 \001(" +
"\t\0220\n\rquery_context\030\006 \001(\0132\031.greptime.v1.Q" +
"ueryContext\0325\n\023TracingContextEntry\022\013\n\003ke" +
"y\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:\0028\001\"\256\007\n\rRegionReq" +
"uest\0227\n\006header\030\001 \001(\0132\'.greptime.v1.regio" +
"n.RegionRequestHeader\0225\n\007inserts\030\003 \001(\0132\"" +
".greptime.v1.region.InsertRequestsH\000\0225\n\007" +
"deletes\030\004 \001(\0132\".greptime.v1.region.Delet" +
"eRequestsH\000\0223\n\006create\030\005 \001(\0132!.greptime.v" +
"1.region.CreateRequestH\000\022/\n\004drop\030\006 \001(\0132\037" +
".greptime.v1.region.DropRequestH\000\022/\n\004ope" +
"n\030\007 \001(\0132\037.greptime.v1.region.OpenRequest" +
"H\000\0221\n\005close\030\010 \001(\0132 .greptime.v1.region.C" +
"loseRequestH\000\0221\n\005alter\030\t \001(\0132 .greptime." +
"v1.region.AlterRequestH\000\0221\n\005flush\030\n \001(\0132" +
" .greptime.v1.region.FlushRequestH\000\0225\n\007c" +
"ompact\030\013 \001(\0132\".greptime.v1.region.Compac" +
"tRequestH\000\0227\n\010truncate\030\014 \001(\0132#.greptime." +
"v1.region.TruncateRequestH\000\0225\n\007creates\030\r" +
" \001(\0132\".greptime.v1.region.CreateRequests" +
"H\000\0221\n\005drops\030\016 \001(\0132 .greptime.v1.region.D" +
"ropRequestsH\000\0223\n\006alters\030\017 \001(\0132!.greptime" +
".v1.region.AlterRequestsH\000\022<\n\013bulk_inser" +
"t\030\020 \001(\0132%.greptime.v1.region.BulkInsertR" +
"equestH\000\022/\n\004sync\030\021 \001(\0132\037.greptime.v1.reg" +
"ion.SyncRequestH\000\022@\n\rlist_metadata\030\022 \001(\013" +
"2\'.greptime.v1.region.ListMetadataReques" +
"tH\000B\006\n\004body\"\341\001\n\016RegionResponse\022+\n\006header" +
"\030\001 \001(\0132\033.greptime.v1.ResponseHeader\022\025\n\ra" +
"ffected_rows\030\002 \001(\004\022F\n\nextensions\030\003 \003(\01322" +
".greptime.v1.region.RegionResponse.Exten" +
"sionsEntry\022\020\n\010metadata\030\004 \001(\014\0321\n\017Extensio" +
"nsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\014:\0028\001\"" +
"E\n\016InsertRequests\0223\n\010requests\030\001 \003(\0132!.gr" +
"eptime.v1.region.InsertRequest\"E\n\016Delete" +
"Requests\0223\n\010requests\030\001 \003(\0132!.greptime.v1" +
".region.DeleteRequest\"C\n\rInsertRequest\022\021" +
"\n\tregion_id\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.grepti" +
"me.v1.Rows\"C\n\rDeleteRequest\022\021\n\tregion_id" +
"\030\001 \001(\004\022\037\n\004rows\030\002 \001(\0132\021.greptime.v1.Rows\"" +
"h\n\014QueryRequest\0227\n\006header\030\001 \001(\0132\'.grepti" +
"me.v1.region.RegionRequestHeader\022\021\n\tregi" +
"on_id\030\002 \001(\004\022\014\n\004plan\030\003 \001(\014\"E\n\016CreateReque" +
"sts\0223\n\010requests\030\001 \003(\0132!.greptime.v1.regi" +
"on.CreateRequest\"\260\002\n\rCreateRequest\022\021\n\tre" +
"gion_id\030\001 \001(\004\022\016\n\006engine\030\002 \001(\t\0228\n\013column_" +
"defs\030\003 \003(\0132#.greptime.v1.region.RegionCo" +
"lumnDef\022\023\n\013primary_key\030\004 \003(\r\022\014\n\004path\030\005 \001" +
"(\t\022?\n\007options\030\006 \003(\0132..greptime.v1.region" +
".CreateRequest.OptionsEntry\022.\n\tpartition" +
"\030\007 \001(\0132\033.greptime.v1.meta.Partition\032.\n\014O" +
"ptionsEntry\022\013\n\003key\030\001 \001(\t\022\r\n\005value\030\002 \001(\t:" +
"\0028\001\"A\n\014DropRequests\0221\n\010requests\030\001 \003(\0132\037." +
"greptime.v1.region.DropRequest\"3\n\013DropRe" +
"quest\022\021\n\tregion_id\030\001 \001(\004\022\021\n\tfast_path\030\002 " +
"\001(\010\"\255\001\n\013OpenRequest\022\021\n\tregion_id\030\001 \001(\004\022\016" +
"\n\006engine\030\002 \001(\t\022\014\n\004path\030\003 \001(\t\022=\n\007options\030" +
"\004 \003(\0132,.greptime.v1.region.OpenRequest.O" +
"ptionsEntry\032.\n\014OptionsEntry\022\013\n\003key\030\001 \001(\t" +
"\022\r\n\005value\030\002 \001(\t:\0028\001\"!\n\014CloseRequest\022\021\n\tr" +
"egion_id\030\001 \001(\004\"C\n\rAlterRequests\0222\n\010reque" +
"sts\030\001 \003(\0132 .greptime.v1.region.AlterRequ" +
"est\"\311\005\n\014AlterRequest\022\021\n\tregion_id\030\001 \001(\004\022" +
"5\n\013add_columns\030\002 \001(\0132\036.greptime.v1.regio" +
"n.AddColumnsH\000\0227\n\014drop_columns\030\003 \001(\0132\037.g" +
"reptime.v1.region.DropColumnsH\000\022=\n\023modif" +
"y_column_types\030\005 \001(\0132\036.greptime.v1.Modif" +
"yColumnTypesH\000\0229\n\021set_table_options\030\006 \001(" +
"\0132\034.greptime.v1.SetTableOptionsH\000\022=\n\023uns" +
"et_table_options\030\t \001(\0132\036.greptime.v1.Uns" +
"etTableOptionsH\000\022*\n\tset_index\030\n \001(\0132\025.gr" +
"eptime.v1.SetIndexH\000\022.\n\013unset_index\030\013 \001(" +
"\0132\027.greptime.v1.UnsetIndexH\000\0222\n\rdrop_def" +
"aults\030\014 \001(\0132\031.greptime.v1.DropDefaultsH\000" +
"\022.\n\013set_indexes\030\r \001(\0132\027.greptime.v1.SetI" +
"ndexesH\000\0222\n\runset_indexes\030\016 \001(\0132\031.grepti" +
"me.v1.UnsetIndexesH\000\0220\n\014set_defaults\030\017 \001" +
"(\0132\030.greptime.v1.SetDefaultsH\000\0227\n\014sync_c" +
"olumns\030\020 \001(\0132\037.greptime.v1.region.SyncCo" +
"lumnsH\000\022\026\n\016schema_version\030\004 \001(\004B\006\n\004kind\"" +
"G\n\013SyncColumns\0228\n\013column_defs\030\001 \003(\0132#.gr" +
"eptime.v1.region.RegionColumnDef\"@\n\nAddC" +
"olumns\0222\n\013add_columns\030\001 \003(\0132\035.greptime.v" +
"1.region.AddColumn\"C\n\013DropColumns\0224\n\014dro" +
"p_columns\030\001 \003(\0132\036.greptime.v1.region.Dro" +
"pColumn\"v\n\tAddColumn\0227\n\ncolumn_def\030\001 \001(\013" +
"2#.greptime.v1.region.RegionColumnDef\0220\n" +
"\010location\030\003 \001(\0132\036.greptime.v1.AddColumnL" +
"ocation\"\032\n\nDropColumn\022\014\n\004name\030\001 \001(\t\"!\n\014F" +
"lushRequest\022\021\n\tregion_id\030\001 \001(\004\"\t\n\007Regula" +
"r\"&\n\014StrictWindow\022\026\n\016window_seconds\030\001 \001(" +
"\003\"\231\001\n\016CompactRequest\022\021\n\tregion_id\030\001 \001(\004\022" +
".\n\007regular\030\002 \001(\0132\033.greptime.v1.region.Re" +
"gularH\000\0229\n\rstrict_window\030\003 \001(\0132 .greptim" +
"e.v1.region.StrictWindowH\000B\t\n\007options\"\204\001" +
"\n\017TruncateRequest\022\021\n\tregion_id\030\001 \001(\004\022&\n\003" +
"all\030\002 \001(\0132\027.greptime.v1.region.AllH\000\022.\n\013" +
"time_ranges\030\003 \001(\0132\027.greptime.v1.TimeRang" +
"esH\000B\006\n\004kind\"\005\n\003All\"P\n\017RegionColumnDef\022*" +
"\n\ncolumn_def\030\001 \001(\0132\026.greptime.v1.ColumnD" +
"ef\022\021\n\tcolumn_id\030\002 \001(\r\"Z\n\021BulkInsertReque" +
"st\022\021\n\tregion_id\030\001 \001(\004\022*\n\tarrow_ipc\030\002 \001(\013" +
"2\025.greptime.v1.ArrowIpcH\000B\006\n\004body\"1\n\020Mit" +
"oManifestInfo\022\035\n\025data_manifest_version\030\001" +
" \001(\004\"V\n\022MetricManifestInfo\022\035\n\025data_manif" +
"est_version\030\001 \001(\004\022!\n\031metadata_manifest_v" +
"ersion\030\002 \001(\004\"\275\001\n\013SyncRequest\022\021\n\tregion_i" +
"d\030\001 \001(\004\022B\n\022mito_manifest_info\030\002 \001(\0132$.gr" +
"eptime.v1.region.MitoManifestInfoH\000\022F\n\024m" +
"etric_manifest_info\030\003 \001(\0132&.greptime.v1." +
"region.MetricManifestInfoH\000B\017\n\rmanifest_" +
"info\")\n\023ListMetadataRequest\022\022\n\nregion_id" +
"s\030\001 \003(\0042Y\n\006Region\022O\n\006Handle\022!.greptime.v" +
"1.region.RegionRequest\032\".greptime.v1.reg" +
"ion.RegionResponseB]\n\025io.greptime.v1.reg" +
"ionB\006ServerZ<github.com/GreptimeTeam/gre" +
"ptime-proto/go/greptime/v1/regionb\006proto" +
"3"
};
descriptor = com.google.protobuf.Descriptors.FileDescriptor
.internalBuildGeneratedFileFrom(descriptorData,
new com.google.protobuf.Descriptors.FileDescriptor[] {
io.greptime.v1.Common.getDescriptor(),
io.greptime.v1.Ddl.getDescriptor(),
greptime.v1.meta.Route.getDescriptor(),
io.greptime.v1.RowData.getDescriptor(),
});
internal_static_greptime_v1_region_RegionRequestHeader_descriptor =
@@ -33108,7 +33374,7 @@ java.lang.String defaultValue);
internal_static_greptime_v1_region_CreateRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_greptime_v1_region_CreateRequest_descriptor,
new java.lang.String[] { "RegionId", "Engine", "ColumnDefs", "PrimaryKey", "Path", "Options", });
new java.lang.String[] { "RegionId", "Engine", "ColumnDefs", "PrimaryKey", "Path", "Options", "Partition", });
internal_static_greptime_v1_region_CreateRequest_OptionsEntry_descriptor =
internal_static_greptime_v1_region_CreateRequest_descriptor.getNestedTypes().get(0);
internal_static_greptime_v1_region_CreateRequest_OptionsEntry_fieldAccessorTable = new
@@ -33261,6 +33527,7 @@ java.lang.String defaultValue);
new java.lang.String[] { "RegionIds", });
io.greptime.v1.Common.getDescriptor();
io.greptime.v1.Ddl.getDescriptor();
greptime.v1.meta.Route.getDescriptor();
io.greptime.v1.RowData.getDescriptor();
}