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 2017/04/01 20:36:32 UTC
[40/51] [partial] calcite-avatica git commit: [CALCITE-1717] Remove
Calcite code and lift avatica
http://git-wip-us.apache.org/repos/asf/calcite-avatica/blob/fc7b26c8/avatica/core/src/main/java/org/apache/calcite/avatica/proto/Responses.java
----------------------------------------------------------------------
diff --git a/avatica/core/src/main/java/org/apache/calcite/avatica/proto/Responses.java b/avatica/core/src/main/java/org/apache/calcite/avatica/proto/Responses.java
deleted file mode 100644
index 87d567d..0000000
--- a/avatica/core/src/main/java/org/apache/calcite/avatica/proto/Responses.java
+++ /dev/null
@@ -1,13962 +0,0 @@
-// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: responses.proto
-
-package org.apache.calcite.avatica.proto;
-
-public final class Responses {
- private Responses() {}
- public static void registerAllExtensions(
- com.google.protobuf.ExtensionRegistryLite registry) {
- }
-
- public static void registerAllExtensions(
- com.google.protobuf.ExtensionRegistry registry) {
- registerAllExtensions(
- (com.google.protobuf.ExtensionRegistryLite) registry);
- }
- public interface ResultSetResponseOrBuilder extends
- // @@protoc_insertion_point(interface_extends:ResultSetResponse)
- 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();
-
- /**
- * <code>optional bool own_statement = 3;</code>
- */
- boolean getOwnStatement();
-
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- boolean hasSignature();
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- org.apache.calcite.avatica.proto.Common.Signature getSignature();
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- org.apache.calcite.avatica.proto.Common.SignatureOrBuilder getSignatureOrBuilder();
-
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- boolean hasFirstFrame();
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- org.apache.calcite.avatica.proto.Common.Frame getFirstFrame();
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- org.apache.calcite.avatica.proto.Common.FrameOrBuilder getFirstFrameOrBuilder();
-
- /**
- * <pre>
- * -1 for normal result sets, else this response contains a dummy result set
- * </pre>
- *
- * <code>optional uint64 update_count = 6;</code>
- */
- long getUpdateCount();
-
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- boolean hasMetadata();
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata();
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder getMetadataOrBuilder();
- }
- /**
- * <pre>
- * Response that contains a result set.
- * </pre>
- *
- * Protobuf type {@code ResultSetResponse}
- */
- public static final class ResultSetResponse extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:ResultSetResponse)
- ResultSetResponseOrBuilder {
- // Use ResultSetResponse.newBuilder() to construct.
- private ResultSetResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private ResultSetResponse() {
- connectionId_ = "";
- statementId_ = 0;
- ownStatement_ = false;
- updateCount_ = 0L;
- }
-
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
- }
- private ResultSetResponse(
- 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: {
- java.lang.String s = input.readStringRequireUtf8();
-
- connectionId_ = s;
- break;
- }
- case 16: {
-
- statementId_ = input.readUInt32();
- break;
- }
- case 24: {
-
- ownStatement_ = input.readBool();
- break;
- }
- case 34: {
- org.apache.calcite.avatica.proto.Common.Signature.Builder subBuilder = null;
- if (signature_ != null) {
- subBuilder = signature_.toBuilder();
- }
- signature_ = input.readMessage(org.apache.calcite.avatica.proto.Common.Signature.parser(), extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(signature_);
- signature_ = subBuilder.buildPartial();
- }
-
- break;
- }
- case 42: {
- org.apache.calcite.avatica.proto.Common.Frame.Builder subBuilder = null;
- if (firstFrame_ != null) {
- subBuilder = firstFrame_.toBuilder();
- }
- firstFrame_ = input.readMessage(org.apache.calcite.avatica.proto.Common.Frame.parser(), extensionRegistry);
- if (subBuilder != null) {
- subBuilder.mergeFrom(firstFrame_);
- firstFrame_ = subBuilder.buildPartial();
- }
-
- break;
- }
- case 48: {
-
- 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) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e).setUnfinishedMessage(this);
- } finally {
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse.class, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder.class);
- }
-
- public static final int CONNECTION_ID_FIELD_NUMBER = 1;
- private volatile 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();
- 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;
- }
- }
-
- public static final int STATEMENT_ID_FIELD_NUMBER = 2;
- private int statementId_;
- /**
- * <code>optional uint32 statement_id = 2;</code>
- */
- public int getStatementId() {
- return statementId_;
- }
-
- public static final int OWN_STATEMENT_FIELD_NUMBER = 3;
- private boolean ownStatement_;
- /**
- * <code>optional bool own_statement = 3;</code>
- */
- public boolean getOwnStatement() {
- return ownStatement_;
- }
-
- public static final int SIGNATURE_FIELD_NUMBER = 4;
- private org.apache.calcite.avatica.proto.Common.Signature signature_;
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public boolean hasSignature() {
- return signature_ != null;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Signature getSignature() {
- return signature_ == null ? org.apache.calcite.avatica.proto.Common.Signature.getDefaultInstance() : signature_;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public org.apache.calcite.avatica.proto.Common.SignatureOrBuilder getSignatureOrBuilder() {
- return getSignature();
- }
-
- public static final int FIRST_FRAME_FIELD_NUMBER = 5;
- private org.apache.calcite.avatica.proto.Common.Frame firstFrame_;
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public boolean hasFirstFrame() {
- return firstFrame_ != null;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Frame getFirstFrame() {
- return firstFrame_ == null ? org.apache.calcite.avatica.proto.Common.Frame.getDefaultInstance() : firstFrame_;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public org.apache.calcite.avatica.proto.Common.FrameOrBuilder getFirstFrameOrBuilder() {
- return getFirstFrame();
- }
-
- public static final int UPDATE_COUNT_FIELD_NUMBER = 6;
- private long updateCount_;
- /**
- * <pre>
- * -1 for normal result sets, else this response contains a dummy result set
- * </pre>
- *
- * <code>optional uint64 update_count = 6;</code>
- */
- public long getUpdateCount() {
- return updateCount_;
- }
-
- public static final int METADATA_FIELD_NUMBER = 7;
- private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_;
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- public boolean hasMetadata() {
- return metadata_ != null;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.RpcMetadata getMetadata() {
- return metadata_ == null ? org.apache.calcite.avatica.proto.Responses.RpcMetadata.getDefaultInstance() : metadata_;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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;
- }
-
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- if (!getConnectionIdBytes().isEmpty()) {
- com.google.protobuf.GeneratedMessageV3.writeString(output, 1, connectionId_);
- }
- if (statementId_ != 0) {
- output.writeUInt32(2, statementId_);
- }
- if (ownStatement_ != false) {
- output.writeBool(3, ownStatement_);
- }
- if (signature_ != null) {
- output.writeMessage(4, getSignature());
- }
- if (firstFrame_ != null) {
- output.writeMessage(5, getFirstFrame());
- }
- if (updateCount_ != 0L) {
- output.writeUInt64(6, updateCount_);
- }
- if (metadata_ != null) {
- output.writeMessage(7, getMetadata());
- }
- }
-
- public int getSerializedSize() {
- int size = memoizedSize;
- if (size != -1) return size;
-
- size = 0;
- if (!getConnectionIdBytes().isEmpty()) {
- size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, connectionId_);
- }
- if (statementId_ != 0) {
- size += com.google.protobuf.CodedOutputStream
- .computeUInt32Size(2, statementId_);
- }
- if (ownStatement_ != false) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(3, ownStatement_);
- }
- if (signature_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(4, getSignature());
- }
- if (firstFrame_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(5, getFirstFrame());
- }
- if (updateCount_ != 0L) {
- size += com.google.protobuf.CodedOutputStream
- .computeUInt64Size(6, updateCount_);
- }
- if (metadata_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(7, getMetadata());
- }
- memoizedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- public boolean equals(final java.lang.Object obj) {
- if (obj == this) {
- return true;
- }
- if (!(obj instanceof org.apache.calcite.avatica.proto.Responses.ResultSetResponse)) {
- return super.equals(obj);
- }
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse other = (org.apache.calcite.avatica.proto.Responses.ResultSetResponse) obj;
-
- boolean result = true;
- result = result && getConnectionId()
- .equals(other.getConnectionId());
- result = result && (getStatementId()
- == other.getStatementId());
- result = result && (getOwnStatement()
- == other.getOwnStatement());
- result = result && (hasSignature() == other.hasSignature());
- if (hasSignature()) {
- result = result && getSignature()
- .equals(other.getSignature());
- }
- result = result && (hasFirstFrame() == other.hasFirstFrame());
- if (hasFirstFrame()) {
- result = result && getFirstFrame()
- .equals(other.getFirstFrame());
- }
- result = result && (getUpdateCount()
- == other.getUpdateCount());
- result = result && (hasMetadata() == other.hasMetadata());
- if (hasMetadata()) {
- result = result && getMetadata()
- .equals(other.getMetadata());
- }
- return result;
- }
-
- @java.lang.Override
- public int hashCode() {
- if (memoizedHashCode != 0) {
- return memoizedHashCode;
- }
- int hash = 41;
- hash = (19 * hash) + getDescriptorForType().hashCode();
- hash = (37 * hash) + CONNECTION_ID_FIELD_NUMBER;
- hash = (53 * hash) + getConnectionId().hashCode();
- hash = (37 * hash) + STATEMENT_ID_FIELD_NUMBER;
- hash = (53 * hash) + getStatementId();
- hash = (37 * hash) + OWN_STATEMENT_FIELD_NUMBER;
- hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
- getOwnStatement());
- if (hasSignature()) {
- hash = (37 * hash) + SIGNATURE_FIELD_NUMBER;
- hash = (53 * hash) + getSignature().hashCode();
- }
- if (hasFirstFrame()) {
- hash = (37 * hash) + FIRST_FRAME_FIELD_NUMBER;
- hash = (53 * hash) + getFirstFrame().hashCode();
- }
- hash = (37 * hash) + UPDATE_COUNT_FIELD_NUMBER;
- hash = (53 * hash) + com.google.protobuf.Internal.hashLong(
- getUpdateCount());
- if (hasMetadata()) {
- hash = (37 * hash) + METADATA_FIELD_NUMBER;
- hash = (53 * hash) + getMetadata().hashCode();
- }
- hash = (29 * hash) + unknownFields.hashCode();
- memoizedHashCode = hash;
- return hash;
- }
-
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse 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.Responses.ResultSetResponse parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse 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.Responses.ResultSetResponse parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
-
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder() {
- return DEFAULT_INSTANCE.toBuilder();
- }
- public static Builder newBuilder(org.apache.calcite.avatica.proto.Responses.ResultSetResponse prototype) {
- return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() {
- return this == DEFAULT_INSTANCE
- ? new Builder() : new Builder().mergeFrom(this);
- }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * <pre>
- * Response that contains a result set.
- * </pre>
- *
- * Protobuf type {@code ResultSetResponse}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:ResultSetResponse)
- org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse.class, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder.class);
- }
-
- // Construct using org.apache.calcite.avatica.proto.Responses.ResultSetResponse.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessageV3
- .alwaysUseFieldBuilders) {
- }
- }
- public Builder clear() {
- super.clear();
- connectionId_ = "";
-
- statementId_ = 0;
-
- ownStatement_ = false;
-
- if (signatureBuilder_ == null) {
- signature_ = null;
- } else {
- signature_ = null;
- signatureBuilder_ = null;
- }
- if (firstFrameBuilder_ == null) {
- firstFrame_ = null;
- } else {
- firstFrame_ = null;
- firstFrameBuilder_ = null;
- }
- updateCount_ = 0L;
-
- if (metadataBuilder_ == null) {
- metadata_ = null;
- } else {
- metadata_ = null;
- metadataBuilder_ = null;
- }
- return this;
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_descriptor;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse getDefaultInstanceForType() {
- return org.apache.calcite.avatica.proto.Responses.ResultSetResponse.getDefaultInstance();
- }
-
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse build() {
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse buildPartial() {
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse result = new org.apache.calcite.avatica.proto.Responses.ResultSetResponse(this);
- result.connectionId_ = connectionId_;
- result.statementId_ = statementId_;
- result.ownStatement_ = ownStatement_;
- if (signatureBuilder_ == null) {
- result.signature_ = signature_;
- } else {
- result.signature_ = signatureBuilder_.build();
- }
- if (firstFrameBuilder_ == null) {
- result.firstFrame_ = firstFrame_;
- } else {
- result.firstFrame_ = firstFrameBuilder_.build();
- }
- result.updateCount_ = updateCount_;
- if (metadataBuilder_ == null) {
- result.metadata_ = metadata_;
- } else {
- result.metadata_ = metadataBuilder_.build();
- }
- onBuilt();
- return result;
- }
-
- public Builder clone() {
- return (Builder) super.clone();
- }
- public Builder setField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return (Builder) super.setField(field, value);
- }
- public Builder clearField(
- com.google.protobuf.Descriptors.FieldDescriptor field) {
- return (Builder) super.clearField(field);
- }
- public Builder clearOneof(
- com.google.protobuf.Descriptors.OneofDescriptor oneof) {
- return (Builder) super.clearOneof(oneof);
- }
- public Builder setRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- int index, Object value) {
- return (Builder) super.setRepeatedField(field, index, value);
- }
- public Builder addRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return (Builder) super.addRepeatedField(field, value);
- }
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.calcite.avatica.proto.Responses.ResultSetResponse) {
- return mergeFrom((org.apache.calcite.avatica.proto.Responses.ResultSetResponse)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.apache.calcite.avatica.proto.Responses.ResultSetResponse other) {
- if (other == org.apache.calcite.avatica.proto.Responses.ResultSetResponse.getDefaultInstance()) return this;
- if (!other.getConnectionId().isEmpty()) {
- connectionId_ = other.connectionId_;
- onChanged();
- }
- if (other.getStatementId() != 0) {
- setStatementId(other.getStatementId());
- }
- if (other.getOwnStatement() != false) {
- setOwnStatement(other.getOwnStatement());
- }
- if (other.hasSignature()) {
- mergeSignature(other.getSignature());
- }
- if (other.hasFirstFrame()) {
- mergeFirstFrame(other.getFirstFrame());
- }
- if (other.getUpdateCount() != 0L) {
- setUpdateCount(other.getUpdateCount());
- }
- if (other.hasMetadata()) {
- mergeMetadata(other.getMetadata());
- }
- 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.Responses.ResultSetResponse parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.calcite.avatica.proto.Responses.ResultSetResponse) e.getUnfinishedMessage();
- throw e.unwrapIOException();
- } 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();
- 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();
- }
- checkByteStringIsUtf8(value);
-
- connectionId_ = value;
- 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;
- }
-
- private boolean ownStatement_ ;
- /**
- * <code>optional bool own_statement = 3;</code>
- */
- public boolean getOwnStatement() {
- return ownStatement_;
- }
- /**
- * <code>optional bool own_statement = 3;</code>
- */
- public Builder setOwnStatement(boolean value) {
-
- ownStatement_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>optional bool own_statement = 3;</code>
- */
- public Builder clearOwnStatement() {
-
- ownStatement_ = false;
- onChanged();
- return this;
- }
-
- private org.apache.calcite.avatica.proto.Common.Signature signature_ = null;
- private com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Signature, org.apache.calcite.avatica.proto.Common.Signature.Builder, org.apache.calcite.avatica.proto.Common.SignatureOrBuilder> signatureBuilder_;
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public boolean hasSignature() {
- return signatureBuilder_ != null || signature_ != null;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Signature getSignature() {
- if (signatureBuilder_ == null) {
- return signature_ == null ? org.apache.calcite.avatica.proto.Common.Signature.getDefaultInstance() : signature_;
- } else {
- return signatureBuilder_.getMessage();
- }
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public Builder setSignature(org.apache.calcite.avatica.proto.Common.Signature value) {
- if (signatureBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- signature_ = value;
- onChanged();
- } else {
- signatureBuilder_.setMessage(value);
- }
-
- return this;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public Builder setSignature(
- org.apache.calcite.avatica.proto.Common.Signature.Builder builderForValue) {
- if (signatureBuilder_ == null) {
- signature_ = builderForValue.build();
- onChanged();
- } else {
- signatureBuilder_.setMessage(builderForValue.build());
- }
-
- return this;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public Builder mergeSignature(org.apache.calcite.avatica.proto.Common.Signature value) {
- if (signatureBuilder_ == null) {
- if (signature_ != null) {
- signature_ =
- org.apache.calcite.avatica.proto.Common.Signature.newBuilder(signature_).mergeFrom(value).buildPartial();
- } else {
- signature_ = value;
- }
- onChanged();
- } else {
- signatureBuilder_.mergeFrom(value);
- }
-
- return this;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public Builder clearSignature() {
- if (signatureBuilder_ == null) {
- signature_ = null;
- onChanged();
- } else {
- signature_ = null;
- signatureBuilder_ = null;
- }
-
- return this;
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Signature.Builder getSignatureBuilder() {
-
- onChanged();
- return getSignatureFieldBuilder().getBuilder();
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- public org.apache.calcite.avatica.proto.Common.SignatureOrBuilder getSignatureOrBuilder() {
- if (signatureBuilder_ != null) {
- return signatureBuilder_.getMessageOrBuilder();
- } else {
- return signature_ == null ?
- org.apache.calcite.avatica.proto.Common.Signature.getDefaultInstance() : signature_;
- }
- }
- /**
- * <code>optional .Signature signature = 4;</code>
- */
- private com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Signature, org.apache.calcite.avatica.proto.Common.Signature.Builder, org.apache.calcite.avatica.proto.Common.SignatureOrBuilder>
- getSignatureFieldBuilder() {
- if (signatureBuilder_ == null) {
- signatureBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Signature, org.apache.calcite.avatica.proto.Common.Signature.Builder, org.apache.calcite.avatica.proto.Common.SignatureOrBuilder>(
- getSignature(),
- getParentForChildren(),
- isClean());
- signature_ = null;
- }
- return signatureBuilder_;
- }
-
- private org.apache.calcite.avatica.proto.Common.Frame firstFrame_ = null;
- private com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Frame, org.apache.calcite.avatica.proto.Common.Frame.Builder, org.apache.calcite.avatica.proto.Common.FrameOrBuilder> firstFrameBuilder_;
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public boolean hasFirstFrame() {
- return firstFrameBuilder_ != null || firstFrame_ != null;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Frame getFirstFrame() {
- if (firstFrameBuilder_ == null) {
- return firstFrame_ == null ? org.apache.calcite.avatica.proto.Common.Frame.getDefaultInstance() : firstFrame_;
- } else {
- return firstFrameBuilder_.getMessage();
- }
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public Builder setFirstFrame(org.apache.calcite.avatica.proto.Common.Frame value) {
- if (firstFrameBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- firstFrame_ = value;
- onChanged();
- } else {
- firstFrameBuilder_.setMessage(value);
- }
-
- return this;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public Builder setFirstFrame(
- org.apache.calcite.avatica.proto.Common.Frame.Builder builderForValue) {
- if (firstFrameBuilder_ == null) {
- firstFrame_ = builderForValue.build();
- onChanged();
- } else {
- firstFrameBuilder_.setMessage(builderForValue.build());
- }
-
- return this;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public Builder mergeFirstFrame(org.apache.calcite.avatica.proto.Common.Frame value) {
- if (firstFrameBuilder_ == null) {
- if (firstFrame_ != null) {
- firstFrame_ =
- org.apache.calcite.avatica.proto.Common.Frame.newBuilder(firstFrame_).mergeFrom(value).buildPartial();
- } else {
- firstFrame_ = value;
- }
- onChanged();
- } else {
- firstFrameBuilder_.mergeFrom(value);
- }
-
- return this;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public Builder clearFirstFrame() {
- if (firstFrameBuilder_ == null) {
- firstFrame_ = null;
- onChanged();
- } else {
- firstFrame_ = null;
- firstFrameBuilder_ = null;
- }
-
- return this;
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public org.apache.calcite.avatica.proto.Common.Frame.Builder getFirstFrameBuilder() {
-
- onChanged();
- return getFirstFrameFieldBuilder().getBuilder();
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- public org.apache.calcite.avatica.proto.Common.FrameOrBuilder getFirstFrameOrBuilder() {
- if (firstFrameBuilder_ != null) {
- return firstFrameBuilder_.getMessageOrBuilder();
- } else {
- return firstFrame_ == null ?
- org.apache.calcite.avatica.proto.Common.Frame.getDefaultInstance() : firstFrame_;
- }
- }
- /**
- * <code>optional .Frame first_frame = 5;</code>
- */
- private com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Frame, org.apache.calcite.avatica.proto.Common.Frame.Builder, org.apache.calcite.avatica.proto.Common.FrameOrBuilder>
- getFirstFrameFieldBuilder() {
- if (firstFrameBuilder_ == null) {
- firstFrameBuilder_ = new com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Common.Frame, org.apache.calcite.avatica.proto.Common.Frame.Builder, org.apache.calcite.avatica.proto.Common.FrameOrBuilder>(
- getFirstFrame(),
- getParentForChildren(),
- isClean());
- firstFrame_ = null;
- }
- return firstFrameBuilder_;
- }
-
- private long updateCount_ ;
- /**
- * <pre>
- * -1 for normal result sets, else this response contains a dummy result set
- * </pre>
- *
- * <code>optional uint64 update_count = 6;</code>
- */
- public long getUpdateCount() {
- return updateCount_;
- }
- /**
- * <pre>
- * -1 for normal result sets, else this response contains a dummy result set
- * </pre>
- *
- * <code>optional uint64 update_count = 6;</code>
- */
- public Builder setUpdateCount(long value) {
-
- updateCount_ = value;
- onChanged();
- return this;
- }
- /**
- * <pre>
- * -1 for normal result sets, else this response contains a dummy result set
- * </pre>
- *
- * <code>optional uint64 update_count = 6;</code>
- */
- public Builder clearUpdateCount() {
-
- updateCount_ = 0L;
- onChanged();
- return this;
- }
-
- private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
- private com.google.protobuf.SingleFieldBuilderV3<
- org.apache.calcite.avatica.proto.Responses.RpcMetadata, org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder, org.apache.calcite.avatica.proto.Responses.RpcMetadataOrBuilder> metadataBuilder_;
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- public boolean hasMetadata() {
- return metadataBuilder_ != null || metadata_ != null;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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();
- }
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- public Builder clearMetadata() {
- if (metadataBuilder_ == null) {
- metadata_ = null;
- onChanged();
- } else {
- metadata_ = null;
- metadataBuilder_ = null;
- }
-
- return this;
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.RpcMetadata.Builder getMetadataBuilder() {
-
- onChanged();
- return getMetadataFieldBuilder().getBuilder();
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</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_;
- }
- }
- /**
- * <pre>
- * with no signature nor other data.
- * </pre>
- *
- * <code>optional .RpcMetadata metadata = 7;</code>
- */
- private com.google.protobuf.SingleFieldBuilderV3<
- 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.SingleFieldBuilderV3<
- 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:ResultSetResponse)
- }
-
- // @@protoc_insertion_point(class_scope:ResultSetResponse)
- private static final org.apache.calcite.avatica.proto.Responses.ResultSetResponse DEFAULT_INSTANCE;
- static {
- DEFAULT_INSTANCE = new org.apache.calcite.avatica.proto.Responses.ResultSetResponse();
- }
-
- public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse getDefaultInstance() {
- return DEFAULT_INSTANCE;
- }
-
- private static final com.google.protobuf.Parser<ResultSetResponse>
- PARSER = new com.google.protobuf.AbstractParser<ResultSetResponse>() {
- public ResultSetResponse parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new ResultSetResponse(input, extensionRegistry);
- }
- };
-
- public static com.google.protobuf.Parser<ResultSetResponse> parser() {
- return PARSER;
- }
-
- @java.lang.Override
- public com.google.protobuf.Parser<ResultSetResponse> getParserForType() {
- return PARSER;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse getDefaultInstanceForType() {
- return DEFAULT_INSTANCE;
- }
-
- }
-
- public interface ExecuteResponseOrBuilder extends
- // @@protoc_insertion_point(interface_extends:ExecuteResponse)
- com.google.protobuf.MessageOrBuilder {
-
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse>
- getResultsList();
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse getResults(int index);
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- int getResultsCount();
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- java.util.List<? extends org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder>
- getResultsOrBuilderList();
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder getResultsOrBuilder(
- int index);
-
- /**
- * <pre>
- * Did the request fail because of no-cached statement
- * </pre>
- *
- * <code>optional bool missing_statement = 2;</code>
- */
- 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();
- }
- /**
- * <pre>
- * Response to PrepareAndExecuteRequest
- * </pre>
- *
- * Protobuf type {@code ExecuteResponse}
- */
- public static final class ExecuteResponse extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:ExecuteResponse)
- ExecuteResponseOrBuilder {
- // Use ExecuteResponse.newBuilder() to construct.
- private ExecuteResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private ExecuteResponse() {
- results_ = java.util.Collections.emptyList();
- missingStatement_ = false;
- }
-
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
- }
- private ExecuteResponse(
- 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: {
- if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
- results_ = new java.util.ArrayList<org.apache.calcite.avatica.proto.Responses.ResultSetResponse>();
- mutable_bitField0_ |= 0x00000001;
- }
- results_.add(
- input.readMessage(org.apache.calcite.avatica.proto.Responses.ResultSetResponse.parser(), extensionRegistry));
- break;
- }
- case 16: {
-
- 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) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e).setUnfinishedMessage(this);
- } finally {
- if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
- results_ = java.util.Collections.unmodifiableList(results_);
- }
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ExecuteResponse_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ExecuteResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.calcite.avatica.proto.Responses.ExecuteResponse.class, org.apache.calcite.avatica.proto.Responses.ExecuteResponse.Builder.class);
- }
-
- private int bitField0_;
- public static final int RESULTS_FIELD_NUMBER = 1;
- private java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse> results_;
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse> getResultsList() {
- return results_;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public java.util.List<? extends org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder>
- getResultsOrBuilderList() {
- return results_;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public int getResultsCount() {
- return results_.size();
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse getResults(int index) {
- return results_.get(index);
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder getResultsOrBuilder(
- int index) {
- return results_.get(index);
- }
-
- public static final int MISSING_STATEMENT_FIELD_NUMBER = 2;
- private boolean missingStatement_;
- /**
- * <pre>
- * Did the request fail because of no-cached statement
- * </pre>
- *
- * <code>optional bool missing_statement = 2;</code>
- */
- public boolean getMissingStatement() {
- 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;
- 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 {
- for (int i = 0; i < results_.size(); i++) {
- output.writeMessage(1, results_.get(i));
- }
- if (missingStatement_ != false) {
- output.writeBool(2, missingStatement_);
- }
- if (metadata_ != null) {
- output.writeMessage(3, getMetadata());
- }
- }
-
- public int getSerializedSize() {
- int size = memoizedSize;
- if (size != -1) return size;
-
- size = 0;
- for (int i = 0; i < results_.size(); i++) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(1, results_.get(i));
- }
- if (missingStatement_ != false) {
- size += com.google.protobuf.CodedOutputStream
- .computeBoolSize(2, missingStatement_);
- }
- if (metadata_ != null) {
- size += com.google.protobuf.CodedOutputStream
- .computeMessageSize(3, getMetadata());
- }
- memoizedSize = size;
- return size;
- }
-
- private static final long serialVersionUID = 0L;
- @java.lang.Override
- public boolean equals(final java.lang.Object obj) {
- if (obj == this) {
- return true;
- }
- if (!(obj instanceof org.apache.calcite.avatica.proto.Responses.ExecuteResponse)) {
- return super.equals(obj);
- }
- org.apache.calcite.avatica.proto.Responses.ExecuteResponse other = (org.apache.calcite.avatica.proto.Responses.ExecuteResponse) obj;
-
- boolean result = true;
- result = result && getResultsList()
- .equals(other.getResultsList());
- result = result && (getMissingStatement()
- == other.getMissingStatement());
- result = result && (hasMetadata() == other.hasMetadata());
- if (hasMetadata()) {
- result = result && getMetadata()
- .equals(other.getMetadata());
- }
- return result;
- }
-
- @java.lang.Override
- public int hashCode() {
- if (memoizedHashCode != 0) {
- return memoizedHashCode;
- }
- int hash = 41;
- hash = (19 * hash) + getDescriptorForType().hashCode();
- if (getResultsCount() > 0) {
- hash = (37 * hash) + RESULTS_FIELD_NUMBER;
- hash = (53 * hash) + getResultsList().hashCode();
- }
- hash = (37 * hash) + MISSING_STATEMENT_FIELD_NUMBER;
- hash = (53 * hash) + com.google.protobuf.Internal.hashBoolean(
- getMissingStatement());
- if (hasMetadata()) {
- hash = (37 * hash) + METADATA_FIELD_NUMBER;
- hash = (53 * hash) + getMetadata().hashCode();
- }
- hash = (29 * hash) + unknownFields.hashCode();
- memoizedHashCode = hash;
- return hash;
- }
-
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse 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.Responses.ExecuteResponse parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse 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.Responses.ExecuteResponse parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
-
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder() {
- return DEFAULT_INSTANCE.toBuilder();
- }
- public static Builder newBuilder(org.apache.calcite.avatica.proto.Responses.ExecuteResponse prototype) {
- return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
- }
- public Builder toBuilder() {
- return this == DEFAULT_INSTANCE
- ? new Builder() : new Builder().mergeFrom(this);
- }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * <pre>
- * Response to PrepareAndExecuteRequest
- * </pre>
- *
- * Protobuf type {@code ExecuteResponse}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:ExecuteResponse)
- org.apache.calcite.avatica.proto.Responses.ExecuteResponseOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ExecuteResponse_descriptor;
- }
-
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ExecuteResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- org.apache.calcite.avatica.proto.Responses.ExecuteResponse.class, org.apache.calcite.avatica.proto.Responses.ExecuteResponse.Builder.class);
- }
-
- // Construct using org.apache.calcite.avatica.proto.Responses.ExecuteResponse.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessageV3
- .alwaysUseFieldBuilders) {
- getResultsFieldBuilder();
- }
- }
- public Builder clear() {
- super.clear();
- if (resultsBuilder_ == null) {
- results_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000001);
- } else {
- resultsBuilder_.clear();
- }
- missingStatement_ = false;
-
- if (metadataBuilder_ == null) {
- metadata_ = null;
- } else {
- metadata_ = null;
- metadataBuilder_ = null;
- }
- return this;
- }
-
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return org.apache.calcite.avatica.proto.Responses.internal_static_ExecuteResponse_descriptor;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ExecuteResponse getDefaultInstanceForType() {
- return org.apache.calcite.avatica.proto.Responses.ExecuteResponse.getDefaultInstance();
- }
-
- public org.apache.calcite.avatica.proto.Responses.ExecuteResponse build() {
- org.apache.calcite.avatica.proto.Responses.ExecuteResponse result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ExecuteResponse buildPartial() {
- org.apache.calcite.avatica.proto.Responses.ExecuteResponse result = new org.apache.calcite.avatica.proto.Responses.ExecuteResponse(this);
- int from_bitField0_ = bitField0_;
- int to_bitField0_ = 0;
- if (resultsBuilder_ == null) {
- if (((bitField0_ & 0x00000001) == 0x00000001)) {
- results_ = java.util.Collections.unmodifiableList(results_);
- bitField0_ = (bitField0_ & ~0x00000001);
- }
- result.results_ = results_;
- } else {
- 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;
- }
-
- public Builder clone() {
- return (Builder) super.clone();
- }
- public Builder setField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return (Builder) super.setField(field, value);
- }
- public Builder clearField(
- com.google.protobuf.Descriptors.FieldDescriptor field) {
- return (Builder) super.clearField(field);
- }
- public Builder clearOneof(
- com.google.protobuf.Descriptors.OneofDescriptor oneof) {
- return (Builder) super.clearOneof(oneof);
- }
- public Builder setRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- int index, Object value) {
- return (Builder) super.setRepeatedField(field, index, value);
- }
- public Builder addRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- Object value) {
- return (Builder) super.addRepeatedField(field, value);
- }
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.calcite.avatica.proto.Responses.ExecuteResponse) {
- return mergeFrom((org.apache.calcite.avatica.proto.Responses.ExecuteResponse)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(org.apache.calcite.avatica.proto.Responses.ExecuteResponse other) {
- if (other == org.apache.calcite.avatica.proto.Responses.ExecuteResponse.getDefaultInstance()) return this;
- if (resultsBuilder_ == null) {
- if (!other.results_.isEmpty()) {
- if (results_.isEmpty()) {
- results_ = other.results_;
- bitField0_ = (bitField0_ & ~0x00000001);
- } else {
- ensureResultsIsMutable();
- results_.addAll(other.results_);
- }
- onChanged();
- }
- } else {
- if (!other.results_.isEmpty()) {
- if (resultsBuilder_.isEmpty()) {
- resultsBuilder_.dispose();
- resultsBuilder_ = null;
- results_ = other.results_;
- bitField0_ = (bitField0_ & ~0x00000001);
- resultsBuilder_ =
- com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ?
- getResultsFieldBuilder() : null;
- } else {
- resultsBuilder_.addAllMessages(other.results_);
- }
- }
- }
- if (other.getMissingStatement() != false) {
- setMissingStatement(other.getMissingStatement());
- }
- if (other.hasMetadata()) {
- mergeMetadata(other.getMetadata());
- }
- 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.Responses.ExecuteResponse parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.calcite.avatica.proto.Responses.ExecuteResponse) e.getUnfinishedMessage();
- throw e.unwrapIOException();
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
- private int bitField0_;
-
- private java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse> results_ =
- java.util.Collections.emptyList();
- private void ensureResultsIsMutable() {
- if (!((bitField0_ & 0x00000001) == 0x00000001)) {
- results_ = new java.util.ArrayList<org.apache.calcite.avatica.proto.Responses.ResultSetResponse>(results_);
- bitField0_ |= 0x00000001;
- }
- }
-
- private com.google.protobuf.RepeatedFieldBuilderV3<
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder, org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder> resultsBuilder_;
-
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse> getResultsList() {
- if (resultsBuilder_ == null) {
- return java.util.Collections.unmodifiableList(results_);
- } else {
- return resultsBuilder_.getMessageList();
- }
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public int getResultsCount() {
- if (resultsBuilder_ == null) {
- return results_.size();
- } else {
- return resultsBuilder_.getCount();
- }
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse getResults(int index) {
- if (resultsBuilder_ == null) {
- return results_.get(index);
- } else {
- return resultsBuilder_.getMessage(index);
- }
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder setResults(
- int index, org.apache.calcite.avatica.proto.Responses.ResultSetResponse value) {
- if (resultsBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureResultsIsMutable();
- results_.set(index, value);
- onChanged();
- } else {
- resultsBuilder_.setMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder setResults(
- int index, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder builderForValue) {
- if (resultsBuilder_ == null) {
- ensureResultsIsMutable();
- results_.set(index, builderForValue.build());
- onChanged();
- } else {
- resultsBuilder_.setMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder addResults(org.apache.calcite.avatica.proto.Responses.ResultSetResponse value) {
- if (resultsBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureResultsIsMutable();
- results_.add(value);
- onChanged();
- } else {
- resultsBuilder_.addMessage(value);
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder addResults(
- int index, org.apache.calcite.avatica.proto.Responses.ResultSetResponse value) {
- if (resultsBuilder_ == null) {
- if (value == null) {
- throw new NullPointerException();
- }
- ensureResultsIsMutable();
- results_.add(index, value);
- onChanged();
- } else {
- resultsBuilder_.addMessage(index, value);
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder addResults(
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder builderForValue) {
- if (resultsBuilder_ == null) {
- ensureResultsIsMutable();
- results_.add(builderForValue.build());
- onChanged();
- } else {
- resultsBuilder_.addMessage(builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder addResults(
- int index, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder builderForValue) {
- if (resultsBuilder_ == null) {
- ensureResultsIsMutable();
- results_.add(index, builderForValue.build());
- onChanged();
- } else {
- resultsBuilder_.addMessage(index, builderForValue.build());
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder addAllResults(
- java.lang.Iterable<? extends org.apache.calcite.avatica.proto.Responses.ResultSetResponse> values) {
- if (resultsBuilder_ == null) {
- ensureResultsIsMutable();
- com.google.protobuf.AbstractMessageLite.Builder.addAll(
- values, results_);
- onChanged();
- } else {
- resultsBuilder_.addAllMessages(values);
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder clearResults() {
- if (resultsBuilder_ == null) {
- results_ = java.util.Collections.emptyList();
- bitField0_ = (bitField0_ & ~0x00000001);
- onChanged();
- } else {
- resultsBuilder_.clear();
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public Builder removeResults(int index) {
- if (resultsBuilder_ == null) {
- ensureResultsIsMutable();
- results_.remove(index);
- onChanged();
- } else {
- resultsBuilder_.remove(index);
- }
- return this;
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder getResultsBuilder(
- int index) {
- return getResultsFieldBuilder().getBuilder(index);
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder getResultsOrBuilder(
- int index) {
- if (resultsBuilder_ == null) {
- return results_.get(index); } else {
- return resultsBuilder_.getMessageOrBuilder(index);
- }
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public java.util.List<? extends org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder>
- getResultsOrBuilderList() {
- if (resultsBuilder_ != null) {
- return resultsBuilder_.getMessageOrBuilderList();
- } else {
- return java.util.Collections.unmodifiableList(results_);
- }
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder addResultsBuilder() {
- return getResultsFieldBuilder().addBuilder(
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse.getDefaultInstance());
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder addResultsBuilder(
- int index) {
- return getResultsFieldBuilder().addBuilder(
- index, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.getDefaultInstance());
- }
- /**
- * <code>repeated .ResultSetResponse results = 1;</code>
- */
- public java.util.List<org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder>
- getResultsBuilderList() {
- return getResultsFieldBuilder().getBuilderList();
- }
- private com.google.protobuf.RepeatedFieldBuilderV3<
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder, org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder>
- getResultsFieldBuilder() {
- if (resultsBuilder_ == null) {
- resultsBuilder_ = new com.google.protobuf.RepeatedFieldBuilderV3<
- org.apache.calcite.avatica.proto.Responses.ResultSetResponse, org.apache.calcite.avatica.proto.Responses.ResultSetResponse.Builder, org.apache.calcite.avatica.proto.Responses.ResultSetResponseOrBuilder>(
- results_,
- ((bitField0_ & 0x00000001) == 0x00000001),
- getParentForChildren(),
- isClean());
- results_ = null;
- }
- return resultsBuilder_;
- }
-
- private boolean missingStatement_ ;
- /**
- * <pre>
- * Did the request fail because of no-cached statement
- * </pre>
- *
- * <code>optional bool missing_statement = 2;</code>
- */
- public boolean getMissingStatement() {
- return missingStatement_;
- }
- /**
- * <pre>
- * Did the request fail because of no-cached statement
- * </pre>
- *
- * <code>optional bool missing_statement = 2;</code>
- */
- public Builder setMissingStatement(boolean value) {
-
- missingStatement_ = value;
- onChanged();
- return this;
- }
- /**
- * <pre>
- * Did the request fail because of no-cached statement
- * </pre>
- *
- * <code>optional bool missing_statement = 2;</code>
- */
- public Builder clearMissingStatement() {
-
- missingStatement_ = false;
- onChanged();
- return this;
- }
-
- private org.apache.calcite.avatica.proto.Responses.RpcMetadata metadata_ = null;
- private com.google.protobuf.SingleFieldBuilderV3<
- 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.SingleFieldBuilderV3<
- 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.SingleFieldBuilderV3<
- 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:ExecuteResponse)
- }
-
- // @@protoc_insertion_point(class_scope:ExecuteResponse)
- private static final org.apache.calcite.avatica.proto.Responses.ExecuteResponse DEFAULT_INSTANCE;
- static {
- DEFAULT_INSTANCE = new org.apache.calcite.avatica.proto.Responses.ExecuteResponse();
- }
-
- public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse getDefaultInstance() {
- return DEFAULT_INSTANCE;
- }
-
- private static final com.google.protobuf.Parser<ExecuteResponse>
- PARSER = new com.google.protobuf.AbstractParser<ExecuteResponse>() {
- public ExecuteResponse parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new ExecuteResponse(input, extensionRegistry);
- }
- };
-
- public static com.google.protobuf.Parser<ExecuteResponse> parser() {
- return PARSER;
- }
-
- @java.lang.Override
- public com.google.protobuf.Parser<ExecuteResponse> getParserForType() {
- return PARSER;
- }
-
- public org.apache.calcite.avatica.proto.Responses.ExecuteResponse getDefaultInstanceForType() {
- return DEFAULT_INSTANCE;
- }
-
- }
-
- public interface PrepareResponseOrBuilder extends
- // @@protoc_insertion_point(interface_extends:PrepareResponse)
- com.google.protobuf.MessageOrBuilder {
-
- /**
- * <code>optional .StatementHandle statement = 1;</code>
- */
- boolean hasStatement();
- /**
- * <code>optional .StatementHandle statement = 1;</code>
- */
- org.apache.calcite.avatica.proto.Common.StatementHandle getStatement();
- /**
- * <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();
- }
- /**
- * <pre>
- * Response to PrepareRequest
- * </pre>
- *
- * Protobuf type {@code PrepareResponse}
- */
- public static final class PrepareResponse extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:PrepareResponse)
- PrepareResponseOrBuilder {
- // Use PrepareResponse.newBuilder() to construct.
- private PrepareResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private PrepareResponse() {
- }
-
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return com.google.protobuf.UnknownFieldSet.getDefaultInstance();
- }
- private PrepareResponse(
- com.google.protobuf.CodedInputStream input,
- com.google.prot
<TRUNCATED>