http://git-wip-us.apache.org/repos/asf/calcite/blob/a63639b1/avatica/src/main/java/org/apache/calcite/avatica/proto/Requests.java ---------------------------------------------------------------------- diff --git a/avatica/src/main/java/org/apache/calcite/avatica/proto/Requests.java b/avatica/src/main/java/org/apache/calcite/avatica/proto/Requests.java index bdcb140..00b8623 100644 --- a/avatica/src/main/java/org/apache/calcite/avatica/proto/Requests.java +++ b/avatica/src/main/java/org/apache/calcite/avatica/proto/Requests.java @@ -27,6 +27,16 @@ package org.apache.calcite.avatica.proto; public interface CatalogsRequestOrBuilder extends // @@protoc_insertion_point(interface_extends:CatalogsRequest) com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string connection_id = 1;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 1;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code CatalogsRequest} @@ -44,6 +54,7 @@ package org.apache.calcite.avatica.proto; super(builder); } private CatalogsRequest() { + connectionId_ = ""; } @java.lang.Override @@ -56,6 +67,7 @@ package org.apache.calcite.avatica.proto; com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { this(); + int mutable_bitField0_ = 0; try { boolean done = false; while (!done) { @@ -70,6 +82,12 @@ package org.apache.calcite.avatica.proto; } break; } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -108,6 +126,42 @@ package org.apache.calcite.avatica.proto; return PARSER; } + public static final int CONNECTION_ID_FIELD_NUMBER = 1; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -121,6 +175,9 @@ package org.apache.calcite.avatica.proto; public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { getSerializedSize(); + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(1, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -129,6 +186,10 @@ package org.apache.calcite.avatica.proto; if (size != -1) return size; size = 0; + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -239,6 +300,8 @@ package org.apache.calcite.avatica.proto; } public Builder clear() { super.clear(); + connectionId_ = ""; + return this; } @@ -261,6 +324,7 @@ package org.apache.calcite.avatica.proto; public org.apache.calcite.avatica.proto.Requests.CatalogsRequest buildPartial() { org.apache.calcite.avatica.proto.Requests.CatalogsRequest result = new org.apache.calcite.avatica.proto.Requests.CatalogsRequest(this); + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -276,6 +340,10 @@ package org.apache.calcite.avatica.proto; public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.CatalogsRequest other) { if (other == org.apache.calcite.avatica.proto.Requests.CatalogsRequest.getDefaultInstance()) return this; + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -301,6 +369,76 @@ package org.apache.calcite.avatica.proto; } return this; } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -333,6 +471,16 @@ package org.apache.calcite.avatica.proto; public interface DatabasePropertyRequestOrBuilder extends // @@protoc_insertion_point(interface_extends:DatabasePropertyRequest) com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string connection_id = 1;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 1;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code DatabasePropertyRequest} @@ -350,6 +498,7 @@ package org.apache.calcite.avatica.proto; super(builder); } private DatabasePropertyRequest() { + connectionId_ = ""; } @java.lang.Override @@ -362,6 +511,7 @@ package org.apache.calcite.avatica.proto; com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { this(); + int mutable_bitField0_ = 0; try { boolean done = false; while (!done) { @@ -376,6 +526,12 @@ package org.apache.calcite.avatica.proto; } break; } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -414,6 +570,42 @@ package org.apache.calcite.avatica.proto; return PARSER; } + public static final int CONNECTION_ID_FIELD_NUMBER = 1; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -427,6 +619,9 @@ package org.apache.calcite.avatica.proto; public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { getSerializedSize(); + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(1, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -435,6 +630,10 @@ package org.apache.calcite.avatica.proto; if (size != -1) return size; size = 0; + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -545,6 +744,8 @@ package org.apache.calcite.avatica.proto; } public Builder clear() { super.clear(); + connectionId_ = ""; + return this; } @@ -567,6 +768,7 @@ package org.apache.calcite.avatica.proto; public org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest buildPartial() { org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest result = new org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest(this); + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -582,6 +784,10 @@ package org.apache.calcite.avatica.proto; public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest other) { if (other == org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest.getDefaultInstance()) return this; + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -607,41 +813,111 @@ package org.apache.calcite.avatica.proto; } return this; } - public final Builder setUnknownFields( - final com.google.protobuf.UnknownFieldSet unknownFields) { - return this; - } - public final Builder mergeUnknownFields( - final com.google.protobuf.UnknownFieldSet unknownFields) { - return this; + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } } - - - // @@protoc_insertion_point(builder_scope:DatabasePropertyRequest) - } - - // @@protoc_insertion_point(class_scope:DatabasePropertyRequest) - private static final org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest defaultInstance;static { - defaultInstance = new org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest(); - } - - public static org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest getDefaultInstance() { - return defaultInstance; - } - - public org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest getDefaultInstanceForType() { - return defaultInstance; - } - - } - - public interface SchemasRequestOrBuilder extends - // @@protoc_insertion_point(interface_extends:SchemasRequest) - com.google.protobuf.MessageOrBuilder { - - /** - * <code>optional string catalog = 1;</code> + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + + // @@protoc_insertion_point(builder_scope:DatabasePropertyRequest) + } + + // @@protoc_insertion_point(class_scope:DatabasePropertyRequest) + private static final org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest defaultInstance;static { + defaultInstance = new org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest(); + } + + public static org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest getDefaultInstance() { + return defaultInstance; + } + + public org.apache.calcite.avatica.proto.Requests.DatabasePropertyRequest getDefaultInstanceForType() { + return defaultInstance; + } + + } + + public interface SchemasRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:SchemasRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string catalog = 1;</code> */ java.lang.String getCatalog(); /** @@ -659,6 +935,16 @@ package org.apache.calcite.avatica.proto; */ com.google.protobuf.ByteString getSchemaPatternBytes(); + + /** + * <code>optional string connection_id = 3;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 3;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code SchemasRequest} @@ -678,6 +964,7 @@ package org.apache.calcite.avatica.proto; private SchemasRequest() { catalog_ = ""; schemaPattern_ = ""; + connectionId_ = ""; } @java.lang.Override @@ -717,6 +1004,12 @@ package org.apache.calcite.avatica.proto; schemaPattern_ = bs; break; } + case 26: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -827,6 +1120,42 @@ package org.apache.calcite.avatica.proto; } } + public static final int CONNECTION_ID_FIELD_NUMBER = 3; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 3;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 3;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -846,6 +1175,9 @@ package org.apache.calcite.avatica.proto; if (!getSchemaPatternBytes().isEmpty()) { output.writeBytes(2, getSchemaPatternBytes()); } + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(3, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -862,6 +1194,10 @@ package org.apache.calcite.avatica.proto; size += com.google.protobuf.CodedOutputStream .computeBytesSize(2, getSchemaPatternBytes()); } + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(3, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -976,6 +1312,8 @@ package org.apache.calcite.avatica.proto; schemaPattern_ = ""; + connectionId_ = ""; + return this; } @@ -1000,6 +1338,7 @@ package org.apache.calcite.avatica.proto; org.apache.calcite.avatica.proto.Requests.SchemasRequest result = new org.apache.calcite.avatica.proto.Requests.SchemasRequest(this); result.catalog_ = catalog_; result.schemaPattern_ = schemaPattern_; + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -1023,6 +1362,10 @@ package org.apache.calcite.avatica.proto; schemaPattern_ = other.schemaPattern_; onChanged(); } + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -1188,6 +1531,76 @@ package org.apache.calcite.avatica.proto; onChanged(); return this; } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 3;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 3;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 3;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 3;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 3;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -1278,6 +1691,16 @@ package org.apache.calcite.avatica.proto; * </pre> */ boolean getHasTypeList(); + + /** + * <code>optional string connection_id = 7;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 7;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code TablesRequest} @@ -1301,6 +1724,7 @@ package org.apache.calcite.avatica.proto; tableNamePattern_ = ""; typeList_ = com.google.protobuf.LazyStringArrayList.EMPTY; hasTypeList_ = false; + connectionId_ = ""; } @java.lang.Override @@ -1360,6 +1784,12 @@ package org.apache.calcite.avatica.proto; hasTypeList_ = input.readBool(); break; } + case 58: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -1552,23 +1982,59 @@ package org.apache.calcite.avatica.proto; return hasTypeList_; } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (!getCatalogBytes().isEmpty()) { - output.writeBytes(1, getCatalogBytes()); + public static final int CONNECTION_ID_FIELD_NUMBER = 7; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 7;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; } - if (!getSchemaPatternBytes().isEmpty()) { + } + /** + * <code>optional string connection_id = 7;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (!getCatalogBytes().isEmpty()) { + output.writeBytes(1, getCatalogBytes()); + } + if (!getSchemaPatternBytes().isEmpty()) { output.writeBytes(2, getSchemaPatternBytes()); } if (!getTableNamePatternBytes().isEmpty()) { @@ -1580,6 +2046,9 @@ package org.apache.calcite.avatica.proto; if (hasTypeList_ != false) { output.writeBool(6, hasTypeList_); } + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(7, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -1613,6 +2082,10 @@ package org.apache.calcite.avatica.proto; size += com.google.protobuf.CodedOutputStream .computeBoolSize(6, hasTypeList_); } + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(7, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -1734,6 +2207,8 @@ package org.apache.calcite.avatica.proto; bitField0_ = (bitField0_ & ~0x00000008); hasTypeList_ = false; + connectionId_ = ""; + return this; } @@ -1767,6 +2242,7 @@ package org.apache.calcite.avatica.proto; } result.typeList_ = typeList_; result.hasTypeList_ = hasTypeList_; + result.connectionId_ = connectionId_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1808,6 +2284,10 @@ package org.apache.calcite.avatica.proto; if (other.getHasTypeList() != false) { setHasTypeList(other.getHasTypeList()); } + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -2175,6 +2655,76 @@ package org.apache.calcite.avatica.proto; onChanged(); return this; } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 7;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 7;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 7;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 7;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 7;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -2207,6 +2757,16 @@ package org.apache.calcite.avatica.proto; public interface TableTypesRequestOrBuilder extends // @@protoc_insertion_point(interface_extends:TableTypesRequest) com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string connection_id = 1;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 1;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code TableTypesRequest} @@ -2224,6 +2784,7 @@ package org.apache.calcite.avatica.proto; super(builder); } private TableTypesRequest() { + connectionId_ = ""; } @java.lang.Override @@ -2236,6 +2797,7 @@ package org.apache.calcite.avatica.proto; com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { this(); + int mutable_bitField0_ = 0; try { boolean done = false; while (!done) { @@ -2250,6 +2812,12 @@ package org.apache.calcite.avatica.proto; } break; } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -2288,6 +2856,42 @@ package org.apache.calcite.avatica.proto; return PARSER; } + public static final int CONNECTION_ID_FIELD_NUMBER = 1; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -2301,6 +2905,9 @@ package org.apache.calcite.avatica.proto; public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { getSerializedSize(); + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(1, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -2309,6 +2916,10 @@ package org.apache.calcite.avatica.proto; if (size != -1) return size; size = 0; + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -2419,6 +3030,8 @@ package org.apache.calcite.avatica.proto; } public Builder clear() { super.clear(); + connectionId_ = ""; + return this; } @@ -2441,6 +3054,7 @@ package org.apache.calcite.avatica.proto; public org.apache.calcite.avatica.proto.Requests.TableTypesRequest buildPartial() { org.apache.calcite.avatica.proto.Requests.TableTypesRequest result = new org.apache.calcite.avatica.proto.Requests.TableTypesRequest(this); + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -2456,6 +3070,10 @@ package org.apache.calcite.avatica.proto; public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.TableTypesRequest other) { if (other == org.apache.calcite.avatica.proto.Requests.TableTypesRequest.getDefaultInstance()) return this; + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -2481,6 +3099,76 @@ package org.apache.calcite.avatica.proto; } return this; } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -2553,13 +3241,23 @@ package org.apache.calcite.avatica.proto; */ com.google.protobuf.ByteString getColumnNamePatternBytes(); - } - /** - * Protobuf type {@code ColumnsRequest} - * - * <pre> - * Request for Meta#getColumns(String, org.apache.calcite.avatica.Meta.Pat, - * org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.Pat). + + /** + * <code>optional string connection_id = 5;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 5;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); + } + /** + * Protobuf type {@code ColumnsRequest} + * + * <pre> + * Request for Meta#getColumns(String, org.apache.calcite.avatica.Meta.Pat, + * org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.Pat). * </pre> */ public static final class ColumnsRequest extends @@ -2575,6 +3273,7 @@ package org.apache.calcite.avatica.proto; schemaPattern_ = ""; tableNamePattern_ = ""; columnNamePattern_ = ""; + connectionId_ = ""; } @java.lang.Override @@ -2626,6 +3325,12 @@ package org.apache.calcite.avatica.proto; columnNamePattern_ = bs; break; } + case 42: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -2808,6 +3513,42 @@ package org.apache.calcite.avatica.proto; } } + public static final int CONNECTION_ID_FIELD_NUMBER = 5; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 5;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 5;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -2833,6 +3574,9 @@ package org.apache.calcite.avatica.proto; if (!getColumnNamePatternBytes().isEmpty()) { output.writeBytes(4, getColumnNamePatternBytes()); } + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(5, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -2857,6 +3601,10 @@ package org.apache.calcite.avatica.proto; size += com.google.protobuf.CodedOutputStream .computeBytesSize(4, getColumnNamePatternBytes()); } + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(5, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -2976,6 +3724,8 @@ package org.apache.calcite.avatica.proto; columnNamePattern_ = ""; + connectionId_ = ""; + return this; } @@ -3002,6 +3752,7 @@ package org.apache.calcite.avatica.proto; result.schemaPattern_ = schemaPattern_; result.tableNamePattern_ = tableNamePattern_; result.columnNamePattern_ = columnNamePattern_; + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -3033,6 +3784,10 @@ package org.apache.calcite.avatica.proto; columnNamePattern_ = other.columnNamePattern_; onChanged(); } + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -3338,6 +4093,76 @@ package org.apache.calcite.avatica.proto; onChanged(); return this; } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 5;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 5;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 5;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 5;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 5;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -3370,6 +4195,16 @@ package org.apache.calcite.avatica.proto; public interface TypeInfoRequestOrBuilder extends // @@protoc_insertion_point(interface_extends:TypeInfoRequest) com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string connection_id = 1;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 1;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); } /** * Protobuf type {@code TypeInfoRequest} @@ -3387,6 +4222,7 @@ package org.apache.calcite.avatica.proto; super(builder); } private TypeInfoRequest() { + connectionId_ = ""; } @java.lang.Override @@ -3399,6 +4235,7 @@ package org.apache.calcite.avatica.proto; com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { this(); + int mutable_bitField0_ = 0; try { boolean done = false; while (!done) { @@ -3413,6 +4250,12 @@ package org.apache.calcite.avatica.proto; } break; } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -3451,6 +4294,42 @@ package org.apache.calcite.avatica.proto; return PARSER; } + public static final int CONNECTION_ID_FIELD_NUMBER = 1; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -3464,6 +4343,9 @@ package org.apache.calcite.avatica.proto; public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io.IOException { getSerializedSize(); + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(1, getConnectionIdBytes()); + } } private int memoizedSerializedSize = -1; @@ -3472,6 +4354,10 @@ package org.apache.calcite.avatica.proto; if (size != -1) return size; size = 0; + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getConnectionIdBytes()); + } memoizedSerializedSize = size; return size; } @@ -3582,6 +4468,8 @@ package org.apache.calcite.avatica.proto; } public Builder clear() { super.clear(); + connectionId_ = ""; + return this; } @@ -3604,6 +4492,7 @@ package org.apache.calcite.avatica.proto; public org.apache.calcite.avatica.proto.Requests.TypeInfoRequest buildPartial() { org.apache.calcite.avatica.proto.Requests.TypeInfoRequest result = new org.apache.calcite.avatica.proto.Requests.TypeInfoRequest(this); + result.connectionId_ = connectionId_; onBuilt(); return result; } @@ -3619,6 +4508,10 @@ package org.apache.calcite.avatica.proto; public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.TypeInfoRequest other) { if (other == org.apache.calcite.avatica.proto.Requests.TypeInfoRequest.getDefaultInstance()) return this; + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } onChanged(); return this; } @@ -3644,21 +4537,91 @@ package org.apache.calcite.avatica.proto; } return this; } - public final Builder setUnknownFields( - final com.google.protobuf.UnknownFieldSet unknownFields) { - return this; - } - public final Builder mergeUnknownFields( - final com.google.protobuf.UnknownFieldSet unknownFields) { + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); return this; } - - - // @@protoc_insertion_point(builder_scope:TypeInfoRequest) - } - - // @@protoc_insertion_point(class_scope:TypeInfoRequest) + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + + // @@protoc_insertion_point(builder_scope:TypeInfoRequest) + } + + // @@protoc_insertion_point(class_scope:TypeInfoRequest) private static final org.apache.calcite.avatica.proto.Requests.TypeInfoRequest defaultInstance;static { defaultInstance = new org.apache.calcite.avatica.proto.Requests.TypeInfoRequest(); } @@ -5751,7 +6714,462 @@ package org.apache.calcite.avatica.proto; }; @java.lang.Override - public com.google.protobuf.Parser<CreateStatementRequest> getParserForType() { + public com.google.protobuf.Parser<CreateStatementRequest> getParserForType() { + return PARSER; + } + + public static final int CONNECTION_ID_FIELD_NUMBER = 1; + private java.lang.Object connectionId_; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (!getConnectionIdBytes().isEmpty()) { + output.writeBytes(1, getConnectionIdBytes()); + } + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (!getConnectionIdBytes().isEmpty()) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, getConnectionIdBytes()); + } + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + com.google.protobuf.ByteString data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return new Builder(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.calcite.avatica.proto.Requests.CreateStatementRequest prototype) { + return newBuilder().mergeFrom(prototype); + } + public Builder toBuilder() { return newBuilder(this); } + + @java.lang.Override + protected Builder newBuilderForType( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + Builder builder = new Builder(parent); + return builder; + } + /** + * Protobuf type {@code CreateStatementRequest} + * + * <pre> + * Request for Meta#createStatement(Meta.ConnectionHandle) + * </pre> + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> implements + // @@protoc_insertion_point(builder_implements:CreateStatementRequest) + org.apache.calcite.avatica.proto.Requests.CreateStatementRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.class, org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.Builder.class); + } + + // Construct using org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.newBuilder() + private Builder() { + maybeForceBuilderInitialization(); + } + + private Builder( + com.google.protobuf.GeneratedMessage.BuilderParent parent) { + super(parent); + maybeForceBuilderInitialization(); + } + private void maybeForceBuilderInitialization() { + if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { + } + } + public Builder clear() { + super.clear(); + connectionId_ = ""; + + return this; + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_descriptor; + } + + public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstanceForType() { + return org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.getDefaultInstance(); + } + + public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest build() { + org.apache.calcite.avatica.proto.Requests.CreateStatementRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest buildPartial() { + org.apache.calcite.avatica.proto.Requests.CreateStatementRequest result = new org.apache.calcite.avatica.proto.Requests.CreateStatementRequest(this); + result.connectionId_ = connectionId_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.calcite.avatica.proto.Requests.CreateStatementRequest) { + return mergeFrom((org.apache.calcite.avatica.proto.Requests.CreateStatementRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.CreateStatementRequest other) { + if (other == org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.getDefaultInstance()) return this; + if (!other.getConnectionId().isEmpty()) { + connectionId_ = other.connectionId_; + onChanged(); + } + onChanged(); + return this; + } + + public final boolean isInitialized() { + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.calcite.avatica.proto.Requests.CreateStatementRequest) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + + private java.lang.Object connectionId_ = ""; + /** + * <code>optional string connection_id = 1;</code> + */ + public java.lang.String getConnectionId() { + java.lang.Object ref = connectionId_; + if (!(ref instanceof java.lang.String)) { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + connectionId_ = s; + } + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public com.google.protobuf.ByteString + getConnectionIdBytes() { + java.lang.Object ref = connectionId_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + connectionId_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionId( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder clearConnectionId() { + + connectionId_ = getDefaultInstance().getConnectionId(); + onChanged(); + return this; + } + /** + * <code>optional string connection_id = 1;</code> + */ + public Builder setConnectionIdBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + + connectionId_ = value; + onChanged(); + return this; + } + public final Builder setUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + public final Builder mergeUnknownFields( + final com.google.protobuf.UnknownFieldSet unknownFields) { + return this; + } + + + // @@protoc_insertion_point(builder_scope:CreateStatementRequest) + } + + // @@protoc_insertion_point(class_scope:CreateStatementRequest) + private static final org.apache.calcite.avatica.proto.Requests.CreateStatementRequest defaultInstance;static { + defaultInstance = new org.apache.calcite.avatica.proto.Requests.CreateStatementRequest(); + } + + public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstance() { + return defaultInstance; + } + + public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstanceForType() { + return defaultInstance; + } + + } + + public interface CloseStatementRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:CloseStatementRequest) + com.google.protobuf.MessageOrBuilder { + + /** + * <code>optional string connection_id = 1;</code> + */ + java.lang.String getConnectionId(); + /** + * <code>optional string connection_id = 1;</code> + */ + com.google.protobuf.ByteString + getConnectionIdBytes(); + + /** + * <code>optional uint32 statement_id = 2;</code> + */ + int getStatementId(); + } + /** + * Protobuf type {@code CloseStatementRequest} + * + * <pre> + * Request for Meta#closeStatement(Meta.StatementHandle) + * </pre> + */ + public static final class CloseStatementRequest extends + com.google.protobuf.GeneratedMessage implements + // @@protoc_insertion_point(message_implements:CloseStatementRequest) + CloseStatementRequestOrBuilder { + // Use CloseStatementRequest.newBuilder() to construct. + private CloseStatementRequest(com.google.protobuf.GeneratedMessage.Builder builder) { + super(builder); + } + private CloseStatementRequest() { + connectionId_ = ""; + statementId_ = 0; + } + + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return com.google.protobuf.UnknownFieldSet.getDefaultInstance(); + } + private CloseStatementRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + this(); + int mutable_bitField0_ = 0; + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!input.skipField(tag)) { + done = true; + } + break; + } + case 10: { + com.google.protobuf.ByteString bs = input.readBytes(); + + connectionId_ = bs; + break; + } + case 16: { + + statementId_ = input.readUInt32(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.class, org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.Builder.class); + } + + public static final com.google.protobuf.Parser<CloseStatementRequest> PARSER = + new com.google.protobuf.AbstractParser<CloseStatementRequest>() { + public CloseStatementRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new CloseStatementRequest(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<CloseStatementRequest> getParserForType() { return PARSER; } @@ -5791,6 +7209,15 @@ package org.apache.calcite.avatica.proto; } } + public static final int STATEMENT_ID_FIELD_NUMBER = 2; + private int statementId_; + /** + * <code>optional uint32 statement_id = 2;</code> + */ + public int getStatementId() { + return statementId_; + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -5807,6 +7234,9 @@ package org.apache.calcite.avatica.proto; if (!getConnectionIdBytes().isEmpty()) { output.writeBytes(1, getConnectionIdBytes()); } + if (statementId_ != 0) { + output.writeUInt32(2, statementId_); + } } private int memoizedSerializedSize = -1; @@ -5819,58 +7249,62 @@ package org.apache.calcite.avatica.proto; size += com.google.protobuf.CodedOutputStream .computeBytesSize(1, getConnectionIdBytes()); } + if (statementId_ != 0) { + size += com.google.protobuf.CodedOutputStream + .computeUInt32Size(2, statementId_); + } memoizedSerializedSize = size; return size; } private static final long serialVersionUID = 0L; - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom(byte[] data) + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom(java.io.InputStream input) + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom(java.io.InputStream input) throws java.io.IOException { return PARSER.parseFrom(input); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return PARSER.parseFrom(input, extensionRegistry); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseDelimitedFrom(java.io.InputStream input) + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException { return PARSER.parseDelimitedFrom(input); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseDelimitedFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseDelimitedFrom( java.io.InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return PARSER.parseDelimitedFrom(input, extensionRegistry); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( com.google.protobuf.CodedInputStream input) throws java.io.IOException { return PARSER.parseFrom(input); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parseFrom( + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parseFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { @@ -5879,7 +7313,7 @@ package org.apache.calcite.avatica.proto; public static Builder newBuilder() { return new Builder(); } public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(org.apache.calcite.avatica.proto.Requests.CreateStatementRequest prototype) { + public static Builder newBuilder(org.apache.calcite.avatica.proto.Requests.CloseStatementRequest prototype) { return newBuilder().mergeFrom(prototype); } public Builder toBuilder() { return newBuilder(this); } @@ -5891,29 +7325,29 @@ package org.apache.calcite.avatica.proto; return builder; } /** - * Protobuf type {@code CreateStatementRequest} + * Protobuf type {@code CloseStatementRequest} * * <pre> - * Request for Meta#createStatement(Meta.ConnectionHandle) + * Request for Meta#closeStatement(Meta.StatementHandle) * </pre> */ public static final class Builder extends com.google.protobuf.GeneratedMessage.Builder<Builder> implements - // @@protoc_insertion_point(builder_implements:CreateStatementRequest) - org.apache.calcite.avatica.proto.Requests.CreateStatementRequestOrBuilder { + // @@protoc_insertion_point(builder_implements:CloseStatementRequest) + org.apache.calcite.avatica.proto.Requests.CloseStatementRequestOrBuilder { public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_descriptor; + return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_descriptor; } protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_fieldAccessorTable + return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.class, org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.Builder.class); + org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.class, org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.Builder.class); } - // Construct using org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.newBuilder() + // Construct using org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.newBuilder() private Builder() { maybeForceBuilderInitialization(); } @@ -5931,48 +7365,54 @@ package org.apache.calcite.avatica.proto; super.clear(); connectionId_ = ""; + statementId_ = 0; + return this; } public com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { - return org.apache.calcite.avatica.proto.Requests.internal_static_CreateStatementRequest_descriptor; + return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_descriptor; } - public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstanceForType() { - return org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.getDefaultInstance(); + public org.apache.calcite.avatica.proto.Requests.CloseStatementRequest getDefaultInstanceForType() { + return org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.getDefaultInstance(); } - public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest build() { - org.apache.calcite.avatica.proto.Requests.CreateStatementRequest result = buildPartial(); + public org.apache.calcite.avatica.proto.Requests.CloseStatementRequest build() { + org.apache.calcite.avatica.proto.Requests.CloseStatementRequest result = buildPartial(); if (!result.isInitialized()) { throw newUninitializedMessageException(result); } return result; } - public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest buildPartial() { - org.apache.calcite.avatica.proto.Requests.CreateStatementRequest result = new org.apache.calcite.avatica.proto.Requests.CreateStatementRequest(this); + public org.apache.calcite.avatica.proto.Requests.CloseStatementRequest buildPartial() { + org.apache.calcite.avatica.proto.Requests.CloseStatementRequest result = new org.apache.calcite.avatica.proto.Requests.CloseStatementRequest(this); result.connectionId_ = connectionId_; + result.statementId_ = statementId_; onBuilt(); return result; } public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof org.apache.calcite.avatica.proto.Requests.CreateStatementRequest) { - return mergeFrom((org.apache.calcite.avatica.proto.Requests.CreateStatementRequest)other); + if (other instanceof org.apache.calcite.avatica.proto.Requests.CloseStatementRequest) { + return mergeFrom((org.apache.calcite.avatica.proto.Requests.CloseStatementRequest)other); } else { super.mergeFrom(other); return this; } } - public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.CreateStatementRequest other) { - if (other == org.apache.calcite.avatica.proto.Requests.CreateStatementRequest.getDefaultInstance()) return this; + public Builder mergeFrom(org.apache.calcite.avatica.proto.Requests.CloseStatementRequest other) { + if (other == org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.getDefaultInstance()) return this; if (!other.getConnectionId().isEmpty()) { connectionId_ = other.connectionId_; onChanged(); } + if (other.getStatementId() != 0) { + setStatementId(other.getStatementId()); + } onChanged(); return this; } @@ -5985,11 +7425,11 @@ package org.apache.calcite.avatica.proto; com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { - org.apache.calcite.avatica.proto.Requests.CreateStatementRequest parsedMessage = null; + org.apache.calcite.avatica.proto.Requests.CloseStatementRequest parsedMessage = null; try { parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); } catch (com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (org.apache.calcite.avatica.proto.Requests.CreateStatementRequest) e.getUnfinishedMessage(); + parsedMessage = (org.apache.calcite.avatica.proto.Requests.CloseStatementRequest) e.getUnfinishedMessage(); throw e; } finally { if (parsedMessage != null) { @@ -6068,6 +7508,32 @@ package org.apache.calcite.avatica.proto; onChanged(); return this; } + + private int statementId_ ; + /** + * <code>optional uint32 statement_id = 2;</code> + */ + public int getStatementId() { + return statementId_; + } + /** + * <code>optional uint32 statement_id = 2;</code> + */ + public Builder setStatementId(int value) { + + statementId_ = value; + onChanged(); + return this; + } + /** + * <code>optional uint32 statement_id = 2;</code> + */ + public Builder clearStatementId() { + + statementId_ = 0; + onChanged(); + return this; + } public final Builder setUnknownFields( final com.google.protobuf.UnknownFieldSet unknownFields) { return this; @@ -6079,26 +7545,26 @@ package org.apache.calcite.avatica.proto; } - // @@protoc_insertion_point(builder_scope:CreateStatementRequest) + // @@protoc_insertion_point(builder_scope:CloseStatementRequest) } - // @@protoc_insertion_point(class_scope:CreateStatementRequest) - private static final org.apache.calcite.avatica.proto.Requests.CreateStatementRequest defaultInstance;static { - defaultInstance = new org.apache.calcite.avatica.proto.Requests.CreateStatementRequest(); + // @@protoc_insertion_point(class_scope:CloseStatementRequest) + private static final org.apache.calcite.avatica.proto.Requests.CloseStatementRequest defaultInstance;static { + defaultInstance = new org.apache.calcite.avatica.proto.Requests.CloseStatementRequest(); } - public static org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstance() { + public static org.apache.calcite.avatica.proto.Requests.CloseStatementRequest getDefaultInstance() { return defaultInstance; } - public org.apache.calcite.avatica.proto.Requests.CreateStatementRequest getDefaultInstanceForType() { + public org.apache.calcite.avatica.proto.Requests.CloseStatementRequest getDefaultInstanceForType() { return defaultInstance; } } - public interface CloseStatementRequestOrBuilder extends - // @@protoc_insertion_point(interface_extends:CloseStatementRequest) + public interface OpenConnectionRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:OpenConnectionRequest) com.google.protobuf.MessageOrBuilder { /** @@ -6112,28 +7578,28 @@ package org.apache.calcite.avatica.proto; getConnectionIdBytes(); /** - * <code>optional uint32 statement_id = 2;</code> + * <code>map<string, string> info = 2;</code> */ - int getStatementId(); + java.util.Map<java.lang.String, java.lang.String> + getInfo(); } /** - * Protobuf type {@code CloseStatementRequest} + * Protobuf type {@code OpenConnectionRequest} * * <pre> - * Request for Meta#closeStatement(Meta.StatementHandle) + * Request for Meta#openConnection(Meta.ConnectionHandle, Map<String, String>) * </pre> */ - public static final class CloseStatementRequest extends + public static final class OpenConnectionRequest extends com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:CloseStatementRequest) - CloseStatementRequestOrBuilder { - // Use CloseStatementRequest.newBuilder() to construct. - private CloseStatementRequest(com.google.protobuf.GeneratedMessage.Builder builder) { + // @@protoc_insertion_point(message_implements:OpenConnectionRequest) + OpenConnectionRequestOrBuilder { + // Use OpenConnectionRequest.newBuilder() to construct. + private OpenConnectionRequest(com.google.protobuf.GeneratedMessage.Builder builder) { super(builder); } - private CloseStatementRequest() { + private OpenConnectionRequest() { connectionId_ = ""; - statementId_ = 0; } @java.lang.Override @@ -6141,7 +7607,7 @@ package org.apache.calcite.avatica.proto; getUnknownFields() { return com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - private CloseStatementRequest( + private OpenConnectionRequest( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { @@ -6167,9 +7633,16 @@ package org.apache.calcite.avatica.proto; connectionId_ = bs; break; } - case 16: { - - statementId_ = input.readUInt32(); + case 18: { + if (!((mutable_bitField0_ & 0x00000002) == 0x00000002)) { + info_ = com.google.protobuf.MapField.newMapField( + infoDefaultEntry); + mutable_bitField0_ |= 0x00000002; + } + com.google.protobuf.MapEntry<java.lang.String, java.lang.String> + info = input.readMessage( + infoDefaultEntry.getParserForType(), extensionRegistry); + info_.getMutableMap().put(info.getKey(), info.getValue()); break; } } @@ -6185,31 +7658,43 @@ package org.apache.calcite.avatica.proto; } public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_descriptor; + return org.apache.calcite.avatica.proto.Requests.internal_static_OpenConnectionRequest_descriptor; } + @SuppressWarnings({"rawtypes"}) + protected com.google.protobuf.MapField internalGetMapField( + int number) { + switch (number) { + case 2: + return info_; + default: + throw new RuntimeException( + "Invalid map field number: " + number); + } + } protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.calcite.avatica.proto.Requests.internal_static_CloseStatementRequest_fieldAccessorTable + return org.apache.calcite.avatica.proto.Requests.internal_static_OpenConnectionRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.class, org.apache.calcite.avatica.proto.Requests.CloseStatementRequest.Builder.class); + org.apache.calcite.avatica.proto.Requests.OpenConnectionRequest.class, org.apache.calcite.avatica.proto.Requests.OpenConnectionRequest.Builder.class); } - public static final com.google.protobuf.Parser<CloseStatementRequest> PARSER = - new com.google.protobuf.AbstractParser<CloseStatementRequest>() { - public CloseStatementRequest parsePartialFrom( + public static final com.google.protobuf.Parser<OpenConnectionRequest> PARSER = + new com.google.protobuf.AbstractParser<OpenConnectionRequest>() { + public OpenConnectionRequest parsePartialFrom( com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException { - return new CloseStatementRequest(input, extensionRegistry); + return new OpenConnectionRequest(input, extensionRegistry); } }; @java.lang.Override - public com.google.protobuf.Parser<CloseStatementRequest> getParserForType() { + public com.google.
<TRUNCATED>
