You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@calcite.apache.org by el...@apache.org on 2015/12/02 19:06:08 UTC
[2/3] calcite git commit: [CALCITE-989] Add server's address in each
response
http://git-wip-us.apache.org/repos/asf/calcite/blob/3be816f4/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java
----------------------------------------------------------------------
diff --git a/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java b/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java
index 9392326..f364021 100644
--- a/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java
+++ b/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java
@@ -82,6 +82,31 @@ package org.apache.calcite.avatica.proto;
* </pre>
*/
long getUpdateCount();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code ResultSetResponse}
@@ -176,6 +201,19 @@ package org.apache.calcite.avatica.proto;
updateCount_ = input.readUInt64();
break;
}
+ case 58: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -307,6 +345,39 @@ package org.apache.calcite.avatica.proto;
return updateCount_;
}
+ public static final int METADATA_FIELD_NUMBER = 7;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -337,6 +408,9 @@ package org.apache.calcite.avatica.proto;
if (updateCount_ != 0L) {
output.writeUInt64(6, updateCount_);
}
+ if (metadata_ != null) {
+ output.writeMessage(7, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -367,6 +441,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeUInt64Size(6, updateCount_);
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(7, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -502,6 +580,12 @@ package org.apache.calcite.avatica.proto;
}
updateCount_ = 0L;
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -538,6 +622,11 @@ package org.apache.calcite.avatica.proto;
result.firstFrame_ = firstFrameBuilder_.build();
}
result.updateCount_ = updateCount_;
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -572,6 +661,9 @@ package org.apache.calcite.avatica.proto;
if (other.getUpdateCount() != 0L) {
setUpdateCount(other.getUpdateCount());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -990,6 +1082,159 @@ package org.apache.calcite.avatica.proto;
onChanged();
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 7;</code>
+ *
+ * <pre>
+ * with no signature nor other data.
+ * </pre>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -1084,6 +1329,19 @@ package org.apache.calcite.avatica.proto;
* </pre>
*/
boolean getMissingStatement();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code ExecuteResponse}
@@ -1142,6 +1400,19 @@ package org.apache.calcite.avatica.proto;
missingStatement_ = input.readBool();
break;
}
+ case 26: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -1218,6 +1489,27 @@ package org.apache.calcite.avatica.proto;
return missingStatement_;
}
+ public static final int METADATA_FIELD_NUMBER = 3;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -1236,6 +1528,9 @@ package org.apache.calcite.avatica.proto;
if (missingStatement_ != false) {
output.writeBool(2, missingStatement_);
}
+ if (metadata_ != null) {
+ output.writeMessage(3, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -1251,6 +1546,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(2, missingStatement_);
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(3, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -1375,6 +1674,12 @@ package org.apache.calcite.avatica.proto;
}
missingStatement_ = false;
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -1409,6 +1714,11 @@ package org.apache.calcite.avatica.proto;
result.results_ = resultsBuilder_.build();
}
result.missingStatement_ = missingStatement_;
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@@ -1454,6 +1764,9 @@ package org.apache.calcite.avatica.proto;
if (other.getMissingStatement() != false) {
setMissingStatement(other.getMissingStatement());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -1758,6 +2071,123 @@ package org.apache.calcite.avatica.proto;
onChanged();
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -1832,6 +2262,19 @@ package org.apache.calcite.avatica.proto;
* <code>optional .StatementHandle statement = 1;</code>
*/
org.apache.calcite.avatica.proto.Common.StatementHandleOrBuilder getStatementOrBuilder();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code PrepareResponse}
@@ -1888,6 +2331,19 @@ package org.apache.calcite.avatica.proto;
break;
}
+ case 18: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -1933,13 +2389,34 @@ package org.apache.calcite.avatica.proto;
return getStatement();
}
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized == 1) return true;
- if (isInitialized == 0) return false;
-
- memoizedIsInitialized = 1;
+ public static final int METADATA_FIELD_NUMBER = 2;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
+ 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;
}
@@ -1948,6 +2425,9 @@ package org.apache.calcite.avatica.proto;
if (statement_ != null) {
output.writeMessage(1, getStatement());
}
+ if (metadata_ != null) {
+ output.writeMessage(2, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -1959,6 +2439,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(1, getStatement());
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(2, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -2080,6 +2564,12 @@ package org.apache.calcite.avatica.proto;
statement_ = null;
statementBuilder_ = null;
}
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -2107,6 +2597,11 @@ package org.apache.calcite.avatica.proto;
} else {
result.statement_ = statementBuilder_.build();
}
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -2125,6 +2620,9 @@ package org.apache.calcite.avatica.proto;
if (other.hasStatement()) {
mergeStatement(other.getStatement());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -2267,6 +2765,123 @@ package org.apache.calcite.avatica.proto;
}
return statementBuilder_;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -2359,6 +2974,19 @@ package org.apache.calcite.avatica.proto;
* </pre>
*/
boolean getMissingResults();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code FetchResponse}
@@ -2427,6 +3055,19 @@ package org.apache.calcite.avatica.proto;
missingResults_ = input.readBool();
break;
}
+ case 34: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -2498,6 +3139,27 @@ package org.apache.calcite.avatica.proto;
return missingResults_;
}
+ public static final int METADATA_FIELD_NUMBER = 4;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -2519,6 +3181,9 @@ package org.apache.calcite.avatica.proto;
if (missingResults_ != false) {
output.writeBool(3, missingResults_);
}
+ if (metadata_ != null) {
+ output.writeMessage(4, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -2538,6 +3203,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(3, missingResults_);
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(4, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -2663,6 +3332,12 @@ package org.apache.calcite.avatica.proto;
missingResults_ = false;
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -2692,6 +3367,11 @@ package org.apache.calcite.avatica.proto;
}
result.missingStatement_ = missingStatement_;
result.missingResults_ = missingResults_;
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -2716,6 +3396,9 @@ package org.apache.calcite.avatica.proto;
if (other.getMissingResults() != false) {
setMissingResults(other.getMissingResults());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -2934,6 +3617,123 @@ package org.apache.calcite.avatica.proto;
onChanged();
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 4;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -3010,6 +3810,19 @@ package org.apache.calcite.avatica.proto;
* <code>optional uint32 statement_id = 2;</code>
*/
int getStatementId();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code CreateStatementResponse}
@@ -3066,6 +3879,19 @@ package org.apache.calcite.avatica.proto;
statementId_ = input.readUInt32();
break;
}
+ case 26: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -3133,6 +3959,27 @@ package org.apache.calcite.avatica.proto;
return statementId_;
}
+ public static final int METADATA_FIELD_NUMBER = 3;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -3151,6 +3998,9 @@ package org.apache.calcite.avatica.proto;
if (statementId_ != 0) {
output.writeUInt32(2, statementId_);
}
+ if (metadata_ != null) {
+ output.writeMessage(3, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -3165,6 +4015,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeUInt32Size(2, statementId_);
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(3, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -3284,6 +4138,12 @@ package org.apache.calcite.avatica.proto;
statementId_ = 0;
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -3308,6 +4168,11 @@ package org.apache.calcite.avatica.proto;
org.apache.calcite.avatica.proto.Responses.CreateStatementResponse result = new org.apache.calcite.avatica.proto.Responses.CreateStatementResponse(this);
result.connectionId_ = connectionId_;
result.statementId_ = statementId_;
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -3330,6 +4195,9 @@ package org.apache.calcite.avatica.proto;
if (other.getStatementId() != 0) {
setStatementId(other.getStatementId());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -3450,21 +4318,138 @@ package org.apache.calcite.avatica.proto;
onChanged();
return this;
}
- public final Builder setUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return this;
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
}
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
- public final Builder mergeUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
}
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
- // @@protoc_insertion_point(builder_scope:CreateStatementResponse)
- }
-
- // @@protoc_insertion_point(class_scope:CreateStatementResponse)
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
+ 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:CreateStatementResponse)
+ }
+
+ // @@protoc_insertion_point(class_scope:CreateStatementResponse)
private static final org.apache.calcite.avatica.proto.Responses.CreateStatementResponse DEFAULT_INSTANCE;
static {
DEFAULT_INSTANCE = new org.apache.calcite.avatica.proto.Responses.CreateStatementResponse();
@@ -3511,6 +4496,19 @@ package org.apache.calcite.avatica.proto;
public interface CloseStatementResponseOrBuilder extends
// @@protoc_insertion_point(interface_extends:CloseStatementResponse)
com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code CloseStatementResponse}
@@ -3539,6 +4537,7 @@ package org.apache.calcite.avatica.proto;
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
this();
+ int mutable_bitField0_ = 0;
try {
boolean done = false;
while (!done) {
@@ -3553,6 +4552,19 @@ package org.apache.calcite.avatica.proto;
}
break;
}
+ case 10: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -3577,6 +4589,27 @@ package org.apache.calcite.avatica.proto;
org.apache.calcite.avatica.proto.Responses.CloseStatementResponse.class, org.apache.calcite.avatica.proto.Responses.CloseStatementResponse.Builder.class);
}
+ public static final int METADATA_FIELD_NUMBER = 1;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -3589,6 +4622,9 @@ package org.apache.calcite.avatica.proto;
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
+ if (metadata_ != null) {
+ output.writeMessage(1, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -3596,6 +4632,10 @@ package org.apache.calcite.avatica.proto;
if (size != -1) return size;
size = 0;
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -3711,6 +4751,12 @@ package org.apache.calcite.avatica.proto;
}
public Builder clear() {
super.clear();
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -3733,6 +4779,11 @@ package org.apache.calcite.avatica.proto;
public org.apache.calcite.avatica.proto.Responses.CloseStatementResponse buildPartial() {
org.apache.calcite.avatica.proto.Responses.CloseStatementResponse result = new org.apache.calcite.avatica.proto.Responses.CloseStatementResponse(this);
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -3748,6 +4799,9 @@ package org.apache.calcite.avatica.proto;
public Builder mergeFrom(org.apache.calcite.avatica.proto.Responses.CloseStatementResponse other) {
if (other == org.apache.calcite.avatica.proto.Responses.CloseStatementResponse.getDefaultInstance()) return this;
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -3773,6 +4827,123 @@ package org.apache.calcite.avatica.proto;
}
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -3834,6 +5005,19 @@ package org.apache.calcite.avatica.proto;
public interface OpenConnectionResponseOrBuilder extends
// @@protoc_insertion_point(interface_extends:OpenConnectionResponse)
com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code OpenConnectionResponse}
@@ -3862,6 +5046,7 @@ package org.apache.calcite.avatica.proto;
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
this();
+ int mutable_bitField0_ = 0;
try {
boolean done = false;
while (!done) {
@@ -3876,6 +5061,19 @@ package org.apache.calcite.avatica.proto;
}
break;
}
+ case 10: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -3900,6 +5098,27 @@ package org.apache.calcite.avatica.proto;
org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse.class, org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse.Builder.class);
}
+ public static final int METADATA_FIELD_NUMBER = 1;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -3912,6 +5131,9 @@ package org.apache.calcite.avatica.proto;
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
+ if (metadata_ != null) {
+ output.writeMessage(1, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -3919,6 +5141,10 @@ package org.apache.calcite.avatica.proto;
if (size != -1) return size;
size = 0;
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -4034,6 +5260,12 @@ package org.apache.calcite.avatica.proto;
}
public Builder clear() {
super.clear();
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -4056,6 +5288,11 @@ package org.apache.calcite.avatica.proto;
public org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse buildPartial() {
org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse result = new org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse(this);
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -4071,6 +5308,9 @@ package org.apache.calcite.avatica.proto;
public Builder mergeFrom(org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse other) {
if (other == org.apache.calcite.avatica.proto.Responses.OpenConnectionResponse.getDefaultInstance()) return this;
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -4096,6 +5336,123 @@ package org.apache.calcite.avatica.proto;
}
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -4157,6 +5514,19 @@ package org.apache.calcite.avatica.proto;
public interface CloseConnectionResponseOrBuilder extends
// @@protoc_insertion_point(interface_extends:CloseConnectionResponse)
com.google.protobuf.MessageOrBuilder {
+
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code CloseConnectionResponse}
@@ -4185,6 +5555,7 @@ package org.apache.calcite.avatica.proto;
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) {
this();
+ int mutable_bitField0_ = 0;
try {
boolean done = false;
while (!done) {
@@ -4199,6 +5570,19 @@ package org.apache.calcite.avatica.proto;
}
break;
}
+ case 10: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -4223,11 +5607,32 @@ package org.apache.calcite.avatica.proto;
org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse.class, org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse.Builder.class);
}
- private byte memoizedIsInitialized = -1;
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized == 1) return true;
- if (isInitialized == 0) return false;
+ public static final int METADATA_FIELD_NUMBER = 1;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
+ 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;
@@ -4235,6 +5640,9 @@ package org.apache.calcite.avatica.proto;
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
+ if (metadata_ != null) {
+ output.writeMessage(1, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -4242,6 +5650,10 @@ package org.apache.calcite.avatica.proto;
if (size != -1) return size;
size = 0;
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(1, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -4357,6 +5769,12 @@ package org.apache.calcite.avatica.proto;
}
public Builder clear() {
super.clear();
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -4379,6 +5797,11 @@ package org.apache.calcite.avatica.proto;
public org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse buildPartial() {
org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse result = new org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse(this);
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -4394,6 +5817,9 @@ package org.apache.calcite.avatica.proto;
public Builder mergeFrom(org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse other) {
if (other == org.apache.calcite.avatica.proto.Responses.CloseConnectionResponse.getDefaultInstance()) return this;
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -4419,6 +5845,123 @@ package org.apache.calcite.avatica.proto;
}
return this;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 1;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -4493,6 +6036,19 @@ package org.apache.calcite.avatica.proto;
* <code>optional .ConnectionProperties conn_props = 1;</code>
*/
org.apache.calcite.avatica.proto.Common.ConnectionPropertiesOrBuilder getConnPropsOrBuilder();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code ConnectionSyncResponse}
@@ -4549,6 +6105,19 @@ package org.apache.calcite.avatica.proto;
break;
}
+ case 18: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -4594,6 +6163,27 @@ package org.apache.calcite.avatica.proto;
return getConnProps();
}
+ public static final int METADATA_FIELD_NUMBER = 2;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -4609,6 +6199,9 @@ package org.apache.calcite.avatica.proto;
if (connProps_ != null) {
output.writeMessage(1, getConnProps());
}
+ if (metadata_ != null) {
+ output.writeMessage(2, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -4620,6 +6213,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(1, getConnProps());
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(2, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -4741,6 +6338,12 @@ package org.apache.calcite.avatica.proto;
connProps_ = null;
connPropsBuilder_ = null;
}
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
return this;
}
@@ -4768,6 +6371,11 @@ package org.apache.calcite.avatica.proto;
} else {
result.connProps_ = connPropsBuilder_.build();
}
+ if (metadataBuilder_ == null) {
+ result.metadata_ = metadata_;
+ } else {
+ result.metadata_ = metadataBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -4786,6 +6394,9 @@ package org.apache.calcite.avatica.proto;
if (other.hasConnProps()) {
mergeConnProps(other.getConnProps());
}
+ if (other.hasMetadata()) {
+ mergeMetadata(other.getMetadata());
+ }
onChanged();
return this;
}
@@ -4928,6 +6539,123 @@ package org.apache.calcite.avatica.proto;
}
return connPropsBuilder_;
}
+
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public boolean hasMetadata() {
+ return metadataBuilder_ != null || metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ if (metadataBuilder_ == null) {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ } else {
+ return metadataBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder setMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ metadata_ = value;
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder setMetadata(
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder builderForValue) {
+ if (metadataBuilder_ == null) {
+ metadata_ = builderForValue.build();
+ onChanged();
+ } else {
+ metadataBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder mergeMetadata(org.apache.calcite.avatica.proto.Responses.RpcMetadata value) {
+ if (metadataBuilder_ == null) {
+ if (metadata_ != null) {
+ metadata_ =
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.newBuilder(metadata_).mergeFrom(value).buildPartial();
+ } else {
+ metadata_ = value;
+ }
+ onChanged();
+ } else {
+ metadataBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public Builder clearMetadata() {
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ onChanged();
+ } else {
+ metadata_ = null;
+ metadataBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
+
+ onChanged();
+ return getMetadataFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ if (metadataBuilder_ != null) {
+ return metadataBuilder_.getMessageOrBuilder();
+ } else {
+ return metadata_ == null ?
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 2;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>
+ getMetadataFieldBuilder() {
+ if (metadataBuilder_ == null) {
+ metadataBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder>(
+ getMetadata(),
+ getParentForChildren(),
+ isClean());
+ metadata_ = null;
+ }
+ return metadataBuilder_;
+ }
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
return this;
@@ -5015,6 +6743,19 @@ package org.apache.calcite.avatica.proto;
* <code>optional .TypedValue value = 2;</code>
*/
org.apache.calcite.avatica.proto.Common.TypedValueOrBuilder getValueOrBuilder();
+
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ boolean hasMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
}
/**
* Protobuf type {@code DatabasePropertyElement}
@@ -5080,6 +6821,19 @@ package org.apache.calcite.avatica.proto;
break;
}
+ case 26: {
+ org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder subBuilder = null;
+ if (metadata_ != null) {
+ subBuilder = metadata_.toBuilder();
+ }
+ metadata_ = input.readMessage(org.apache.calcite.avatica.proto.Responses.RpcMetadata.parser(), extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(metadata_);
+ metadata_ = subBuilder.buildPartial();
+ }
+
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -5146,6 +6900,27 @@ package org.apache.calcite.avatica.proto;
return getValue();
}
+ public static final int METADATA_FIELD_NUMBER = 3;
+ private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public boolean hasMetadata() {
+ return metadata_ != null;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
+ return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
+ }
+ /**
+ * <code>optional .RpcMetadata metadata = 3;</code>
+ */
+ public org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder() {
+ return getMetadata();
+ }
+
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
byte isInitialized = memoizedIsInitialized;
@@ -5164,6 +6939,9 @@ package org.apache.calcite.avatica.proto;
if (value_ != null) {
output.writeMessage(2, getValue());
}
+ if (metadata_ != null) {
+ output.writeMessage(3, getMetadata());
+ }
}
public int getSerializedSize() {
@@ -5179,6 +6957,10 @@ package org.apache.calcite.avatica.proto;
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, getValue());
}
+ if (metadata_ != null) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(3, getMetadata());
+ }
memoizedSize = size;
return size;
}
@@ -5302,6 +7084,12 @@ package org.apache.calcite.avatica.proto;
value_ = null;
valueBuilder_ = null;
}
+ if (metadataBuilder_ == null) {
+ metadata_ = null;
+ } else {
+ metadata_ = null;
+ me
<TRUNCATED>