diff --git a/pom.xml b/pom.xml index 6550779e9..994fa81ee 100644 --- a/pom.xml +++ b/pom.xml @@ -26,6 +26,7 @@ 1.12.681 + 3.23.4 1.0.392 libsqlite4java ${project.build.directory}/test-lib @@ -60,7 +61,7 @@ com.google.protobuf protobuf-java - 3.23.4 + ${protobuf.version} org.apache.commons @@ -149,6 +150,13 @@ + + + kr.motd.maven + os-maven-plugin + 1.6.0 + + @@ -165,6 +173,21 @@ + + org.xolstice.maven.plugins + protobuf-maven-plugin + 0.6.1 + + + + compile + + + + + com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier} + + org.apache.maven.plugins maven-surefire-plugin diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/types/Messages.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/types/Messages.java deleted file mode 100644 index aaab70016..000000000 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/types/Messages.java +++ /dev/null @@ -1,2730 +0,0 @@ -/* - * Copyright 2019 Amazon.com, Inc. or its affiliates. - * Licensed 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: messages.proto - -package com.amazonaws.services.kinesis.clientlibrary.types; - -public final class Messages { - private Messages() {} - public static void registerAllExtensions( - com.google.protobuf.ExtensionRegistry registry) { - } - public interface TagOrBuilder extends - // @@protoc_insertion_point(interface_extends:Tag) - com.google.protobuf.MessageOrBuilder { - - /** - * required string key = 1; - */ - boolean hasKey(); - /** - * required string key = 1; - */ - java.lang.String getKey(); - /** - * required string key = 1; - */ - com.google.protobuf.ByteString - getKeyBytes(); - - /** - * optional string value = 2; - */ - boolean hasValue(); - /** - * optional string value = 2; - */ - java.lang.String getValue(); - /** - * optional string value = 2; - */ - com.google.protobuf.ByteString - getValueBytes(); - } - /** - * Protobuf type {@code Tag} - */ - public static final class Tag extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:Tag) - TagOrBuilder { - // Use Tag.newBuilder() to construct. - private Tag(com.google.protobuf.GeneratedMessage.Builder builder) { - super(builder); - this.unknownFields = builder.getUnknownFields(); - } - private Tag(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - - private static final Tag defaultInstance; - public static Tag getDefaultInstance() { - return defaultInstance; - } - - public Tag getDefaultInstanceForType() { - return defaultInstance; - } - - private final com.google.protobuf.UnknownFieldSet unknownFields; - @java.lang.Override - public final com.google.protobuf.UnknownFieldSet - getUnknownFields() { - return this.unknownFields; - } - private Tag( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - initFields(); - int mutable_bitField0_ = 0; - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder(); - try { - boolean done = false; - while (!done) { - int tag = input.readTag(); - switch (tag) { - case 0: - done = true; - break; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - done = true; - } - break; - } - case 10: { - com.google.protobuf.ByteString bs = input.readBytes(); - bitField0_ |= 0x00000001; - key_ = bs; - break; - } - case 18: { - com.google.protobuf.ByteString bs = input.readBytes(); - bitField0_ |= 0x00000002; - value_ = bs; - break; - } - } - } - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - throw e.setUnfinishedMessage(this); - } catch (java.io.IOException e) { - throw new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).setUnfinishedMessage(this); - } finally { - this.unknownFields = unknownFields.build(); - makeExtensionsImmutable(); - } - } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_Tag_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_Tag_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.Tag.class, Messages.Tag.Builder.class); - } - - public static com.google.protobuf.Parser PARSER = - new com.google.protobuf.AbstractParser() { - public Tag parsePartialFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return new Tag(input, extensionRegistry); - } - }; - - @java.lang.Override - public com.google.protobuf.Parser getParserForType() { - return PARSER; - } - - private int bitField0_; - public static final int KEY_FIELD_NUMBER = 1; - private java.lang.Object key_; - /** - * required string key = 1; - */ - public boolean hasKey() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * required string key = 1; - */ - public java.lang.String getKey() { - java.lang.Object ref = key_; - if (ref instanceof java.lang.String) { - return (java.lang.String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - java.lang.String s = bs.toStringUtf8(); - if (bs.isValidUtf8()) { - key_ = s; - } - return s; - } - } - /** - * required string key = 1; - */ - public com.google.protobuf.ByteString - getKeyBytes() { - java.lang.Object ref = key_; - if (ref instanceof java.lang.String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8( - (java.lang.String) ref); - key_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - public static final int VALUE_FIELD_NUMBER = 2; - private java.lang.Object value_; - /** - * optional string value = 2; - */ - public boolean hasValue() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - /** - * optional string value = 2; - */ - public java.lang.String getValue() { - java.lang.Object ref = value_; - if (ref instanceof java.lang.String) { - return (java.lang.String) ref; - } else { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - java.lang.String s = bs.toStringUtf8(); - if (bs.isValidUtf8()) { - value_ = s; - } - return s; - } - } - /** - * optional string value = 2; - */ - public com.google.protobuf.ByteString - getValueBytes() { - java.lang.Object ref = value_; - if (ref instanceof java.lang.String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8( - (java.lang.String) ref); - value_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - - private void initFields() { - key_ = ""; - value_ = ""; - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - if (!hasKey()) { - memoizedIsInitialized = 0; - return false; - } - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, getKeyBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeBytes(2, getValueBytes()); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, getKeyBytes()); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(2, getValueBytes()); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static Messages.Tag parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.Tag parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.Tag parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.Tag parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.Tag parseFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.Tag parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - public static Messages.Tag parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input); - } - public static Messages.Tag parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input, extensionRegistry); - } - public static Messages.Tag parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.Tag parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(Messages.Tag prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - /** - * Protobuf type {@code Tag} - */ - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder implements - // @@protoc_insertion_point(builder_implements:Tag) - Messages.TagOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_Tag_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_Tag_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.Tag.class, Messages.Tag.Builder.class); - } - - // Construct using Messages.Tag.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - key_ = ""; - bitField0_ = (bitField0_ & ~0x00000001); - value_ = ""; - bitField0_ = (bitField0_ & ~0x00000002); - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return Messages.internal_static_Tag_descriptor; - } - - public Messages.Tag getDefaultInstanceForType() { - return Messages.Tag.getDefaultInstance(); - } - - public Messages.Tag build() { - Messages.Tag result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - public Messages.Tag buildPartial() { - Messages.Tag result = new Messages.Tag(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.key_ = key_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.value_ = value_; - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof Messages.Tag) { - return mergeFrom((Messages.Tag)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(Messages.Tag other) { - if (other == Messages.Tag.getDefaultInstance()) return this; - if (other.hasKey()) { - bitField0_ |= 0x00000001; - key_ = other.key_; - onChanged(); - } - if (other.hasValue()) { - bitField0_ |= 0x00000002; - value_ = other.value_; - onChanged(); - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasKey()) { - - return false; - } - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Messages.Tag parsedMessage = null; - try { - parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (Messages.Tag) e.getUnfinishedMessage(); - throw e; - } finally { - if (parsedMessage != null) { - mergeFrom(parsedMessage); - } - } - return this; - } - private int bitField0_; - - private java.lang.Object key_ = ""; - /** - * required string key = 1; - */ - public boolean hasKey() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * required string key = 1; - */ - public java.lang.String getKey() { - java.lang.Object ref = key_; - if (!(ref instanceof java.lang.String)) { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - java.lang.String s = bs.toStringUtf8(); - if (bs.isValidUtf8()) { - key_ = s; - } - return s; - } else { - return (java.lang.String) ref; - } - } - /** - * required string key = 1; - */ - public com.google.protobuf.ByteString - getKeyBytes() { - java.lang.Object ref = key_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8( - (java.lang.String) ref); - key_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - /** - * required string key = 1; - */ - public Builder setKey( - java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - key_ = value; - onChanged(); - return this; - } - /** - * required string key = 1; - */ - public Builder clearKey() { - bitField0_ = (bitField0_ & ~0x00000001); - key_ = getDefaultInstance().getKey(); - onChanged(); - return this; - } - /** - * required string key = 1; - */ - public Builder setKeyBytes( - com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000001; - key_ = value; - onChanged(); - return this; - } - - private java.lang.Object value_ = ""; - /** - * optional string value = 2; - */ - public boolean hasValue() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - /** - * optional string value = 2; - */ - public java.lang.String getValue() { - java.lang.Object ref = value_; - if (!(ref instanceof java.lang.String)) { - com.google.protobuf.ByteString bs = - (com.google.protobuf.ByteString) ref; - java.lang.String s = bs.toStringUtf8(); - if (bs.isValidUtf8()) { - value_ = s; - } - return s; - } else { - return (java.lang.String) ref; - } - } - /** - * optional string value = 2; - */ - public com.google.protobuf.ByteString - getValueBytes() { - java.lang.Object ref = value_; - if (ref instanceof String) { - com.google.protobuf.ByteString b = - com.google.protobuf.ByteString.copyFromUtf8( - (java.lang.String) ref); - value_ = b; - return b; - } else { - return (com.google.protobuf.ByteString) ref; - } - } - /** - * optional string value = 2; - */ - public Builder setValue( - java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - value_ = value; - onChanged(); - return this; - } - /** - * optional string value = 2; - */ - public Builder clearValue() { - bitField0_ = (bitField0_ & ~0x00000002); - value_ = getDefaultInstance().getValue(); - onChanged(); - return this; - } - /** - * optional string value = 2; - */ - public Builder setValueBytes( - com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000002; - value_ = value; - onChanged(); - return this; - } - - // @@protoc_insertion_point(builder_scope:Tag) - } - - static { - defaultInstance = new Tag(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:Tag) - } - - public interface RecordOrBuilder extends - // @@protoc_insertion_point(interface_extends:Record) - com.google.protobuf.MessageOrBuilder { - - /** - * required uint64 partition_key_index = 1; - */ - boolean hasPartitionKeyIndex(); - /** - * required uint64 partition_key_index = 1; - */ - long getPartitionKeyIndex(); - - /** - * optional uint64 explicit_hash_key_index = 2; - */ - boolean hasExplicitHashKeyIndex(); - /** - * optional uint64 explicit_hash_key_index = 2; - */ - long getExplicitHashKeyIndex(); - - /** - * required bytes data = 3; - */ - boolean hasData(); - /** - * required bytes data = 3; - */ - com.google.protobuf.ByteString getData(); - - /** - * repeated .Tag tags = 4; - */ - java.util.List - getTagsList(); - /** - * repeated .Tag tags = 4; - */ - Messages.Tag getTags(int index); - /** - * repeated .Tag tags = 4; - */ - int getTagsCount(); - /** - * repeated .Tag tags = 4; - */ - java.util.List - getTagsOrBuilderList(); - /** - * repeated .Tag tags = 4; - */ - Messages.TagOrBuilder getTagsOrBuilder( - int index); - } - /** - * Protobuf type {@code Record} - */ - public static final class Record extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:Record) - RecordOrBuilder { - // Use Record.newBuilder() to construct. - private Record(com.google.protobuf.GeneratedMessage.Builder builder) { - super(builder); - this.unknownFields = builder.getUnknownFields(); - } - private Record(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - - private static final Record defaultInstance; - public static Record getDefaultInstance() { - return defaultInstance; - } - - public Record getDefaultInstanceForType() { - return defaultInstance; - } - - private final com.google.protobuf.UnknownFieldSet unknownFields; - @java.lang.Override - public final com.google.protobuf.UnknownFieldSet - getUnknownFields() { - return this.unknownFields; - } - private Record( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - initFields(); - int mutable_bitField0_ = 0; - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder(); - try { - boolean done = false; - while (!done) { - int tag = input.readTag(); - switch (tag) { - case 0: - done = true; - break; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - done = true; - } - break; - } - case 8: { - bitField0_ |= 0x00000001; - partitionKeyIndex_ = input.readUInt64(); - break; - } - case 16: { - bitField0_ |= 0x00000002; - explicitHashKeyIndex_ = input.readUInt64(); - break; - } - case 26: { - bitField0_ |= 0x00000004; - data_ = input.readBytes(); - break; - } - case 34: { - if (!((mutable_bitField0_ & 0x00000008) == 0x00000008)) { - tags_ = new java.util.ArrayList(); - mutable_bitField0_ |= 0x00000008; - } - tags_.add(input.readMessage(Messages.Tag.PARSER, extensionRegistry)); - break; - } - } - } - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - throw e.setUnfinishedMessage(this); - } catch (java.io.IOException e) { - throw new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).setUnfinishedMessage(this); - } finally { - if (((mutable_bitField0_ & 0x00000008) == 0x00000008)) { - tags_ = java.util.Collections.unmodifiableList(tags_); - } - this.unknownFields = unknownFields.build(); - makeExtensionsImmutable(); - } - } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_Record_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_Record_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.Record.class, Messages.Record.Builder.class); - } - - public static com.google.protobuf.Parser PARSER = - new com.google.protobuf.AbstractParser() { - public Record parsePartialFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return new Record(input, extensionRegistry); - } - }; - - @java.lang.Override - public com.google.protobuf.Parser getParserForType() { - return PARSER; - } - - private int bitField0_; - public static final int PARTITION_KEY_INDEX_FIELD_NUMBER = 1; - private long partitionKeyIndex_; - /** - * required uint64 partition_key_index = 1; - */ - public boolean hasPartitionKeyIndex() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * required uint64 partition_key_index = 1; - */ - public long getPartitionKeyIndex() { - return partitionKeyIndex_; - } - - public static final int EXPLICIT_HASH_KEY_INDEX_FIELD_NUMBER = 2; - private long explicitHashKeyIndex_; - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public boolean hasExplicitHashKeyIndex() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public long getExplicitHashKeyIndex() { - return explicitHashKeyIndex_; - } - - public static final int DATA_FIELD_NUMBER = 3; - private com.google.protobuf.ByteString data_; - /** - * required bytes data = 3; - */ - public boolean hasData() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - /** - * required bytes data = 3; - */ - public com.google.protobuf.ByteString getData() { - return data_; - } - - public static final int TAGS_FIELD_NUMBER = 4; - private java.util.List tags_; - /** - * repeated .Tag tags = 4; - */ - public java.util.List getTagsList() { - return tags_; - } - /** - * repeated .Tag tags = 4; - */ - public java.util.List - getTagsOrBuilderList() { - return tags_; - } - /** - * repeated .Tag tags = 4; - */ - public int getTagsCount() { - return tags_.size(); - } - /** - * repeated .Tag tags = 4; - */ - public Messages.Tag getTags(int index) { - return tags_.get(index); - } - /** - * repeated .Tag tags = 4; - */ - public Messages.TagOrBuilder getTagsOrBuilder( - int index) { - return tags_.get(index); - } - - private void initFields() { - partitionKeyIndex_ = 0L; - explicitHashKeyIndex_ = 0L; - data_ = com.google.protobuf.ByteString.EMPTY; - tags_ = java.util.Collections.emptyList(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - if (!hasPartitionKeyIndex()) { - memoizedIsInitialized = 0; - return false; - } - if (!hasData()) { - memoizedIsInitialized = 0; - return false; - } - for (int i = 0; i < getTagsCount(); i++) { - if (!getTags(i).isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeUInt64(1, partitionKeyIndex_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeUInt64(2, explicitHashKeyIndex_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - output.writeBytes(3, data_); - } - for (int i = 0; i < tags_.size(); i++) { - output.writeMessage(4, tags_.get(i)); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeUInt64Size(1, partitionKeyIndex_); - } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeUInt64Size(2, explicitHashKeyIndex_); - } - if (((bitField0_ & 0x00000004) == 0x00000004)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(3, data_); - } - for (int i = 0; i < tags_.size(); i++) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(4, tags_.get(i)); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static Messages.Record parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.Record parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.Record parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.Record parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.Record parseFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.Record parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - public static Messages.Record parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input); - } - public static Messages.Record parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input, extensionRegistry); - } - public static Messages.Record parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.Record parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(Messages.Record prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - /** - * Protobuf type {@code Record} - */ - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder implements - // @@protoc_insertion_point(builder_implements:Record) - Messages.RecordOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_Record_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_Record_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.Record.class, Messages.Record.Builder.class); - } - - // Construct using Messages.Record.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getTagsFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - partitionKeyIndex_ = 0L; - bitField0_ = (bitField0_ & ~0x00000001); - explicitHashKeyIndex_ = 0L; - bitField0_ = (bitField0_ & ~0x00000002); - data_ = com.google.protobuf.ByteString.EMPTY; - bitField0_ = (bitField0_ & ~0x00000004); - if (tagsBuilder_ == null) { - tags_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000008); - } else { - tagsBuilder_.clear(); - } - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return Messages.internal_static_Record_descriptor; - } - - public Messages.Record getDefaultInstanceForType() { - return Messages.Record.getDefaultInstance(); - } - - public Messages.Record build() { - Messages.Record result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - public Messages.Record buildPartial() { - Messages.Record result = new Messages.Record(this); - int from_bitField0_ = bitField0_; - int to_bitField0_ = 0; - if (((from_bitField0_ & 0x00000001) == 0x00000001)) { - to_bitField0_ |= 0x00000001; - } - result.partitionKeyIndex_ = partitionKeyIndex_; - if (((from_bitField0_ & 0x00000002) == 0x00000002)) { - to_bitField0_ |= 0x00000002; - } - result.explicitHashKeyIndex_ = explicitHashKeyIndex_; - if (((from_bitField0_ & 0x00000004) == 0x00000004)) { - to_bitField0_ |= 0x00000004; - } - result.data_ = data_; - if (tagsBuilder_ == null) { - if (((bitField0_ & 0x00000008) == 0x00000008)) { - tags_ = java.util.Collections.unmodifiableList(tags_); - bitField0_ = (bitField0_ & ~0x00000008); - } - result.tags_ = tags_; - } else { - result.tags_ = tagsBuilder_.build(); - } - result.bitField0_ = to_bitField0_; - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof Messages.Record) { - return mergeFrom((Messages.Record)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(Messages.Record other) { - if (other == Messages.Record.getDefaultInstance()) return this; - if (other.hasPartitionKeyIndex()) { - setPartitionKeyIndex(other.getPartitionKeyIndex()); - } - if (other.hasExplicitHashKeyIndex()) { - setExplicitHashKeyIndex(other.getExplicitHashKeyIndex()); - } - if (other.hasData()) { - setData(other.getData()); - } - if (tagsBuilder_ == null) { - if (!other.tags_.isEmpty()) { - if (tags_.isEmpty()) { - tags_ = other.tags_; - bitField0_ = (bitField0_ & ~0x00000008); - } else { - ensureTagsIsMutable(); - tags_.addAll(other.tags_); - } - onChanged(); - } - } else { - if (!other.tags_.isEmpty()) { - if (tagsBuilder_.isEmpty()) { - tagsBuilder_.dispose(); - tagsBuilder_ = null; - tags_ = other.tags_; - bitField0_ = (bitField0_ & ~0x00000008); - tagsBuilder_ = - com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? - getTagsFieldBuilder() : null; - } else { - tagsBuilder_.addAllMessages(other.tags_); - } - } - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - if (!hasPartitionKeyIndex()) { - - return false; - } - if (!hasData()) { - - return false; - } - for (int i = 0; i < getTagsCount(); i++) { - if (!getTags(i).isInitialized()) { - - return false; - } - } - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Messages.Record parsedMessage = null; - try { - parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (Messages.Record) e.getUnfinishedMessage(); - throw e; - } finally { - if (parsedMessage != null) { - mergeFrom(parsedMessage); - } - } - return this; - } - private int bitField0_; - - private long partitionKeyIndex_ ; - /** - * required uint64 partition_key_index = 1; - */ - public boolean hasPartitionKeyIndex() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * required uint64 partition_key_index = 1; - */ - public long getPartitionKeyIndex() { - return partitionKeyIndex_; - } - /** - * required uint64 partition_key_index = 1; - */ - public Builder setPartitionKeyIndex(long value) { - bitField0_ |= 0x00000001; - partitionKeyIndex_ = value; - onChanged(); - return this; - } - /** - * required uint64 partition_key_index = 1; - */ - public Builder clearPartitionKeyIndex() { - bitField0_ = (bitField0_ & ~0x00000001); - partitionKeyIndex_ = 0L; - onChanged(); - return this; - } - - private long explicitHashKeyIndex_ ; - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public boolean hasExplicitHashKeyIndex() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public long getExplicitHashKeyIndex() { - return explicitHashKeyIndex_; - } - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public Builder setExplicitHashKeyIndex(long value) { - bitField0_ |= 0x00000002; - explicitHashKeyIndex_ = value; - onChanged(); - return this; - } - /** - * optional uint64 explicit_hash_key_index = 2; - */ - public Builder clearExplicitHashKeyIndex() { - bitField0_ = (bitField0_ & ~0x00000002); - explicitHashKeyIndex_ = 0L; - onChanged(); - return this; - } - - private com.google.protobuf.ByteString data_ = com.google.protobuf.ByteString.EMPTY; - /** - * required bytes data = 3; - */ - public boolean hasData() { - return ((bitField0_ & 0x00000004) == 0x00000004); - } - /** - * required bytes data = 3; - */ - public com.google.protobuf.ByteString getData() { - return data_; - } - /** - * required bytes data = 3; - */ - public Builder setData(com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - bitField0_ |= 0x00000004; - data_ = value; - onChanged(); - return this; - } - /** - * required bytes data = 3; - */ - public Builder clearData() { - bitField0_ = (bitField0_ & ~0x00000004); - data_ = getDefaultInstance().getData(); - onChanged(); - return this; - } - - private java.util.List tags_ = - java.util.Collections.emptyList(); - private void ensureTagsIsMutable() { - if (!((bitField0_ & 0x00000008) == 0x00000008)) { - tags_ = new java.util.ArrayList(tags_); - bitField0_ |= 0x00000008; - } - } - - private com.google.protobuf.RepeatedFieldBuilder< - Messages.Tag, Messages.Tag.Builder, Messages.TagOrBuilder> tagsBuilder_; - - /** - * repeated .Tag tags = 4; - */ - public java.util.List getTagsList() { - if (tagsBuilder_ == null) { - return java.util.Collections.unmodifiableList(tags_); - } else { - return tagsBuilder_.getMessageList(); - } - } - /** - * repeated .Tag tags = 4; - */ - public int getTagsCount() { - if (tagsBuilder_ == null) { - return tags_.size(); - } else { - return tagsBuilder_.getCount(); - } - } - /** - * repeated .Tag tags = 4; - */ - public Messages.Tag getTags(int index) { - if (tagsBuilder_ == null) { - return tags_.get(index); - } else { - return tagsBuilder_.getMessage(index); - } - } - /** - * repeated .Tag tags = 4; - */ - public Builder setTags( - int index, Messages.Tag value) { - if (tagsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureTagsIsMutable(); - tags_.set(index, value); - onChanged(); - } else { - tagsBuilder_.setMessage(index, value); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder setTags( - int index, Messages.Tag.Builder builderForValue) { - if (tagsBuilder_ == null) { - ensureTagsIsMutable(); - tags_.set(index, builderForValue.build()); - onChanged(); - } else { - tagsBuilder_.setMessage(index, builderForValue.build()); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder addTags(Messages.Tag value) { - if (tagsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureTagsIsMutable(); - tags_.add(value); - onChanged(); - } else { - tagsBuilder_.addMessage(value); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder addTags( - int index, Messages.Tag value) { - if (tagsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureTagsIsMutable(); - tags_.add(index, value); - onChanged(); - } else { - tagsBuilder_.addMessage(index, value); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder addTags( - Messages.Tag.Builder builderForValue) { - if (tagsBuilder_ == null) { - ensureTagsIsMutable(); - tags_.add(builderForValue.build()); - onChanged(); - } else { - tagsBuilder_.addMessage(builderForValue.build()); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder addTags( - int index, Messages.Tag.Builder builderForValue) { - if (tagsBuilder_ == null) { - ensureTagsIsMutable(); - tags_.add(index, builderForValue.build()); - onChanged(); - } else { - tagsBuilder_.addMessage(index, builderForValue.build()); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder addAllTags( - java.lang.Iterable values) { - if (tagsBuilder_ == null) { - ensureTagsIsMutable(); - com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, tags_); - onChanged(); - } else { - tagsBuilder_.addAllMessages(values); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder clearTags() { - if (tagsBuilder_ == null) { - tags_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000008); - onChanged(); - } else { - tagsBuilder_.clear(); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Builder removeTags(int index) { - if (tagsBuilder_ == null) { - ensureTagsIsMutable(); - tags_.remove(index); - onChanged(); - } else { - tagsBuilder_.remove(index); - } - return this; - } - /** - * repeated .Tag tags = 4; - */ - public Messages.Tag.Builder getTagsBuilder( - int index) { - return getTagsFieldBuilder().getBuilder(index); - } - /** - * repeated .Tag tags = 4; - */ - public Messages.TagOrBuilder getTagsOrBuilder( - int index) { - if (tagsBuilder_ == null) { - return tags_.get(index); } else { - return tagsBuilder_.getMessageOrBuilder(index); - } - } - /** - * repeated .Tag tags = 4; - */ - public java.util.List - getTagsOrBuilderList() { - if (tagsBuilder_ != null) { - return tagsBuilder_.getMessageOrBuilderList(); - } else { - return java.util.Collections.unmodifiableList(tags_); - } - } - /** - * repeated .Tag tags = 4; - */ - public Messages.Tag.Builder addTagsBuilder() { - return getTagsFieldBuilder().addBuilder( - Messages.Tag.getDefaultInstance()); - } - /** - * repeated .Tag tags = 4; - */ - public Messages.Tag.Builder addTagsBuilder( - int index) { - return getTagsFieldBuilder().addBuilder( - index, Messages.Tag.getDefaultInstance()); - } - /** - * repeated .Tag tags = 4; - */ - public java.util.List - getTagsBuilderList() { - return getTagsFieldBuilder().getBuilderList(); - } - private com.google.protobuf.RepeatedFieldBuilder< - Messages.Tag, Messages.Tag.Builder, Messages.TagOrBuilder> - getTagsFieldBuilder() { - if (tagsBuilder_ == null) { - tagsBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< - Messages.Tag, Messages.Tag.Builder, Messages.TagOrBuilder>( - tags_, - ((bitField0_ & 0x00000008) == 0x00000008), - getParentForChildren(), - isClean()); - tags_ = null; - } - return tagsBuilder_; - } - - // @@protoc_insertion_point(builder_scope:Record) - } - - static { - defaultInstance = new Record(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:Record) - } - - public interface AggregatedRecordOrBuilder extends - // @@protoc_insertion_point(interface_extends:AggregatedRecord) - com.google.protobuf.MessageOrBuilder { - - /** - * repeated string partition_key_table = 1; - */ - com.google.protobuf.ProtocolStringList - getPartitionKeyTableList(); - /** - * repeated string partition_key_table = 1; - */ - int getPartitionKeyTableCount(); - /** - * repeated string partition_key_table = 1; - */ - java.lang.String getPartitionKeyTable(int index); - /** - * repeated string partition_key_table = 1; - */ - com.google.protobuf.ByteString - getPartitionKeyTableBytes(int index); - - /** - * repeated string explicit_hash_key_table = 2; - */ - com.google.protobuf.ProtocolStringList - getExplicitHashKeyTableList(); - /** - * repeated string explicit_hash_key_table = 2; - */ - int getExplicitHashKeyTableCount(); - /** - * repeated string explicit_hash_key_table = 2; - */ - java.lang.String getExplicitHashKeyTable(int index); - /** - * repeated string explicit_hash_key_table = 2; - */ - com.google.protobuf.ByteString - getExplicitHashKeyTableBytes(int index); - - /** - * repeated .Record records = 3; - */ - java.util.List - getRecordsList(); - /** - * repeated .Record records = 3; - */ - Messages.Record getRecords(int index); - /** - * repeated .Record records = 3; - */ - int getRecordsCount(); - /** - * repeated .Record records = 3; - */ - java.util.List - getRecordsOrBuilderList(); - /** - * repeated .Record records = 3; - */ - Messages.RecordOrBuilder getRecordsOrBuilder( - int index); - } - /** - * Protobuf type {@code AggregatedRecord} - */ - public static final class AggregatedRecord extends - com.google.protobuf.GeneratedMessage implements - // @@protoc_insertion_point(message_implements:AggregatedRecord) - AggregatedRecordOrBuilder { - // Use AggregatedRecord.newBuilder() to construct. - private AggregatedRecord(com.google.protobuf.GeneratedMessage.Builder builder) { - super(builder); - this.unknownFields = builder.getUnknownFields(); - } - private AggregatedRecord(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - - private static final AggregatedRecord defaultInstance; - public static AggregatedRecord getDefaultInstance() { - return defaultInstance; - } - - public AggregatedRecord getDefaultInstanceForType() { - return defaultInstance; - } - - private final com.google.protobuf.UnknownFieldSet unknownFields; - @java.lang.Override - public final com.google.protobuf.UnknownFieldSet - getUnknownFields() { - return this.unknownFields; - } - private AggregatedRecord( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - initFields(); - int mutable_bitField0_ = 0; - com.google.protobuf.UnknownFieldSet.Builder unknownFields = - com.google.protobuf.UnknownFieldSet.newBuilder(); - try { - boolean done = false; - while (!done) { - int tag = input.readTag(); - switch (tag) { - case 0: - done = true; - break; - default: { - if (!parseUnknownField(input, unknownFields, - extensionRegistry, tag)) { - done = true; - } - break; - } - case 10: { - com.google.protobuf.ByteString bs = input.readBytes(); - if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) { - partitionKeyTable_ = new com.google.protobuf.LazyStringArrayList(); - mutable_bitField0_ |= 0x00000001; - } - partitionKeyTable_.add(bs); - break; - } - case 18: { - com.google.protobuf.ByteString bs = input.readBytes(); - if (!((mutable_bitField0_ & 0x00000002) == 0x00000002)) { - explicitHashKeyTable_ = new com.google.protobuf.LazyStringArrayList(); - mutable_bitField0_ |= 0x00000002; - } - explicitHashKeyTable_.add(bs); - break; - } - case 26: { - if (!((mutable_bitField0_ & 0x00000004) == 0x00000004)) { - records_ = new java.util.ArrayList(); - mutable_bitField0_ |= 0x00000004; - } - records_.add(input.readMessage(Messages.Record.PARSER, extensionRegistry)); - break; - } - } - } - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - throw e.setUnfinishedMessage(this); - } catch (java.io.IOException e) { - throw new com.google.protobuf.InvalidProtocolBufferException( - e.getMessage()).setUnfinishedMessage(this); - } finally { - if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) { - partitionKeyTable_ = partitionKeyTable_.getUnmodifiableView(); - } - if (((mutable_bitField0_ & 0x00000002) == 0x00000002)) { - explicitHashKeyTable_ = explicitHashKeyTable_.getUnmodifiableView(); - } - if (((mutable_bitField0_ & 0x00000004) == 0x00000004)) { - records_ = java.util.Collections.unmodifiableList(records_); - } - this.unknownFields = unknownFields.build(); - makeExtensionsImmutable(); - } - } - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_AggregatedRecord_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_AggregatedRecord_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.AggregatedRecord.class, Messages.AggregatedRecord.Builder.class); - } - - public static com.google.protobuf.Parser PARSER = - new com.google.protobuf.AbstractParser() { - public AggregatedRecord parsePartialFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return new AggregatedRecord(input, extensionRegistry); - } - }; - - @java.lang.Override - public com.google.protobuf.Parser getParserForType() { - return PARSER; - } - - public static final int PARTITION_KEY_TABLE_FIELD_NUMBER = 1; - private com.google.protobuf.LazyStringList partitionKeyTable_; - /** - * repeated string partition_key_table = 1; - */ - public com.google.protobuf.ProtocolStringList - getPartitionKeyTableList() { - return partitionKeyTable_; - } - /** - * repeated string partition_key_table = 1; - */ - public int getPartitionKeyTableCount() { - return partitionKeyTable_.size(); - } - /** - * repeated string partition_key_table = 1; - */ - public java.lang.String getPartitionKeyTable(int index) { - return partitionKeyTable_.get(index); - } - /** - * repeated string partition_key_table = 1; - */ - public com.google.protobuf.ByteString - getPartitionKeyTableBytes(int index) { - return partitionKeyTable_.getByteString(index); - } - - public static final int EXPLICIT_HASH_KEY_TABLE_FIELD_NUMBER = 2; - private com.google.protobuf.LazyStringList explicitHashKeyTable_; - /** - * repeated string explicit_hash_key_table = 2; - */ - public com.google.protobuf.ProtocolStringList - getExplicitHashKeyTableList() { - return explicitHashKeyTable_; - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public int getExplicitHashKeyTableCount() { - return explicitHashKeyTable_.size(); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public java.lang.String getExplicitHashKeyTable(int index) { - return explicitHashKeyTable_.get(index); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public com.google.protobuf.ByteString - getExplicitHashKeyTableBytes(int index) { - return explicitHashKeyTable_.getByteString(index); - } - - public static final int RECORDS_FIELD_NUMBER = 3; - private java.util.List records_; - /** - * repeated .Record records = 3; - */ - public java.util.List getRecordsList() { - return records_; - } - /** - * repeated .Record records = 3; - */ - public java.util.List - getRecordsOrBuilderList() { - return records_; - } - /** - * repeated .Record records = 3; - */ - public int getRecordsCount() { - return records_.size(); - } - /** - * repeated .Record records = 3; - */ - public Messages.Record getRecords(int index) { - return records_.get(index); - } - /** - * repeated .Record records = 3; - */ - public Messages.RecordOrBuilder getRecordsOrBuilder( - int index) { - return records_.get(index); - } - - private void initFields() { - partitionKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - explicitHashKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - records_ = java.util.Collections.emptyList(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - for (int i = 0; i < getRecordsCount(); i++) { - if (!getRecords(i).isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - memoizedIsInitialized = 1; - return true; - } - - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - for (int i = 0; i < partitionKeyTable_.size(); i++) { - output.writeBytes(1, partitionKeyTable_.getByteString(i)); - } - for (int i = 0; i < explicitHashKeyTable_.size(); i++) { - output.writeBytes(2, explicitHashKeyTable_.getByteString(i)); - } - for (int i = 0; i < records_.size(); i++) { - output.writeMessage(3, records_.get(i)); - } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - - size = 0; - { - int dataSize = 0; - for (int i = 0; i < partitionKeyTable_.size(); i++) { - dataSize += com.google.protobuf.CodedOutputStream - .computeBytesSizeNoTag(partitionKeyTable_.getByteString(i)); - } - size += dataSize; - size += 1 * getPartitionKeyTableList().size(); - } - { - int dataSize = 0; - for (int i = 0; i < explicitHashKeyTable_.size(); i++) { - dataSize += com.google.protobuf.CodedOutputStream - .computeBytesSizeNoTag(explicitHashKeyTable_.getByteString(i)); - } - size += dataSize; - size += 1 * getExplicitHashKeyTableList().size(); - } - for (int i = 0; i < records_.size(); i++) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(3, records_.get(i)); - } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - - private static final long serialVersionUID = 0L; - @java.lang.Override - protected java.lang.Object writeReplace() - throws java.io.ObjectStreamException { - return super.writeReplace(); - } - - public static Messages.AggregatedRecord parseFrom( - com.google.protobuf.ByteString data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.AggregatedRecord parseFrom( - com.google.protobuf.ByteString data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.AggregatedRecord parseFrom(byte[] data) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data); - } - public static Messages.AggregatedRecord parseFrom( - byte[] data, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws com.google.protobuf.InvalidProtocolBufferException { - return PARSER.parseFrom(data, extensionRegistry); - } - public static Messages.AggregatedRecord parseFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.AggregatedRecord parseFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - public static Messages.AggregatedRecord parseDelimitedFrom(java.io.InputStream input) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input); - } - public static Messages.AggregatedRecord parseDelimitedFrom( - java.io.InputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseDelimitedFrom(input, extensionRegistry); - } - public static Messages.AggregatedRecord parseFrom( - com.google.protobuf.CodedInputStream input) - throws java.io.IOException { - return PARSER.parseFrom(input); - } - public static Messages.AggregatedRecord parseFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - return PARSER.parseFrom(input, extensionRegistry); - } - - public static Builder newBuilder() { return Builder.create(); } - public Builder newBuilderForType() { return newBuilder(); } - public static Builder newBuilder(Messages.AggregatedRecord prototype) { - return newBuilder().mergeFrom(prototype); - } - public Builder toBuilder() { return newBuilder(this); } - - @java.lang.Override - protected Builder newBuilderForType( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - Builder builder = new Builder(parent); - return builder; - } - /** - * Protobuf type {@code AggregatedRecord} - */ - public static final class Builder extends - com.google.protobuf.GeneratedMessage.Builder implements - // @@protoc_insertion_point(builder_implements:AggregatedRecord) - Messages.AggregatedRecordOrBuilder { - public static final com.google.protobuf.Descriptors.Descriptor - getDescriptor() { - return Messages.internal_static_AggregatedRecord_descriptor; - } - - protected com.google.protobuf.GeneratedMessage.FieldAccessorTable - internalGetFieldAccessorTable() { - return Messages.internal_static_AggregatedRecord_fieldAccessorTable - .ensureFieldAccessorsInitialized( - Messages.AggregatedRecord.class, Messages.AggregatedRecord.Builder.class); - } - - // Construct using Messages.AggregatedRecord.newBuilder() - private Builder() { - maybeForceBuilderInitialization(); - } - - private Builder( - com.google.protobuf.GeneratedMessage.BuilderParent parent) { - super(parent); - maybeForceBuilderInitialization(); - } - private void maybeForceBuilderInitialization() { - if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { - getRecordsFieldBuilder(); - } - } - private static Builder create() { - return new Builder(); - } - - public Builder clear() { - super.clear(); - partitionKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - explicitHashKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000002); - if (recordsBuilder_ == null) { - records_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000004); - } else { - recordsBuilder_.clear(); - } - return this; - } - - public Builder clone() { - return create().mergeFrom(buildPartial()); - } - - public com.google.protobuf.Descriptors.Descriptor - getDescriptorForType() { - return Messages.internal_static_AggregatedRecord_descriptor; - } - - public Messages.AggregatedRecord getDefaultInstanceForType() { - return Messages.AggregatedRecord.getDefaultInstance(); - } - - public Messages.AggregatedRecord build() { - Messages.AggregatedRecord result = buildPartial(); - if (!result.isInitialized()) { - throw newUninitializedMessageException(result); - } - return result; - } - - public Messages.AggregatedRecord buildPartial() { - Messages.AggregatedRecord result = new Messages.AggregatedRecord(this); - int from_bitField0_ = bitField0_; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - partitionKeyTable_ = partitionKeyTable_.getUnmodifiableView(); - bitField0_ = (bitField0_ & ~0x00000001); - } - result.partitionKeyTable_ = partitionKeyTable_; - if (((bitField0_ & 0x00000002) == 0x00000002)) { - explicitHashKeyTable_ = explicitHashKeyTable_.getUnmodifiableView(); - bitField0_ = (bitField0_ & ~0x00000002); - } - result.explicitHashKeyTable_ = explicitHashKeyTable_; - if (recordsBuilder_ == null) { - if (((bitField0_ & 0x00000004) == 0x00000004)) { - records_ = java.util.Collections.unmodifiableList(records_); - bitField0_ = (bitField0_ & ~0x00000004); - } - result.records_ = records_; - } else { - result.records_ = recordsBuilder_.build(); - } - onBuilt(); - return result; - } - - public Builder mergeFrom(com.google.protobuf.Message other) { - if (other instanceof Messages.AggregatedRecord) { - return mergeFrom((Messages.AggregatedRecord)other); - } else { - super.mergeFrom(other); - return this; - } - } - - public Builder mergeFrom(Messages.AggregatedRecord other) { - if (other == Messages.AggregatedRecord.getDefaultInstance()) return this; - if (!other.partitionKeyTable_.isEmpty()) { - if (partitionKeyTable_.isEmpty()) { - partitionKeyTable_ = other.partitionKeyTable_; - bitField0_ = (bitField0_ & ~0x00000001); - } else { - ensurePartitionKeyTableIsMutable(); - partitionKeyTable_.addAll(other.partitionKeyTable_); - } - onChanged(); - } - if (!other.explicitHashKeyTable_.isEmpty()) { - if (explicitHashKeyTable_.isEmpty()) { - explicitHashKeyTable_ = other.explicitHashKeyTable_; - bitField0_ = (bitField0_ & ~0x00000002); - } else { - ensureExplicitHashKeyTableIsMutable(); - explicitHashKeyTable_.addAll(other.explicitHashKeyTable_); - } - onChanged(); - } - if (recordsBuilder_ == null) { - if (!other.records_.isEmpty()) { - if (records_.isEmpty()) { - records_ = other.records_; - bitField0_ = (bitField0_ & ~0x00000004); - } else { - ensureRecordsIsMutable(); - records_.addAll(other.records_); - } - onChanged(); - } - } else { - if (!other.records_.isEmpty()) { - if (recordsBuilder_.isEmpty()) { - recordsBuilder_.dispose(); - recordsBuilder_ = null; - records_ = other.records_; - bitField0_ = (bitField0_ & ~0x00000004); - recordsBuilder_ = - com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? - getRecordsFieldBuilder() : null; - } else { - recordsBuilder_.addAllMessages(other.records_); - } - } - } - this.mergeUnknownFields(other.getUnknownFields()); - return this; - } - - public final boolean isInitialized() { - for (int i = 0; i < getRecordsCount(); i++) { - if (!getRecords(i).isInitialized()) { - - return false; - } - } - return true; - } - - public Builder mergeFrom( - com.google.protobuf.CodedInputStream input, - com.google.protobuf.ExtensionRegistryLite extensionRegistry) - throws java.io.IOException { - Messages.AggregatedRecord parsedMessage = null; - try { - parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); - } catch (com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (Messages.AggregatedRecord) e.getUnfinishedMessage(); - throw e; - } finally { - if (parsedMessage != null) { - mergeFrom(parsedMessage); - } - } - return this; - } - private int bitField0_; - - private com.google.protobuf.LazyStringList partitionKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - private void ensurePartitionKeyTableIsMutable() { - if (!((bitField0_ & 0x00000001) == 0x00000001)) { - partitionKeyTable_ = new com.google.protobuf.LazyStringArrayList(partitionKeyTable_); - bitField0_ |= 0x00000001; - } - } - /** - * repeated string partition_key_table = 1; - */ - public com.google.protobuf.ProtocolStringList - getPartitionKeyTableList() { - return partitionKeyTable_.getUnmodifiableView(); - } - /** - * repeated string partition_key_table = 1; - */ - public int getPartitionKeyTableCount() { - return partitionKeyTable_.size(); - } - /** - * repeated string partition_key_table = 1; - */ - public java.lang.String getPartitionKeyTable(int index) { - return partitionKeyTable_.get(index); - } - /** - * repeated string partition_key_table = 1; - */ - public com.google.protobuf.ByteString - getPartitionKeyTableBytes(int index) { - return partitionKeyTable_.getByteString(index); - } - /** - * repeated string partition_key_table = 1; - */ - public Builder setPartitionKeyTable( - int index, java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensurePartitionKeyTableIsMutable(); - partitionKeyTable_.set(index, value); - onChanged(); - return this; - } - /** - * repeated string partition_key_table = 1; - */ - public Builder addPartitionKeyTable( - java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensurePartitionKeyTableIsMutable(); - partitionKeyTable_.add(value); - onChanged(); - return this; - } - /** - * repeated string partition_key_table = 1; - */ - public Builder addAllPartitionKeyTable( - java.lang.Iterable values) { - ensurePartitionKeyTableIsMutable(); - com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, partitionKeyTable_); - onChanged(); - return this; - } - /** - * repeated string partition_key_table = 1; - */ - public Builder clearPartitionKeyTable() { - partitionKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000001); - onChanged(); - return this; - } - /** - * repeated string partition_key_table = 1; - */ - public Builder addPartitionKeyTableBytes( - com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - ensurePartitionKeyTableIsMutable(); - partitionKeyTable_.add(value); - onChanged(); - return this; - } - - private com.google.protobuf.LazyStringList explicitHashKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - private void ensureExplicitHashKeyTableIsMutable() { - if (!((bitField0_ & 0x00000002) == 0x00000002)) { - explicitHashKeyTable_ = new com.google.protobuf.LazyStringArrayList(explicitHashKeyTable_); - bitField0_ |= 0x00000002; - } - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public com.google.protobuf.ProtocolStringList - getExplicitHashKeyTableList() { - return explicitHashKeyTable_.getUnmodifiableView(); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public int getExplicitHashKeyTableCount() { - return explicitHashKeyTable_.size(); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public java.lang.String getExplicitHashKeyTable(int index) { - return explicitHashKeyTable_.get(index); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public com.google.protobuf.ByteString - getExplicitHashKeyTableBytes(int index) { - return explicitHashKeyTable_.getByteString(index); - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public Builder setExplicitHashKeyTable( - int index, java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureExplicitHashKeyTableIsMutable(); - explicitHashKeyTable_.set(index, value); - onChanged(); - return this; - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public Builder addExplicitHashKeyTable( - java.lang.String value) { - if (value == null) { - throw new NullPointerException(); - } - ensureExplicitHashKeyTableIsMutable(); - explicitHashKeyTable_.add(value); - onChanged(); - return this; - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public Builder addAllExplicitHashKeyTable( - java.lang.Iterable values) { - ensureExplicitHashKeyTableIsMutable(); - com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, explicitHashKeyTable_); - onChanged(); - return this; - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public Builder clearExplicitHashKeyTable() { - explicitHashKeyTable_ = com.google.protobuf.LazyStringArrayList.EMPTY; - bitField0_ = (bitField0_ & ~0x00000002); - onChanged(); - return this; - } - /** - * repeated string explicit_hash_key_table = 2; - */ - public Builder addExplicitHashKeyTableBytes( - com.google.protobuf.ByteString value) { - if (value == null) { - throw new NullPointerException(); - } - ensureExplicitHashKeyTableIsMutable(); - explicitHashKeyTable_.add(value); - onChanged(); - return this; - } - - private java.util.List records_ = - java.util.Collections.emptyList(); - private void ensureRecordsIsMutable() { - if (!((bitField0_ & 0x00000004) == 0x00000004)) { - records_ = new java.util.ArrayList(records_); - bitField0_ |= 0x00000004; - } - } - - private com.google.protobuf.RepeatedFieldBuilder< - Messages.Record, Messages.Record.Builder, Messages.RecordOrBuilder> recordsBuilder_; - - /** - * repeated .Record records = 3; - */ - public java.util.List getRecordsList() { - if (recordsBuilder_ == null) { - return java.util.Collections.unmodifiableList(records_); - } else { - return recordsBuilder_.getMessageList(); - } - } - /** - * repeated .Record records = 3; - */ - public int getRecordsCount() { - if (recordsBuilder_ == null) { - return records_.size(); - } else { - return recordsBuilder_.getCount(); - } - } - /** - * repeated .Record records = 3; - */ - public Messages.Record getRecords(int index) { - if (recordsBuilder_ == null) { - return records_.get(index); - } else { - return recordsBuilder_.getMessage(index); - } - } - /** - * repeated .Record records = 3; - */ - public Builder setRecords( - int index, Messages.Record value) { - if (recordsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureRecordsIsMutable(); - records_.set(index, value); - onChanged(); - } else { - recordsBuilder_.setMessage(index, value); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder setRecords( - int index, Messages.Record.Builder builderForValue) { - if (recordsBuilder_ == null) { - ensureRecordsIsMutable(); - records_.set(index, builderForValue.build()); - onChanged(); - } else { - recordsBuilder_.setMessage(index, builderForValue.build()); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder addRecords(Messages.Record value) { - if (recordsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureRecordsIsMutable(); - records_.add(value); - onChanged(); - } else { - recordsBuilder_.addMessage(value); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder addRecords( - int index, Messages.Record value) { - if (recordsBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureRecordsIsMutable(); - records_.add(index, value); - onChanged(); - } else { - recordsBuilder_.addMessage(index, value); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder addRecords( - Messages.Record.Builder builderForValue) { - if (recordsBuilder_ == null) { - ensureRecordsIsMutable(); - records_.add(builderForValue.build()); - onChanged(); - } else { - recordsBuilder_.addMessage(builderForValue.build()); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder addRecords( - int index, Messages.Record.Builder builderForValue) { - if (recordsBuilder_ == null) { - ensureRecordsIsMutable(); - records_.add(index, builderForValue.build()); - onChanged(); - } else { - recordsBuilder_.addMessage(index, builderForValue.build()); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder addAllRecords( - java.lang.Iterable values) { - if (recordsBuilder_ == null) { - ensureRecordsIsMutable(); - com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, records_); - onChanged(); - } else { - recordsBuilder_.addAllMessages(values); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder clearRecords() { - if (recordsBuilder_ == null) { - records_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000004); - onChanged(); - } else { - recordsBuilder_.clear(); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Builder removeRecords(int index) { - if (recordsBuilder_ == null) { - ensureRecordsIsMutable(); - records_.remove(index); - onChanged(); - } else { - recordsBuilder_.remove(index); - } - return this; - } - /** - * repeated .Record records = 3; - */ - public Messages.Record.Builder getRecordsBuilder( - int index) { - return getRecordsFieldBuilder().getBuilder(index); - } - /** - * repeated .Record records = 3; - */ - public Messages.RecordOrBuilder getRecordsOrBuilder( - int index) { - if (recordsBuilder_ == null) { - return records_.get(index); } else { - return recordsBuilder_.getMessageOrBuilder(index); - } - } - /** - * repeated .Record records = 3; - */ - public java.util.List - getRecordsOrBuilderList() { - if (recordsBuilder_ != null) { - return recordsBuilder_.getMessageOrBuilderList(); - } else { - return java.util.Collections.unmodifiableList(records_); - } - } - /** - * repeated .Record records = 3; - */ - public Messages.Record.Builder addRecordsBuilder() { - return getRecordsFieldBuilder().addBuilder( - Messages.Record.getDefaultInstance()); - } - /** - * repeated .Record records = 3; - */ - public Messages.Record.Builder addRecordsBuilder( - int index) { - return getRecordsFieldBuilder().addBuilder( - index, Messages.Record.getDefaultInstance()); - } - /** - * repeated .Record records = 3; - */ - public java.util.List - getRecordsBuilderList() { - return getRecordsFieldBuilder().getBuilderList(); - } - private com.google.protobuf.RepeatedFieldBuilder< - Messages.Record, Messages.Record.Builder, Messages.RecordOrBuilder> - getRecordsFieldBuilder() { - if (recordsBuilder_ == null) { - recordsBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< - Messages.Record, Messages.Record.Builder, Messages.RecordOrBuilder>( - records_, - ((bitField0_ & 0x00000004) == 0x00000004), - getParentForChildren(), - isClean()); - records_ = null; - } - return recordsBuilder_; - } - - // @@protoc_insertion_point(builder_scope:AggregatedRecord) - } - - static { - defaultInstance = new AggregatedRecord(true); - defaultInstance.initFields(); - } - - // @@protoc_insertion_point(class_scope:AggregatedRecord) - } - - private static final com.google.protobuf.Descriptors.Descriptor - internal_static_Tag_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_Tag_fieldAccessorTable; - private static final com.google.protobuf.Descriptors.Descriptor - internal_static_Record_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_Record_fieldAccessorTable; - private static final com.google.protobuf.Descriptors.Descriptor - internal_static_AggregatedRecord_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_AggregatedRecord_fieldAccessorTable; - - public static com.google.protobuf.Descriptors.FileDescriptor - getDescriptor() { - return descriptor; - } - private static com.google.protobuf.Descriptors.FileDescriptor - descriptor; - static { - java.lang.String[] descriptorData = { - "\n\016messages.proto\"!\n\003Tag\022\013\n\003key\030\001 \002(\t\022\r\n\005" + - "value\030\002 \001(\t\"h\n\006Record\022\033\n\023partition_key_i" + - "ndex\030\001 \002(\004\022\037\n\027explicit_hash_key_index\030\002 " + - "\001(\004\022\014\n\004data\030\003 \002(\014\022\022\n\004tags\030\004 \003(\0132\004.Tag\"j\n" + - "\020AggregatedRecord\022\033\n\023partition_key_table" + - "\030\001 \003(\t\022\037\n\027explicit_hash_key_table\030\002 \003(\t\022" + - "\030\n\007records\030\003 \003(\0132\007.Record" - }; - com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = - new com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() { - public com.google.protobuf.ExtensionRegistry assignDescriptors( - com.google.protobuf.Descriptors.FileDescriptor root) { - descriptor = root; - return null; - } - }; - com.google.protobuf.Descriptors.FileDescriptor - .internalBuildGeneratedFileFrom(descriptorData, - new com.google.protobuf.Descriptors.FileDescriptor[] { - }, assigner); - internal_static_Tag_descriptor = - getDescriptor().getMessageTypes().get(0); - internal_static_Tag_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_Tag_descriptor, - new java.lang.String[] { "Key", "Value", }); - internal_static_Record_descriptor = - getDescriptor().getMessageTypes().get(1); - internal_static_Record_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_Record_descriptor, - new java.lang.String[] { "PartitionKeyIndex", "ExplicitHashKeyIndex", "Data", "Tags", }); - internal_static_AggregatedRecord_descriptor = - getDescriptor().getMessageTypes().get(2); - internal_static_AggregatedRecord_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_AggregatedRecord_descriptor, - new java.lang.String[] { "PartitionKeyTable", "ExplicitHashKeyTable", "Records", }); - } - - // @@protoc_insertion_point(outer_class_scope) -} diff --git a/src/main/proto/messages.proto b/src/main/proto/messages.proto new file mode 100644 index 000000000..823ea0edc --- /dev/null +++ b/src/main/proto/messages.proto @@ -0,0 +1,23 @@ +// Copied from amazon-kinesis-producer/aws/kinesis/protobuf/messages.proto with +// subset of messages that KCL needs + +syntax = "proto2"; +package com.amazonaws.services.kinesis.clientlibrary.types; + +message Tag { + required string key = 1; + optional string value = 2; +} + +message Record { + required uint64 partition_key_index = 1; + optional uint64 explicit_hash_key_index = 2; + required bytes data = 3; + repeated Tag tags = 4; +} + +message AggregatedRecord { + repeated string partition_key_table = 1; + repeated string explicit_hash_key_table = 2; + repeated Record records = 3; +}