http://git-wip-us.apache.org/repos/asf/calcite/blob/5cee486f/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 deleted file mode 100644 index cd3d0cf..0000000 --- a/avatica/src/main/java/org/apache/calcite/avatica/proto/Responses.java +++ /dev/null @@ -1,11853 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to you under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -// Generated by the protocol buffer compiler. DO NOT EDIT! -// source: responses.proto - -package org.apache.calcite.avatica.proto; - -@SuppressWarnings({"unused", "rawtypes"}) public final class Responses { - private Responses() {} - public static void registerAllExtensions( - com.google.protobuf.ExtensionRegistry 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(); - - /** - * <code>optional uint64 update_count = 6;</code> - * - * <pre> - * -1 for normal result sets, else this response contains a dummy result set - * </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} - * - * <pre> - * Response that contains a result set. - * </pre> - */ - public static final class ResultSetResponse extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:ResultSetResponse) - ResultSetResponseOrBuilder { - // Use ResultSetResponse.newBuilder() to construct. - private ResultSetResponse(com.google.protobuf.GeneratedMessage.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) { - 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: { - 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 new RuntimeException(e.setUnfinishedMessage(this)); - } catch (java.io.IOException e) { - throw new RuntimeException( - new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).setUnfinishedMessage(this)); - } finally { - makeExtensionsImmutable(); - } - } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.calcite.avatica.proto.Responses.internal_static_ResultSetResponse_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.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_; - /** - * <code>optional uint64 update_count = 6;</code> - * - * <pre> - * -1 for normal result sets, else this response contains a dummy result set - * </pre> - */ - public long getUpdateCount() { - 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; - 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.GeneratedMessage.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.GeneratedMessage.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; - 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 PARSER.parseFrom(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 PARSER.parseFrom(input, extensionRegistry); - } - public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(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 PARSER.parseDelimitedFrom(input, extensionRegistry); - } - public static org.apache.calcite.avatica.proto.Responses.ResultSetResponse parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return PARSER.parseFrom(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 PARSER.parseFrom(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.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - /** - * Protobuf type {@code ResultSetResponse} - * - * <pre> - * Response that contains a result set. - * </pre> - */ - public static final class Builder extends - com.google.protobuf.GeneratedMessage.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.GeneratedMessage.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.GeneratedMessage.BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.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 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; - } 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.SingleFieldBuilder< - 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.SingleFieldBuilder< - 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.SingleFieldBuilder< - 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.SingleFieldBuilder< - 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.SingleFieldBuilder< - 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.SingleFieldBuilder< - 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_ ; - /** - * <code>optional uint64 update_count = 6;</code> - * - * <pre> - * -1 for normal result sets, else this response contains a dummy result set - * </pre> - */ - public long getUpdateCount() { - return updateCount_; - } - /** - * <code>optional uint64 update_count = 6;</code> - * - * <pre> - * -1 for normal result sets, else this response contains a dummy result set - * </pre> - */ - public Builder setUpdateCount(long value) { - - updateCount_ = value; - onChanged(); - return this; - } - /** - * <code>optional uint64 update_count = 6;</code> - * - * <pre> - * -1 for normal result sets, else this response contains a dummy result set - * </pre> - */ - public Builder clearUpdateCount() { - - updateCount_ = 0L; - 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; - } - - 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 { - try { - return new ResultSetResponse(input, extensionRegistry); - } catch (RuntimeException e) { - if (e.getCause() instanceof - com.google.protobuf.InvalidProtocolBufferException) { - throw (com.google.protobuf.InvalidProtocolBufferException) - e.getCause(); - } - throw e; - } - } - }; - - 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); - - /** - * <code>optional bool missing_statement = 2;</code> - * - * <pre> - * Did the request fail because of no-cached statement - * </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} - * - * <pre> - * Response to PrepareAndExecuteRequest - * </pre> - */ - public static final class ExecuteResponse extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:ExecuteResponse) - ExecuteResponseOrBuilder { - // Use ExecuteResponse.newBuilder() to construct. - private ExecuteResponse(com.google.protobuf.GeneratedMessage.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) { - 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 new RuntimeException(e.setUnfinishedMessage(this)); - } catch (java.io.IOException e) { - throw new RuntimeException( - new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).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.GeneratedMessage.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_; - /** - * <code>optional bool missing_statement = 2;</code> - * - * <pre> - * Did the request fail because of no-cached statement - * </pre> - */ - 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; - 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 PARSER.parseFrom(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 PARSER.parseFrom(input, extensionRegistry); - } - public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(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 PARSER.parseDelimitedFrom(input, extensionRegistry); - } - public static org.apache.calcite.avatica.proto.Responses.ExecuteResponse parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return PARSER.parseFrom(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 PARSER.parseFrom(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.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - /** - * Protobuf type {@code ExecuteResponse} - * - * <pre> - * Response to PrepareAndExecuteRequest - * </pre> - */ - public static final class Builder extends - com.google.protobuf.GeneratedMessage.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.GeneratedMessage.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.GeneratedMessage.BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.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 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.GeneratedMessage.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; - } 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.RepeatedFieldBuilder< - 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.RepeatedFieldBuilder< - 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.RepeatedFieldBuilder< - 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_ ; - /** - * <code>optional bool missing_statement = 2;</code> - * - * <pre> - * Did the request fail because of no-cached statement - * </pre> - */ - public boolean getMissingStatement() { - return missingStatement_; - } - /** - * <code>optional bool missing_statement = 2;</code> - * - * <pre> - * Did the request fail because of no-cached statement - * </pre> - */ - public Builder setMissingStatement(boolean value) { - - missingStatement_ = value; - onChanged(); - return this; - } - /** - * <code>optional bool missing_statement = 2;</code> - * - * <pre> - * Did the request fail because of no-cached statement - * </pre> - */ - public Builder clearMissingStatement() { - - missingStatement_ = false; - 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; - } - - 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 { - try { - return new ExecuteResponse(input, extensionRegistry); - } catch (RuntimeException e) { - if (e.getCause() instanceof - com.google.protobuf.InvalidProtocolBufferException) { - throw (com.google.protobuf.InvalidProtocolBufferException) - e.getCause(); - } - throw e; - } - } - }; - - 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(); - } - /** - * Protobuf type {@code PrepareResponse} - * - * <pre> - * Response to PrepareRequest - * </pre> - */ - public static final class PrepareResponse extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:PrepareResponse) - PrepareResponseOrBuilder { - // Use PrepareResponse.newBuilder() to construct. - private PrepareResponse(com.google.protobuf.GeneratedMessage.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.protobuf.ExtensionRegistryLite extensionRegistry) { - 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: { - org.apache.calcite.avatica.proto.Common.StatementHandle.Builder subBuilder = null; - if (statement_ != null) { - subBuilder = statement_.toBuilder(); - } - statement_ = input.readMessage(org.apache.calcite.avatica.proto.Common.StatementHandle.parser(), extensionRegistry); - if (subBuilder != null) { - subBuilder.mergeFrom(statement_); - statement_ = subBuilder.buildPartial(); - } - - 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) { - throw new RuntimeException(e.setUnfinishedMessage(this)); - } catch (java.io.IOException e) { - throw new RuntimeException( - new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).setUnfinishedMessage(this)); - } finally { - makeExtensionsImmutable(); - } - } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return org.apache.calcite.avatica.proto.Responses.internal_static_PrepareResponse_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return org.apache.calcite.avatica.proto.Responses.internal_static_PrepareResponse_fieldAccessorTable - .ensureFieldAccessorsInitialized( - org.apache.calcite.avatica.proto.Responses.PrepareResponse.class, org.apache.calcite.avatica.proto.Responses.PrepareResponse.Builder.class); - } - - public static final int STATEMENT_FIELD_NUMBER = 1; - private org.apache.calcite.avatica.proto.Common.StatementHandle statement_; - /** - * <code>optional .StatementHandle statement = 1;</code> - */ - public boolean hasStatement() { - return statement_ != null; - } - /** - * <code>optional .StatementHandle statement = 1;</code> - */ - public org.apache.calcite.avatica.proto.Common.StatementHandle getStatement() { - return statement_ == null ? org.apache.calcite.avatica.proto.Common.StatementHandle.getDefaultInstance() : statement_; - } - /** - * <code>optional .StatementHandle statement = 1;</code> - */ - public org.apache.calcite.avatica.proto.Common.StatementHandleOrBuilder getStatementOrBuilder() { - return getStatement(); - } - - 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; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - if (statement_ != null) { - output.writeMessage(1, getStatement()); - } - if (metadata_ != null) { - output.writeMessage(2, getMetadata()); - } - } - - public int getSerializedSize() { - int size = memoizedSize; - if (size != -1) return size; - - size = 0; - if (statement_ != null) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(1, getStatement()); - } - if (metadata_ != null) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, getMetadata()); - } - memoizedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - public static org.apache.calcite.avatica.proto.Responses.PrepareResponse parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static org.apache.calcite.avatica.proto.Responses.PrepareResponse 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.PrepareResponse
<TRUNCATED>
