}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionInitRequest)
}
static {
defaultInstance = new TransactionInitRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionInitRequest)
}
public static final class TransactionInitResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionInitResponse.newBuilder() to construct.
private TransactionInitResponse() {
initFields();
}
private TransactionInitResponse(boolean noInit) {}
private static final TransactionInitResponse defaultInstance;
public static TransactionInitResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionInitResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionInitResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionInitResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
// optional int32 reject_partition = 4;
public static final int REJECT_PARTITION_FIELD_NUMBER = 4;
private boolean hasRejectPartition;
private int rejectPartition_ = 0;
public boolean hasRejectPartition() { return hasRejectPartition; }
public int getRejectPartition() { return rejectPartition_; }
// optional int64 reject_transaction_id = 5;
public static final int REJECT_TRANSACTION_ID_FIELD_NUMBER = 5;
private boolean hasRejectTransactionId;
private long rejectTransactionId_ = 0L;
public boolean hasRejectTransactionId() { return hasRejectTransactionId; }
public long getRejectTransactionId() { return rejectTransactionId_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
if (hasRejectPartition()) {
output.writeInt32(4, getRejectPartition());
}
if (hasRejectTransactionId()) {
output.writeInt64(5, getRejectTransactionId());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
if (hasRejectPartition()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(4, getRejectPartition());
}
if (hasRejectTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(5, getRejectTransactionId());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionInitResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionInitResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionInitResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionInitResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionInitResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionInitResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionInitResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionInitResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionInitResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionInitResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionInitResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionInitResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionInitResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionInitResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionInitResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionInitResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionInitResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionInitResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
if (other.hasRejectPartition()) {
setRejectPartition(other.getRejectPartition());
}
if (other.hasRejectTransactionId()) {
setRejectTransactionId(other.getRejectTransactionId());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
case 32: {
setRejectPartition(input.readInt32());
break;
}
case 40: {
setRejectTransactionId(input.readInt64());
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// optional int32 reject_partition = 4;
public boolean hasRejectPartition() {
return result.hasRejectPartition();
}
public int getRejectPartition() {
return result.getRejectPartition();
}
public Builder setRejectPartition(int value) {
result.hasRejectPartition = true;
result.rejectPartition_ = value;
return this;
}
public Builder clearRejectPartition() {
result.hasRejectPartition = false;
result.rejectPartition_ = 0;
return this;
}
// optional int64 reject_transaction_id = 5;
public boolean hasRejectTransactionId() {
return result.hasRejectTransactionId();
}
public long getRejectTransactionId() {
return result.getRejectTransactionId();
}
public Builder setRejectTransactionId(long value) {
result.hasRejectTransactionId = true;
result.rejectTransactionId_ = value;
return this;
}
public Builder clearRejectTransactionId() {
result.hasRejectTransactionId = false;
result.rejectTransactionId_ = 0L;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionInitResponse)
}
static {
defaultInstance = new TransactionInitResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionInitResponse)
}
public static final class TransactionWorkRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionWorkRequest.newBuilder() to construct.
private TransactionWorkRequest() {
initFields();
}
private TransactionWorkRequest(boolean noInit) {}
private static final TransactionWorkRequest defaultInstance;
public static TransactionWorkRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionWorkRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_fieldAccessorTable;
}
public static final class InputDependency extends
com.google.protobuf.GeneratedMessage {
// Use InputDependency.newBuilder() to construct.
private InputDependency() {
initFields();
}
private InputDependency(boolean noInit) {}
private static final InputDependency defaultInstance;
public static InputDependency getDefaultInstance() {
return defaultInstance;
}
public InputDependency getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_InputDependency_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_InputDependency_fieldAccessorTable;
}
// repeated int32 ids = 1;
public static final int IDS_FIELD_NUMBER = 1;
private java.util.List ids_ =
java.util.Collections.emptyList();
public java.util.List getIdsList() {
return ids_;
}
public int getIdsCount() { return ids_.size(); }
public int getIds(int index) {
return ids_.get(index);
}
private void initFields() {
}
public final boolean isInitialized() {
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
for (int element : getIdsList()) {
output.writeInt32(1, element);
}
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 element : getIdsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
size += 1 * getIdsList().size();
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency prototype) {
return newBuilder().mergeFrom(prototype);
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency result;
// Construct using edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.ids_ != java.util.Collections.EMPTY_LIST) {
result.ids_ =
java.util.Collections.unmodifiableList(result.ids_);
}
edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency other) {
if (other == edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.getDefaultInstance()) return this;
if (!other.ids_.isEmpty()) {
if (result.ids_.isEmpty()) {
result.ids_ = new java.util.ArrayList();
}
result.ids_.addAll(other.ids_);
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
addIds(input.readInt32());
break;
}
case 10: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addIds(input.readInt32());
}
input.popLimit(limit);
break;
}
}
}
}
// repeated int32 ids = 1;
public java.util.List getIdsList() {
return java.util.Collections.unmodifiableList(result.ids_);
}
public int getIdsCount() {
return result.getIdsCount();
}
public int getIds(int index) {
return result.getIds(index);
}
public Builder setIds(int index, int value) {
result.ids_.set(index, value);
return this;
}
public Builder addIds(int value) {
if (result.ids_.isEmpty()) {
result.ids_ = new java.util.ArrayList();
}
result.ids_.add(value);
return this;
}
public Builder addAllIds(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.ids_.isEmpty()) {
result.ids_ = new java.util.ArrayList();
}
super.addAll(values, result.ids_);
return this;
}
public Builder clearIds() {
result.ids_ = java.util.Collections.emptyList();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionWorkRequest.InputDependency)
}
static {
defaultInstance = new InputDependency(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionWorkRequest.InputDependency)
}
public static final class PartitionFragment extends
com.google.protobuf.GeneratedMessage {
// Use PartitionFragment.newBuilder() to construct.
private PartitionFragment() {
initFields();
}
private PartitionFragment(boolean noInit) {}
private static final PartitionFragment defaultInstance;
public static PartitionFragment getDefaultInstance() {
return defaultInstance;
}
public PartitionFragment getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_PartitionFragment_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkRequest_PartitionFragment_fieldAccessorTable;
}
// required int32 partition_id = 1;
public static final int PARTITION_ID_FIELD_NUMBER = 1;
private boolean hasPartitionId;
private int partitionId_ = 0;
public boolean hasPartitionId() { return hasPartitionId; }
public int getPartitionId() { return partitionId_; }
// repeated int32 fragment_id = 2 [packed = true];
public static final int FRAGMENT_ID_FIELD_NUMBER = 2;
private java.util.List fragmentId_ =
java.util.Collections.emptyList();
public java.util.List getFragmentIdList() {
return fragmentId_;
}
public int getFragmentIdCount() { return fragmentId_.size(); }
public int getFragmentId(int index) {
return fragmentId_.get(index);
}
private int fragmentIdMemoizedSerializedSize = -1;
// repeated .edu.brown.hstore.TransactionWorkRequest.InputDependency input_dep_id = 3;
public static final int INPUT_DEP_ID_FIELD_NUMBER = 3;
private java.util.List inputDepId_ =
java.util.Collections.emptyList();
public java.util.List getInputDepIdList() {
return inputDepId_;
}
public int getInputDepIdCount() { return inputDepId_.size(); }
public edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency getInputDepId(int index) {
return inputDepId_.get(index);
}
// repeated int32 output_dep_id = 4 [packed = true];
public static final int OUTPUT_DEP_ID_FIELD_NUMBER = 4;
private java.util.List outputDepId_ =
java.util.Collections.emptyList();
public java.util.List getOutputDepIdList() {
return outputDepId_;
}
public int getOutputDepIdCount() { return outputDepId_.size(); }
public int getOutputDepId(int index) {
return outputDepId_.get(index);
}
private int outputDepIdMemoizedSerializedSize = -1;
// repeated int32 stmt_index = 5 [packed = true];
public static final int STMT_INDEX_FIELD_NUMBER = 5;
private java.util.List stmtIndex_ =
java.util.Collections.emptyList();
public java.util.List getStmtIndexList() {
return stmtIndex_;
}
public int getStmtIndexCount() { return stmtIndex_.size(); }
public int getStmtIndex(int index) {
return stmtIndex_.get(index);
}
private int stmtIndexMemoizedSerializedSize = -1;
// required bool read_only = 6;
public static final int READ_ONLY_FIELD_NUMBER = 6;
private boolean hasReadOnly;
private boolean readOnly_ = false;
public boolean hasReadOnly() { return hasReadOnly; }
public boolean getReadOnly() { return readOnly_; }
// required bool needs_input = 7;
public static final int NEEDS_INPUT_FIELD_NUMBER = 7;
private boolean hasNeedsInput;
private boolean needsInput_ = false;
public boolean hasNeedsInput() { return hasNeedsInput; }
public boolean getNeedsInput() { return needsInput_; }
// optional bool last_fragment = 8 [default = false];
public static final int LAST_FRAGMENT_FIELD_NUMBER = 8;
private boolean hasLastFragment;
private boolean lastFragment_ = false;
public boolean hasLastFragment() { return hasLastFragment; }
public boolean getLastFragment() { return lastFragment_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasPartitionId) return false;
if (!hasReadOnly) return false;
if (!hasNeedsInput) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasPartitionId()) {
output.writeInt32(1, getPartitionId());
}
if (getFragmentIdList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(fragmentIdMemoizedSerializedSize);
}
for (int element : getFragmentIdList()) {
output.writeInt32NoTag(element);
}
for (edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency element : getInputDepIdList()) {
output.writeMessage(3, element);
}
if (getOutputDepIdList().size() > 0) {
output.writeRawVarint32(34);
output.writeRawVarint32(outputDepIdMemoizedSerializedSize);
}
for (int element : getOutputDepIdList()) {
output.writeInt32NoTag(element);
}
if (getStmtIndexList().size() > 0) {
output.writeRawVarint32(42);
output.writeRawVarint32(stmtIndexMemoizedSerializedSize);
}
for (int element : getStmtIndexList()) {
output.writeInt32NoTag(element);
}
if (hasReadOnly()) {
output.writeBool(6, getReadOnly());
}
if (hasNeedsInput()) {
output.writeBool(7, getNeedsInput());
}
if (hasLastFragment()) {
output.writeBool(8, getLastFragment());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasPartitionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getPartitionId());
}
{
int dataSize = 0;
for (int element : getFragmentIdList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getFragmentIdList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
fragmentIdMemoizedSerializedSize = dataSize;
}
for (edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency element : getInputDepIdList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, element);
}
{
int dataSize = 0;
for (int element : getOutputDepIdList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getOutputDepIdList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
outputDepIdMemoizedSerializedSize = dataSize;
}
{
int dataSize = 0;
for (int element : getStmtIndexList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getStmtIndexList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
stmtIndexMemoizedSerializedSize = dataSize;
}
if (hasReadOnly()) {
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(6, getReadOnly());
}
if (hasNeedsInput()) {
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(7, getNeedsInput());
}
if (hasLastFragment()) {
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(8, getLastFragment());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment result;
// Construct using edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.fragmentId_ != java.util.Collections.EMPTY_LIST) {
result.fragmentId_ =
java.util.Collections.unmodifiableList(result.fragmentId_);
}
if (result.inputDepId_ != java.util.Collections.EMPTY_LIST) {
result.inputDepId_ =
java.util.Collections.unmodifiableList(result.inputDepId_);
}
if (result.outputDepId_ != java.util.Collections.EMPTY_LIST) {
result.outputDepId_ =
java.util.Collections.unmodifiableList(result.outputDepId_);
}
if (result.stmtIndex_ != java.util.Collections.EMPTY_LIST) {
result.stmtIndex_ =
java.util.Collections.unmodifiableList(result.stmtIndex_);
}
edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment other) {
if (other == edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.getDefaultInstance()) return this;
if (other.hasPartitionId()) {
setPartitionId(other.getPartitionId());
}
if (!other.fragmentId_.isEmpty()) {
if (result.fragmentId_.isEmpty()) {
result.fragmentId_ = new java.util.ArrayList();
}
result.fragmentId_.addAll(other.fragmentId_);
}
if (!other.inputDepId_.isEmpty()) {
if (result.inputDepId_.isEmpty()) {
result.inputDepId_ = new java.util.ArrayList();
}
result.inputDepId_.addAll(other.inputDepId_);
}
if (!other.outputDepId_.isEmpty()) {
if (result.outputDepId_.isEmpty()) {
result.outputDepId_ = new java.util.ArrayList();
}
result.outputDepId_.addAll(other.outputDepId_);
}
if (!other.stmtIndex_.isEmpty()) {
if (result.stmtIndex_.isEmpty()) {
result.stmtIndex_ = new java.util.ArrayList();
}
result.stmtIndex_.addAll(other.stmtIndex_);
}
if (other.hasReadOnly()) {
setReadOnly(other.getReadOnly());
}
if (other.hasNeedsInput()) {
setNeedsInput(other.getNeedsInput());
}
if (other.hasLastFragment()) {
setLastFragment(other.getLastFragment());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setPartitionId(input.readInt32());
break;
}
case 16: {
addFragmentId(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addFragmentId(input.readInt32());
}
input.popLimit(limit);
break;
}
case 26: {
edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.Builder subBuilder = edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addInputDepId(subBuilder.buildPartial());
break;
}
case 32: {
addOutputDepId(input.readInt32());
break;
}
case 34: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addOutputDepId(input.readInt32());
}
input.popLimit(limit);
break;
}
case 40: {
addStmtIndex(input.readInt32());
break;
}
case 42: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addStmtIndex(input.readInt32());
}
input.popLimit(limit);
break;
}
case 48: {
setReadOnly(input.readBool());
break;
}
case 56: {
setNeedsInput(input.readBool());
break;
}
case 64: {
setLastFragment(input.readBool());
break;
}
}
}
}
// required int32 partition_id = 1;
public boolean hasPartitionId() {
return result.hasPartitionId();
}
public int getPartitionId() {
return result.getPartitionId();
}
public Builder setPartitionId(int value) {
result.hasPartitionId = true;
result.partitionId_ = value;
return this;
}
public Builder clearPartitionId() {
result.hasPartitionId = false;
result.partitionId_ = 0;
return this;
}
// repeated int32 fragment_id = 2 [packed = true];
public java.util.List getFragmentIdList() {
return java.util.Collections.unmodifiableList(result.fragmentId_);
}
public int getFragmentIdCount() {
return result.getFragmentIdCount();
}
public int getFragmentId(int index) {
return result.getFragmentId(index);
}
public Builder setFragmentId(int index, int value) {
result.fragmentId_.set(index, value);
return this;
}
public Builder addFragmentId(int value) {
if (result.fragmentId_.isEmpty()) {
return this;
result.fragmentId_ = new java.util.ArrayList();
}
result.fragmentId_.add(value);
return this;
}
public Builder addAllFragmentId(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.fragmentId_.isEmpty()) {
result.fragmentId_ = new java.util.ArrayList();
}
super.addAll(values, result.fragmentId_);
return this;
}
public Builder clearFragmentId() {
result.fragmentId_ = java.util.Collections.emptyList();
return this;
}
// repeated .edu.brown.hstore.TransactionWorkRequest.InputDependency input_dep_id = 3;
public java.util.List getInputDepIdList() {
return java.util.Collections.unmodifiableList(result.inputDepId_);
}
public int getInputDepIdCount() {
return result.getInputDepIdCount();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency getInputDepId(int index) {
return result.getInputDepId(index);
}
public Builder setInputDepId(int index, edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency value) {
if (value == null) {
throw new NullPointerException();
}
result.inputDepId_.set(index, value);
return this;
}
public Builder setInputDepId(int index, edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.Builder builderForValue) {
result.inputDepId_.set(index, builderForValue.build());
return this;
}
public Builder addInputDepId(edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency value) {
if (value == null) {
throw new NullPointerException();
}
if (result.inputDepId_.isEmpty()) {
result.inputDepId_ = new java.util.ArrayList();
}
result.inputDepId_.add(value);
return this;
}
public Builder addInputDepId(edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency.Builder builderForValue) {
if (result.inputDepId_.isEmpty()) {
result.inputDepId_ = new java.util.ArrayList();
}
result.inputDepId_.add(builderForValue.build());
return this;
}
public Builder addAllInputDepId(
java.lang.Iterable extends edu.brown.hstore.Hstore.TransactionWorkRequest.InputDependency> values) {
if (result.inputDepId_.isEmpty()) {
result.inputDepId_ = new java.util.ArrayList();
}
super.addAll(values, result.inputDepId_);
return this;
}
public Builder clearInputDepId() {
result.inputDepId_ = java.util.Collections.emptyList();
return this;
}
// repeated int32 output_dep_id = 4 [packed = true];
public java.util.List getOutputDepIdList() {
return java.util.Collections.unmodifiableList(result.outputDepId_);
}
public int getOutputDepIdCount() {
return result.getOutputDepIdCount();
}
public int getOutputDepId(int index) {
return result.getOutputDepId(index);
}
public Builder setOutputDepId(int index, int value) {
result.outputDepId_.set(index, value);
return this;
}
public Builder addOutputDepId(int value) {
if (result.outputDepId_.isEmpty()) {
result.outputDepId_ = new java.util.ArrayList();
}
result.outputDepId_.add(value);
}
public Builder addAllOutputDepId(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.outputDepId_.isEmpty()) {
result.outputDepId_ = new java.util.ArrayList();
}
super.addAll(values, result.outputDepId_);
return this;
}
public Builder clearOutputDepId() {
result.outputDepId_ = java.util.Collections.emptyList();
return this;
}
// repeated int32 stmt_index = 5 [packed = true];
public java.util.List getStmtIndexList() {
return java.util.Collections.unmodifiableList(result.stmtIndex_);
}
public int getStmtIndexCount() {
return result.getStmtIndexCount();
}
public int getStmtIndex(int index) {
return result.getStmtIndex(index);
}
public Builder setStmtIndex(int index, int value) {
result.stmtIndex_.set(index, value);
return this;
}
public Builder addStmtIndex(int value) {
if (result.stmtIndex_.isEmpty()) {
result.stmtIndex_ = new java.util.ArrayList();
}
result.stmtIndex_.add(value);
return this;
}
public Builder addAllStmtIndex(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.stmtIndex_.isEmpty()) {
result.stmtIndex_ = new java.util.ArrayList();
}
super.addAll(values, result.stmtIndex_);
return this;
}
public Builder clearStmtIndex() {
result.stmtIndex_ = java.util.Collections.emptyList();
return this;
}
// required bool read_only = 6;
public boolean hasReadOnly() {
return result.hasReadOnly();
}
public boolean getReadOnly() {
return result.getReadOnly();
}
public Builder setReadOnly(boolean value) {
result.hasReadOnly = true;
result.readOnly_ = value;
return this;
}
public Builder clearReadOnly() {
result.hasReadOnly = false;
result.readOnly_ = false;
return this;
}
// required bool needs_input = 7;
public boolean hasNeedsInput() {
return result.hasNeedsInput();
}
public boolean getNeedsInput() {
return result.getNeedsInput();
}
public Builder setNeedsInput(boolean value) {
result.hasNeedsInput = true;
result.needsInput_ = value;
return this;
}
public Builder clearNeedsInput() {
result.hasNeedsInput = false;
result.needsInput_ = false;
return this;
}
// optional bool last_fragment = 8 [default = false];
public boolean hasLastFragment() {
return result.hasLastFragment();
}
public boolean getLastFragment() {
return result.getLastFragment();
}
public Builder setLastFragment(boolean value) {
result.hasLastFragment = true;
result.lastFragment_ = value;
return this;
}
public Builder clearLastFragment() {
result.hasLastFragment = false;
result.lastFragment_ = false;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionWorkRequest.PartitionFragment)
}
static {
defaultInstance = new PartitionFragment(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionWorkRequest.PartitionFragment)
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// required int32 source_partition = 2;
public static final int SOURCE_PARTITION_FIELD_NUMBER = 2;
private boolean hasSourcePartition;
private int sourcePartition_ = 0;
public boolean hasSourcePartition() { return hasSourcePartition; }
public int getSourcePartition() { return sourcePartition_; }
// repeated .edu.brown.hstore.TransactionWorkRequest.PartitionFragment fragments = 3;
public static final int FRAGMENTS_FIELD_NUMBER = 3;
private java.util.List fragments_ =
java.util.Collections.emptyList();
public java.util.List getFragmentsList() {
return fragments_;
}
public int getFragmentsCount() { return fragments_.size(); }
public edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment getFragments(int index) {
return fragments_.get(index);
}
// required bool sysproc = 4 [default = false];
public static final int SYSPROC_FIELD_NUMBER = 4;
private boolean hasSysproc;
private boolean sysproc_ = false;
public boolean hasSysproc() { return hasSysproc; }
public boolean getSysproc() { return sysproc_; }
// repeated bytes parameter_sets = 5;
public static final int PARAMETER_SETS_FIELD_NUMBER = 5;
private java.util.List parameterSets_ =
java.util.Collections.emptyList();
public java.util.List getParameterSetsList() {
return parameterSets_;
}
public int getParameterSetsCount() { return parameterSets_.size(); }
public com.google.protobuf.ByteString getParameterSets(int index) {
return parameterSets_.get(index);
}
// repeated .edu.brown.hstore.Dependency attached = 6;
public static final int ATTACHED_FIELD_NUMBER = 6;
private java.util.List attached_ =
java.util.Collections.emptyList();
public java.util.List getAttachedList() {
return attached_;
}
public int getAttachedCount() { return attached_.size(); }
public edu.brown.hstore.Hstore.Dependency getAttached(int index) {
return attached_.get(index);
}
// repeated int32 done_partition = 7 [packed = true];
public static final int DONE_PARTITION_FIELD_NUMBER = 7;
private java.util.List donePartition_ =
java.util.Collections.emptyList();
public java.util.List getDonePartitionList() {
return donePartition_;
}
public int getDonePartitionCount() { return donePartition_.size(); }
public int getDonePartition(int index) {
return donePartition_.get(index);
}
private int donePartitionMemoizedSerializedSize = -1;
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasSourcePartition) return false;
if (!hasSysproc) return false;
for (edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment element : getFragmentsList()) {
if (!element.isInitialized()) return false;
}
for (edu.brown.hstore.Hstore.Dependency element : getAttachedList()) {
if (!element.isInitialized()) return false;
}
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (hasSourcePartition()) {
output.writeInt32(2, getSourcePartition());
}
for (edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment element : getFragmentsList()) {
output.writeMessage(3, element);
}
if (hasSysproc()) {
output.writeBool(4, getSysproc());
}
for (com.google.protobuf.ByteString element : getParameterSetsList()) {
output.writeBytes(5, element);
}
for (edu.brown.hstore.Hstore.Dependency element : getAttachedList()) {
output.writeMessage(6, element);
}
if (getDonePartitionList().size() > 0) {
output.writeRawVarint32(58);
output.writeRawVarint32(donePartitionMemoizedSerializedSize);
}
for (int element : getDonePartitionList()) {
output.writeInt32NoTag(element);
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
if (hasSourcePartition()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(2, getSourcePartition());
}
for (edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment element : getFragmentsList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(3, element);
}
if (hasSysproc()) {
size += com.google.protobuf.CodedOutputStream
.computeBoolSize(4, getSysproc());
}
{
int dataSize = 0;
for (com.google.protobuf.ByteString element : getParameterSetsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeBytesSizeNoTag(element);
}
size += dataSize;
size += 1 * getParameterSetsList().size();
}
for (edu.brown.hstore.Hstore.Dependency element : getAttachedList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(6, element);
}
{
int dataSize = 0;
for (int element : getDonePartitionList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getDonePartitionList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
donePartitionMemoizedSerializedSize = dataSize;
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionWorkRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionWorkRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionWorkRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionWorkRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionWorkRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionWorkRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionWorkRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionWorkRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.fragments_ != java.util.Collections.EMPTY_LIST) {
result.fragments_ =
java.util.Collections.unmodifiableList(result.fragments_);
}
if (result.parameterSets_ != java.util.Collections.EMPTY_LIST) {
result.parameterSets_ =
java.util.Collections.unmodifiableList(result.parameterSets_);
}
if (result.attached_ != java.util.Collections.EMPTY_LIST) {
result.attached_ =
java.util.Collections.unmodifiableList(result.attached_);
}
if (result.donePartition_ != java.util.Collections.EMPTY_LIST) {
result.donePartition_ =
java.util.Collections.unmodifiableList(result.donePartition_);
}
edu.brown.hstore.Hstore.TransactionWorkRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionWorkRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionWorkRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionWorkRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionWorkRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (other.hasSourcePartition()) {
setSourcePartition(other.getSourcePartition());
}
if (!other.fragments_.isEmpty()) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.addAll(other.fragments_);
}
if (other.hasSysproc()) {
setSysproc(other.getSysproc());
}
if (!other.parameterSets_.isEmpty()) {
if (result.parameterSets_.isEmpty()) {
result.parameterSets_ = new java.util.ArrayList();
}
result.parameterSets_.addAll(other.parameterSets_);
}
if (!other.attached_.isEmpty()) {
if (result.attached_.isEmpty()) {
result.attached_ = new java.util.ArrayList();
}
result.attached_.addAll(other.attached_);
}
if (!other.donePartition_.isEmpty()) {
if (result.donePartition_.isEmpty()) {
result.donePartition_ = new java.util.ArrayList();
}
result.donePartition_.addAll(other.donePartition_);
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
setSourcePartition(input.readInt32());
break;
}
case 26: {
edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.Builder subBuilder = edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addFragments(subBuilder.buildPartial());
break;
}
case 32: {
setSysproc(input.readBool());
break;
}
case 42: {
addParameterSets(input.readBytes());
break;
}
case 50: {
edu.brown.hstore.Hstore.Dependency.Builder subBuilder = edu.brown.hstore.Hstore.Dependency.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addAttached(subBuilder.buildPartial());
break;
}
case 56: {
addDonePartition(input.readInt32());
break;
}
case 58: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addDonePartition(input.readInt32());
}
input.popLimit(limit);
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// required int32 source_partition = 2;
public boolean hasSourcePartition() {
return result.hasSourcePartition();
}
public int getSourcePartition() {
return result.getSourcePartition();
}
public Builder setSourcePartition(int value) {
result.hasSourcePartition = true;
result.sourcePartition_ = value;
return this;
}
public Builder clearSourcePartition() {
result.hasSourcePartition = false;
result.sourcePartition_ = 0;
return this;
}
// repeated .edu.brown.hstore.TransactionWorkRequest.PartitionFragment fragments = 3;
public java.util.List getFragmentsList() {
return java.util.Collections.unmodifiableList(result.fragments_);
}
public int getFragmentsCount() {
return result.getFragmentsCount();
}
public edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment getFragments(int index) {
return result.getFragments(index);
}
public Builder setFragments(int index, edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment value) {
if (value == null) {
throw new NullPointerException();
}
result.fragments_.set(index, value);
return this;
}
public Builder setFragments(int index, edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.Builder builderForValue) {
result.fragments_.set(index, builderForValue.build());
return this;
}
public Builder addFragments(edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment value) {
if (value == null) {
throw new NullPointerException();
}
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.add(value);
return this;
}
public Builder addFragments(edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment.Builder builderForValue) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.add(builderForValue.build());
return this;
}
public Builder addAllFragments(
java.lang.Iterable extends edu.brown.hstore.Hstore.TransactionWorkRequest.PartitionFragment> values) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
super.addAll(values, result.fragments_);
return this;
}
public Builder clearFragments() {
result.fragments_ = java.util.Collections.emptyList();
return this;
}
// required bool sysproc = 4 [default = false];
public boolean hasSysproc() {
return result.hasSysproc();
}
public boolean getSysproc() {
return result.getSysproc();
}
public Builder setSysproc(boolean value) {
result.hasSysproc = true;
result.sysproc_ = value;
return this;
}
public Builder clearSysproc() {
result.hasSysproc = false;
result.sysproc_ = false;
return this;
}
// repeated bytes parameter_sets = 5;
public java.util.List getParameterSetsList() {
return java.util.Collections.unmodifiableList(result.parameterSets_);
}
public int getParameterSetsCount() {
return result.getParameterSetsCount();
}
public com.google.protobuf.ByteString getParameterSets(int index) {
return result.getParameterSets(index);
}
public Builder setParameterSets(int index, com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.parameterSets_.set(index, value);
return this;
}
public Builder addParameterSets(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
if (result.parameterSets_.isEmpty()) {
result.parameterSets_ = new java.util.ArrayList();
}
result.parameterSets_.add(value);
return this;
}
public Builder addAllParameterSets(
java.lang.Iterable extends com.google.protobuf.ByteString> values) {
if (result.parameterSets_.isEmpty()) {
result.parameterSets_ = new java.util.ArrayList();
}
super.addAll(values, result.parameterSets_);
return this;
}
public Builder clearParameterSets() {
result.parameterSets_ = java.util.Collections.emptyList();
return this;
}
// repeated .edu.brown.hstore.Dependency attached = 6;
public java.util.List getAttachedList() {
return java.util.Collections.unmodifiableList(result.attached_);
}
public int getAttachedCount() {
return result.getAttachedCount();
}
public edu.brown.hstore.Hstore.Dependency getAttached(int index) {
return result.getAttached(index);
}
public Builder setAttached(int index, edu.brown.hstore.Hstore.Dependency value) {
if (value == null) {
throw new NullPointerException();
}
result.attached_.set(index, value);
return this;
}
public Builder setAttached(int index, edu.brown.hstore.Hstore.Dependency.Builder builderForValue) {
result.attached_.set(index, builderForValue.build());
return this;
}
public Builder addAttached(edu.brown.hstore.Hstore.Dependency value) {
if (value == null) {
throw new NullPointerException();
}
if (result.attached_.isEmpty()) {
result.attached_ = new java.util.ArrayList();
}
result.attached_.add(value);
return this;
}
public Builder addAttached(edu.brown.hstore.Hstore.Dependency.Builder builderForValue) {
if (result.attached_.isEmpty()) {
result.attached_ = new java.util.ArrayList();
}
result.attached_.add(builderForValue.build());
return this;
}
public Builder addAllAttached(
java.lang.Iterable extends edu.brown.hstore.Hstore.Dependency> values) {
if (result.attached_.isEmpty()) {
result.attached_ = new java.util.ArrayList();
}
super.addAll(values, result.attached_);
return this;
}
public Builder clearAttached() {
result.attached_ = java.util.Collections.emptyList();
return this;
}
// repeated int32 done_partition = 7 [packed = true];
public java.util.List getDonePartitionList() {
return java.util.Collections.unmodifiableList(result.donePartition_);
}
public int getDonePartitionCount() {
return result.getDonePartitionCount();
}
public int getDonePartition(int index) {
return result.getDonePartition(index);
}
public Builder setDonePartition(int index, int value) {
result.donePartition_.set(index, value);
return this;
}
public Builder addDonePartition(int value) {
if (result.donePartition_.isEmpty()) {
result.donePartition_ = new java.util.ArrayList();
}
result.donePartition_.add(value);
return this;
}
public Builder addAllDonePartition(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.donePartition_.isEmpty()) {
result.donePartition_ = new java.util.ArrayList();
}
super.addAll(values, result.donePartition_);
return this;
}
public Builder clearDonePartition() {
result.donePartition_ = java.util.Collections.emptyList();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionWorkRequest)
}
static {
defaultInstance = new TransactionWorkRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionWorkRequest)
}
public static final class TransactionWorkResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionWorkResponse.newBuilder() to construct.
private TransactionWorkResponse() {
initFields();
}
private TransactionWorkResponse(boolean noInit) {}
private static final TransactionWorkResponse defaultInstance;
public static TransactionWorkResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionWorkResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkResponse_fieldAccessorTable;
}
public static final class PartitionResult extends
com.google.protobuf.GeneratedMessage {
// Use PartitionResult.newBuilder() to construct.
private PartitionResult() {
initFields();
}
private PartitionResult(boolean noInit) {}
private static final PartitionResult defaultInstance;
public static PartitionResult getDefaultInstance() {
return defaultInstance;
}
public PartitionResult getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkResponse_PartitionResult_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionWorkResponse_PartitionResult_fieldAccessorTable;
}
// required int32 partition_id = 1;
public static final int PARTITION_ID_FIELD_NUMBER = 1;
private boolean hasPartitionId;
private int partitionId_ = 0;
public boolean hasPartitionId() { return hasPartitionId; }
public int getPartitionId() { return partitionId_; }
// repeated .edu.brown.hstore.Dependency output = 2;
public static final int OUTPUT_FIELD_NUMBER = 2;
private java.util.List output_ =
java.util.Collections.emptyList();
public java.util.List getOutputList() {
return output_;
}
public int getOutputCount() { return output_.size(); }
public edu.brown.hstore.Hstore.Dependency getOutput(int index) {
return output_.get(index);
}
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
// optional bytes error = 4;
public static final int ERROR_FIELD_NUMBER = 4;
private boolean hasError;
private com.google.protobuf.ByteString error_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasError() { return hasError; }
public com.google.protobuf.ByteString getError() { return error_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasPartitionId) return false;
if (!hasStatus) return false;
for (edu.brown.hstore.Hstore.Dependency element : getOutputList()) {
if (!element.isInitialized()) return false;
}
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasPartitionId()) {
output.writeInt32(1, getPartitionId());
}
for (edu.brown.hstore.Hstore.Dependency element : getOutputList()) {
output.writeMessage(2, element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
if (hasError()) {
output.writeBytes(4, getError());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasPartitionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getPartitionId());
}
for (edu.brown.hstore.Hstore.Dependency element : getOutputList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, element);
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
if (hasError()) {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(4, getError());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public Builder clear() {
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult result;
// Construct using edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult internalGetResult() {
return result;
}
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.output_ != java.util.Collections.EMPTY_LIST) {
result.output_ =
java.util.Collections.unmodifiableList(result.output_);
}
edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult other) {
if (other == edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.getDefaultInstance()) return this;
if (other.hasPartitionId()) {
setPartitionId(other.getPartitionId());
}
if (!other.output_.isEmpty()) {
if (result.output_.isEmpty()) {
result.output_ = new java.util.ArrayList();
}
result.output_.addAll(other.output_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
if (other.hasError()) {
setError(other.getError());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setPartitionId(input.readInt32());
break;
}
case 18: {
edu.brown.hstore.Hstore.Dependency.Builder subBuilder = edu.brown.hstore.Hstore.Dependency.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addOutput(subBuilder.buildPartial());
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
case 34: {
setError(input.readBytes());
break;
}
}
}
}
// required int32 partition_id = 1;
public boolean hasPartitionId() {
return result.hasPartitionId();
}
public int getPartitionId() {
return result.getPartitionId();
}
public Builder setPartitionId(int value) {
result.hasPartitionId = true;
result.partitionId_ = value;
return this;
}
public Builder clearPartitionId() {
result.hasPartitionId = false;
result.partitionId_ = 0;
return this;
}
// repeated .edu.brown.hstore.Dependency output = 2;
public java.util.List getOutputList() {
return java.util.Collections.unmodifiableList(result.output_);
}
public int getOutputCount() {
return result.getOutputCount();
}
public edu.brown.hstore.Hstore.Dependency getOutput(int index) {
return result.getOutput(index);
}
public Builder setOutput(int index, edu.brown.hstore.Hstore.Dependency value) {
if (value == null) {
throw new NullPointerException();
}
result.output_.set(index, value);
return this;
}
public Builder setOutput(int index, edu.brown.hstore.Hstore.Dependency.Builder builderForValue) {
result.output_.set(index, builderForValue.build());
return this;
}
public Builder addOutput(edu.brown.hstore.Hstore.Dependency value) {
if (value == null) {
throw new NullPointerException();
}
if (result.output_.isEmpty()) {
result.output_ = new java.util.ArrayList();
result.output_.add(value);
return this;
}
public Builder addOutput(edu.brown.hstore.Hstore.Dependency.Builder builderForValue) {
if (result.output_.isEmpty()) {
result.output_ = new java.util.ArrayList();
}
result.output_.add(builderForValue.build());
return this;
}
public Builder addAllOutput(
java.lang.Iterable extends edu.brown.hstore.Hstore.Dependency> values) {
if (result.output_.isEmpty()) {
result.output_ = new java.util.ArrayList();
}
super.addAll(values, result.output_);
return this;
}
public Builder clearOutput() {
result.output_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// optional bytes error = 4;
public boolean hasError() {
return result.hasError();
}
public com.google.protobuf.ByteString getError() {
return result.getError();
}
public Builder setError(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.hasError = true;
result.error_ = value;
return this;
}
public Builder clearError() {
result.hasError = false;
result.error_ = getDefaultInstance().getError();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionWorkResponse.PartitionResult)
}
static {
defaultInstance = new PartitionResult(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionWorkResponse.PartitionResult)
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated .edu.brown.hstore.TransactionWorkResponse.PartitionResult results = 2;
public static final int RESULTS_FIELD_NUMBER = 2;
private java.util.List results_ =
java.util.Collections.emptyList();
public java.util.List getResultsList() {
return results_;
}
public int getResultsCount() { return results_.size(); }
public edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult getResults(int index) {
return results_.get(index);
}
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
for (edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult element : getResultsList()) {
if (!element.isInitialized()) return false;
}
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult element : getResultsList()) {
output.writeMessage(2, element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult element : getResultsList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, element);
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionWorkResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionWorkResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionWorkResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionWorkResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionWorkResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionWorkResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionWorkResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionWorkResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionWorkResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionWorkResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.results_ != java.util.Collections.EMPTY_LIST) {
result.results_ =
java.util.Collections.unmodifiableList(result.results_);
}
edu.brown.hstore.Hstore.TransactionWorkResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionWorkResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionWorkResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionWorkResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionWorkResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.results_.isEmpty()) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.addAll(other.results_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 18: {
edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.Builder subBuilder = edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addResults(subBuilder.buildPartial());
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated .edu.brown.hstore.TransactionWorkResponse.PartitionResult results = 2;
public java.util.List getResultsList() {
return java.util.Collections.unmodifiableList(result.results_);
}
public int getResultsCount() {
return result.getResultsCount();
}
public edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult getResults(int index) {
return result.getResults(index);
}
public Builder setResults(int index, edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult value) {
if (value == null) {
throw new NullPointerException();
}
result.results_.set(index, value);
return this;
}
public Builder setResults(int index, edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.Builder builderForValue) {
result.results_.set(index, builderForValue.build());
return this;
}
public Builder addResults(edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult value) {
if (value == null) {
throw new NullPointerException();
}
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.add(value);
return this;
}
public Builder addResults(edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult.Builder builderForValue) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.add(builderForValue.build());
return this;
}
public Builder addAllResults(
java.lang.Iterable extends edu.brown.hstore.Hstore.TransactionWorkResponse.PartitionResult> values) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
super.addAll(values, result.results_);
return this;
}
public Builder clearResults() {
result.results_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionWorkResponse)
}
static {
defaultInstance = new TransactionWorkResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionWorkResponse)
}
public static final class TransactionMapRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionMapRequest.newBuilder() to construct.
private TransactionMapRequest() {
initFields();
}
private TransactionMapRequest(boolean noInit) {}
private static final TransactionMapRequest defaultInstance;
public static TransactionMapRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionMapRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionMapRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionMapRequest_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// required int32 base_partition = 2;
public static final int BASE_PARTITION_FIELD_NUMBER = 2;
private boolean hasBasePartition;
private int basePartition_ = 0;
public boolean hasBasePartition() { return hasBasePartition; }
public int getBasePartition() { return basePartition_; }
// required bytes invocation = 3;
public static final int INVOCATION_FIELD_NUMBER = 3;
private boolean hasInvocation;
private com.google.protobuf.ByteString invocation_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasInvocation() { return hasInvocation; }
public com.google.protobuf.ByteString getInvocation() { return invocation_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasBasePartition) return false;
if (!hasInvocation) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (hasBasePartition()) {
output.writeInt32(2, getBasePartition());
}
if (hasInvocation()) {
output.writeBytes(3, getInvocation());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
if (hasBasePartition()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(2, getBasePartition());
}
if (hasInvocation()) {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(3, getInvocation());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionMapRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionMapRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionMapRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionMapRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionMapRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionMapRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionMapRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionMapRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionMapRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionMapRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionMapRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionMapRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TransactionMapRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionMapRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionMapRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionMapRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionMapRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (other.hasBasePartition()) {
setBasePartition(other.getBasePartition());
}
if (other.hasInvocation()) {
setInvocation(other.getInvocation());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
setBasePartition(input.readInt32());
break;
}
case 26: {
setInvocation(input.readBytes());
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// required int32 base_partition = 2;
public boolean hasBasePartition() {
return result.hasBasePartition();
}
public int getBasePartition() {
return result.getBasePartition();
}
public Builder setBasePartition(int value) {
result.hasBasePartition = true;
result.basePartition_ = value;
return this;
}
public Builder clearBasePartition() {
result.hasBasePartition = false;
result.basePartition_ = 0;
return this;
}
// required bytes invocation = 3;
public boolean hasInvocation() {
return result.hasInvocation();
}
public com.google.protobuf.ByteString getInvocation() {
return result.getInvocation();
}
public Builder setInvocation(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.hasInvocation = true;
result.invocation_ = value;
return this;
}
public Builder clearInvocation() {
result.hasInvocation = false;
result.invocation_ = getDefaultInstance().getInvocation();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionMapRequest)
}
static {
defaultInstance = new TransactionMapRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionMapRequest)
}
public static final class TransactionMapResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionMapResponse.newBuilder() to construct.
private TransactionMapResponse() {
initFields();
}
private TransactionMapResponse(boolean noInit) {}
private static final TransactionMapResponse defaultInstance;
public static TransactionMapResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionMapResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionMapResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionMapResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
}
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionMapResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionMapResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionMapResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionMapResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionMapResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionMapResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionMapResponse();
case 8: {
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionMapResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionMapResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionMapResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionMapResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionMapResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionMapResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionMapResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionMapResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionMapResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionMapResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionMapResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionMapResponse)
}
static {
defaultInstance = new TransactionMapResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionMapResponse)
}
public static final class TransactionReduceRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionReduceRequest.newBuilder() to construct.
private TransactionReduceRequest() {
initFields();
}
private TransactionReduceRequest(boolean noInit) {}
private static final TransactionReduceRequest defaultInstance;
public static TransactionReduceRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionReduceRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionReduceRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionReduceRequest_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// required int32 base_partition = 2;
public static final int BASE_PARTITION_FIELD_NUMBER = 2;
private boolean hasBasePartition;
private int basePartition_ = 0;
public boolean hasBasePartition() { return hasBasePartition; }
public int getBasePartition() { return basePartition_; }
// required bytes invocation = 3;
public static final int INVOCATION_FIELD_NUMBER = 3;
private boolean hasInvocation;
private com.google.protobuf.ByteString invocation_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasInvocation() { return hasInvocation; }
public com.google.protobuf.ByteString getInvocation() { return invocation_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasBasePartition) return false;
if (!hasInvocation) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (hasBasePartition()) {
output.writeInt32(2, getBasePartition());
}
if (hasInvocation()) {
output.writeBytes(3, getInvocation());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
if (hasBasePartition()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(2, getBasePartition());
}
if (hasInvocation()) {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(3, getInvocation());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionReduceRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionReduceRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionReduceRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionReduceRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionReduceRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionReduceRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionReduceRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionReduceRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionReduceRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionReduceRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionReduceRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionReduceRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TransactionReduceRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionReduceRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionReduceRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionReduceRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionReduceRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (other.hasBasePartition()) {
setBasePartition(other.getBasePartition());
}
if (other.hasInvocation()) {
setInvocation(other.getInvocation());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
setBasePartition(input.readInt32());
break;
}
case 26: {
setInvocation(input.readBytes());
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// required int32 base_partition = 2;
public boolean hasBasePartition() {
return result.hasBasePartition();
}
public int getBasePartition() {
return result.getBasePartition();
}
public Builder setBasePartition(int value) {
result.hasBasePartition = true;
result.basePartition_ = value;
return this;
}
public Builder clearBasePartition() {
result.hasBasePartition = false;
result.basePartition_ = 0;
return this;
}
// required bytes invocation = 3;
public boolean hasInvocation() {
return result.hasInvocation();
}
public com.google.protobuf.ByteString getInvocation() {
return result.getInvocation();
}
public Builder setInvocation(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.hasInvocation = true;
result.invocation_ = value;
return this;
}
public Builder clearInvocation() {
result.hasInvocation = false;
result.invocation_ = getDefaultInstance().getInvocation();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionReduceRequest)
}
static {
defaultInstance = new TransactionReduceRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionReduceRequest)
}
public static final class TransactionReduceResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionReduceResponse.newBuilder() to construct.
private TransactionReduceResponse() {
initFields();
}
private TransactionReduceResponse(boolean noInit) {}
private static final TransactionReduceResponse defaultInstance;
public static TransactionReduceResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionReduceResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionReduceResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionReduceResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated .edu.brown.hstore.PartitionResult results = 2;
public static final int RESULTS_FIELD_NUMBER = 2;
private java.util.List results_ =
java.util.Collections.emptyList();
public java.util.List getResultsList() {
return results_;
}
public int getResultsCount() { return results_.size(); }
public edu.brown.hstore.Hstore.PartitionResult getResults(int index) {
return results_.get(index);
}
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
for (edu.brown.hstore.Hstore.PartitionResult element : getResultsList()) {
if (!element.isInitialized()) return false;
}
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.PartitionResult element : getResultsList()) {
output.writeMessage(2, element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.PartitionResult element : getResultsList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, element);
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionReduceResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionReduceResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionReduceResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionReduceResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionReduceResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionReduceResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionReduceResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionReduceResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionReduceResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionReduceResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionReduceResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionReduceResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionReduceResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.results_ != java.util.Collections.EMPTY_LIST) {
result.results_ =
java.util.Collections.unmodifiableList(result.results_);
}
edu.brown.hstore.Hstore.TransactionReduceResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionReduceResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionReduceResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionReduceResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionReduceResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.results_.isEmpty()) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.addAll(other.results_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 18: {
edu.brown.hstore.Hstore.PartitionResult.Builder subBuilder = edu.brown.hstore.Hstore.PartitionResult.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addResults(subBuilder.buildPartial());
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated .edu.brown.hstore.PartitionResult results = 2;
public java.util.List getResultsList() {
return java.util.Collections.unmodifiableList(result.results_);
}
public int getResultsCount() {
return result.getResultsCount();
}
public edu.brown.hstore.Hstore.PartitionResult getResults(int index) {
return result.getResults(index);
}
public Builder setResults(int index, edu.brown.hstore.Hstore.PartitionResult value) {
if (value == null) {
throw new NullPointerException();
}
result.results_.set(index, value);
return this;
}
public Builder setResults(int index, edu.brown.hstore.Hstore.PartitionResult.Builder builderForValue) {
result.results_.set(index, builderForValue.build());
return this;
}
public Builder addResults(edu.brown.hstore.Hstore.PartitionResult value) {
if (value == null) {
throw new NullPointerException();
}
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.add(value);
return this;
}
public Builder addResults(edu.brown.hstore.Hstore.PartitionResult.Builder builderForValue) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
result.results_.add(builderForValue.build());
return this;
}
public Builder addAllResults(
java.lang.Iterable extends edu.brown.hstore.Hstore.PartitionResult> values) {
if (result.results_.isEmpty()) {
result.results_ = new java.util.ArrayList();
}
super.addAll(values, result.results_);
return this;
}
public Builder clearResults() {
result.results_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionReduceResponse)
}
static {
defaultInstance = new TransactionReduceResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionReduceResponse)
}
public static final class TransactionPrepareRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionPrepareRequest.newBuilder() to construct.
private TransactionPrepareRequest() {
initFields();
}
private TransactionPrepareRequest(boolean noInit) {}
private static final TransactionPrepareRequest defaultInstance;
public static TransactionPrepareRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionPrepareRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionPrepareRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionPrepareRequest_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
} else {
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionPrepareRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionPrepareRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionPrepareRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionPrepareRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionPrepareRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionPrepareRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionPrepareRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionPrepareRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionPrepareRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionPrepareRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionPrepareRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionPrepareRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionPrepareRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionPrepareRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionPrepareRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionPrepareRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionPrepareRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionPrepareRequest)
}
static {
defaultInstance = new TransactionPrepareRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionPrepareRequest)
}
public static final class TransactionPrepareResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionPrepareResponse.newBuilder() to construct.
private TransactionPrepareResponse() {
initFields();
}
private TransactionPrepareResponse(boolean noInit) {}
private static final TransactionPrepareResponse defaultInstance;
public static TransactionPrepareResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionPrepareResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionPrepareResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionPrepareResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
}
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionPrepareResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionPrepareResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionPrepareResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionPrepareResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionPrepareResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionPrepareResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionPrepareResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionPrepareResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionPrepareResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionPrepareResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionPrepareResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionPrepareResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionPrepareResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionPrepareResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionPrepareResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionPrepareResponse)other);
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionPrepareResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionPrepareResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionPrepareResponse)
}
static {
defaultInstance = new TransactionPrepareResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionPrepareResponse)
}
public static final class TransactionFinishRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionFinishRequest.newBuilder() to construct.
private TransactionFinishRequest() {
initFields();
}
private TransactionFinishRequest(boolean noInit) {}
private static final TransactionFinishRequest defaultInstance;
public static TransactionFinishRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionFinishRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionFinishRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionFinishRequest_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
// required .edu.brown.hstore.Status status = 3;
public static final int STATUS_FIELD_NUMBER = 3;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
if (hasStatus()) {
output.writeEnum(3, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(3, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionFinishRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionFinishRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionFinishRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionFinishRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionFinishRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionFinishRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionFinishRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionFinishRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionFinishRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionFinishRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionFinishRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionFinishRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionFinishRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionFinishRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionFinishRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionFinishRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionFinishRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
case 24: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(3, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// required .edu.brown.hstore.Status status = 3;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionFinishRequest)
}
static {
defaultInstance = new TransactionFinishRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionFinishRequest)
}
public static final class TransactionFinishResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionFinishResponse.newBuilder() to construct.
private TransactionFinishResponse() {
initFields();
}
private TransactionFinishResponse(boolean noInit) {}
private static final TransactionFinishResponse defaultInstance;
public static TransactionFinishResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionFinishResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionFinishResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionFinishResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
return result;
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionFinishResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionFinishResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionFinishResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionFinishResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionFinishResponse();
return builder;
}
}
default: {
protected edu.brown.hstore.Hstore.TransactionFinishResponse internalGetResult() {
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionFinishResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionFinishResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionFinishResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionFinishResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionFinishResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionFinishResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionFinishResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.TransactionFinishResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionFinishResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionFinishResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionFinishResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionFinishResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionFinishResponse)
}
static {
defaultInstance = new TransactionFinishResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionFinishResponse)
}
public static final class TransactionRedirectRequest extends
com.google.protobuf.GeneratedMessage {
// Use TransactionRedirectRequest.newBuilder() to construct.
private TransactionRedirectRequest() {
initFields();
}
private TransactionRedirectRequest(boolean noInit) {}
private static final TransactionRedirectRequest defaultInstance;
public static TransactionRedirectRequest getDefaultInstance() {
return defaultInstance;
}
public TransactionRedirectRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionRedirectRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionRedirectRequest_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required bytes work = 2;
public static final int WORK_FIELD_NUMBER = 2;
private boolean hasWork;
private com.google.protobuf.ByteString work_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasWork() { return hasWork; }
public com.google.protobuf.ByteString getWork() { return work_; }
// optional int64 orig_txn_id = 3;
public static final int ORIG_TXN_ID_FIELD_NUMBER = 3;
private boolean hasOrigTxnId;
private long origTxnId_ = 0L;
public boolean hasOrigTxnId() { return hasOrigTxnId; }
public long getOrigTxnId() { return origTxnId_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
if (!hasWork) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
if (hasWork()) {
output.writeBytes(2, getWork());
}
if (hasOrigTxnId()) {
output.writeInt64(3, getOrigTxnId());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
if (hasWork()) {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(2, getWork());
}
if (hasOrigTxnId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(3, getOrigTxnId());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionRedirectRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionRedirectRequest result;
// Construct using edu.brown.hstore.Hstore.TransactionRedirectRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionRedirectRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionRedirectRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionRedirectRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionRedirectRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionRedirectRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionRedirectRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionRedirectRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionRedirectRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionRedirectRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TransactionRedirectRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionRedirectRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionRedirectRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionRedirectRequest other) {
if (other == edu.brown.hstore.Hstore.TransactionRedirectRequest.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasWork()) {
setWork(other.getWork());
}
if (other.hasOrigTxnId()) {
setOrigTxnId(other.getOrigTxnId());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
case 18: {
setWork(input.readBytes());
break;
}
case 24: {
setOrigTxnId(input.readInt64());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required bytes work = 2;
public boolean hasWork() {
return result.hasWork();
}
public com.google.protobuf.ByteString getWork() {
return result.getWork();
}
public Builder setWork(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.hasWork = true;
result.work_ = value;
return this;
}
public Builder clearWork() {
result.hasWork = false;
result.work_ = getDefaultInstance().getWork();
return this;
}
// optional int64 orig_txn_id = 3;
public boolean hasOrigTxnId() {
return result.hasOrigTxnId();
}
public long getOrigTxnId() {
return result.getOrigTxnId();
}
public Builder setOrigTxnId(long value) {
result.hasOrigTxnId = true;
result.origTxnId_ = value;
return this;
}
public Builder clearOrigTxnId() {
result.hasOrigTxnId = false;
result.origTxnId_ = 0L;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionRedirectRequest)
}
static {
defaultInstance = new TransactionRedirectRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionRedirectRequest)
}
public static final class TransactionRedirectResponse extends
com.google.protobuf.GeneratedMessage {
// Use TransactionRedirectResponse.newBuilder() to construct.
private TransactionRedirectResponse() {
initFields();
}
private TransactionRedirectResponse(boolean noInit) {}
private static final TransactionRedirectResponse defaultInstance;
public static TransactionRedirectResponse getDefaultInstance() {
return defaultInstance;
}
public TransactionRedirectResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionRedirectResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TransactionRedirectResponse_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required bytes output = 2;
public static final int OUTPUT_FIELD_NUMBER = 2;
private boolean hasOutput;
private com.google.protobuf.ByteString output_ = com.google.protobuf.ByteString.EMPTY;
public boolean hasOutput() { return hasOutput; }
public com.google.protobuf.ByteString getOutput() { return output_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
if (!hasOutput) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
if (hasOutput()) {
output.writeBytes(2, getOutput());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
if (hasOutput()) {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(2, getOutput());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TransactionRedirectResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TransactionRedirectResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TransactionRedirectResponse result;
// Construct using edu.brown.hstore.Hstore.TransactionRedirectResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TransactionRedirectResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TransactionRedirectResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TransactionRedirectResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TransactionRedirectResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TransactionRedirectResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TransactionRedirectResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TransactionRedirectResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TransactionRedirectResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TransactionRedirectResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TransactionRedirectResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TransactionRedirectResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TransactionRedirectResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TransactionRedirectResponse other) {
if (other == edu.brown.hstore.Hstore.TransactionRedirectResponse.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasOutput()) {
setOutput(other.getOutput());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
case 18: {
setOutput(input.readBytes());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required bytes output = 2;
public boolean hasOutput() {
return result.hasOutput();
}
public com.google.protobuf.ByteString getOutput() {
return result.getOutput();
}
public Builder setOutput(com.google.protobuf.ByteString value) {
if (value == null) {
throw new NullPointerException();
}
result.hasOutput = true;
result.output_ = value;
return this;
}
public Builder clearOutput() {
result.hasOutput = false;
result.output_ = getDefaultInstance().getOutput();
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TransactionRedirectResponse)
}
static {
defaultInstance = new TransactionRedirectResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TransactionRedirectResponse)
}
public static final class SendDataRequest extends
com.google.protobuf.GeneratedMessage {
return size;
// Use SendDataRequest.newBuilder() to construct.
private SendDataRequest() {
initFields();
}
private SendDataRequest(boolean noInit) {}
private static final SendDataRequest defaultInstance;
public static SendDataRequest getDefaultInstance() {
return defaultInstance;
}
public SendDataRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_SendDataRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_SendDataRequest_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated .edu.brown.hstore.PartitionFragment fragments = 2;
public static final int FRAGMENTS_FIELD_NUMBER = 2;
private java.util.List fragments_ =
java.util.Collections.emptyList();
public java.util.List getFragmentsList() {
return fragments_;
}
public int getFragmentsCount() { return fragments_.size(); }
public edu.brown.hstore.Hstore.PartitionFragment getFragments(int index) {
return fragments_.get(index);
}
// required int32 sender_id = 3;
public static final int SENDER_ID_FIELD_NUMBER = 3;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasSenderId) return false;
for (edu.brown.hstore.Hstore.PartitionFragment element : getFragmentsList()) {
if (!element.isInitialized()) return false;
}
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.PartitionFragment element : getFragmentsList()) {
output.writeMessage(2, element);
}
if (hasSenderId()) {
output.writeInt32(3, getSenderId());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
for (edu.brown.hstore.Hstore.PartitionFragment element : getFragmentsList()) {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(2, element);
}
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(3, getSenderId());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.SendDataRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.SendDataRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.SendDataRequest result;
// Construct using edu.brown.hstore.Hstore.SendDataRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.SendDataRequest();
return builder;
}
protected edu.brown.hstore.Hstore.SendDataRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.SendDataRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.SendDataRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.SendDataRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.SendDataRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.SendDataRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.SendDataRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.SendDataRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.fragments_ != java.util.Collections.EMPTY_LIST) {
result.fragments_ =
java.util.Collections.unmodifiableList(result.fragments_);
}
edu.brown.hstore.Hstore.SendDataRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.SendDataRequest) {
return mergeFrom((edu.brown.hstore.Hstore.SendDataRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.SendDataRequest other) {
if (other == edu.brown.hstore.Hstore.SendDataRequest.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.fragments_.isEmpty()) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.addAll(other.fragments_);
}
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 18: {
edu.brown.hstore.Hstore.PartitionFragment.Builder subBuilder = edu.brown.hstore.Hstore.PartitionFragment.newBuilder();
input.readMessage(subBuilder, extensionRegistry);
addFragments(subBuilder.buildPartial());
break;
}
case 24: {
setSenderId(input.readInt32());
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated .edu.brown.hstore.PartitionFragment fragments = 2;
public java.util.List getFragmentsList() {
return java.util.Collections.unmodifiableList(result.fragments_);
}
public int getFragmentsCount() {
return result.getFragmentsCount();
}
public edu.brown.hstore.Hstore.PartitionFragment getFragments(int index) {
return result.getFragments(index);
}
public Builder setFragments(int index, edu.brown.hstore.Hstore.PartitionFragment value) {
if (value == null) {
throw new NullPointerException();
}
result.fragments_.set(index, value);
return this;
}
public Builder setFragments(int index, edu.brown.hstore.Hstore.PartitionFragment.Builder builderForValue) {
result.fragments_.set(index, builderForValue.build());
return this;
}
public Builder addFragments(edu.brown.hstore.Hstore.PartitionFragment value) {
if (value == null) {
throw new NullPointerException();
}
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.add(value);
return this;
}
public Builder addFragments(edu.brown.hstore.Hstore.PartitionFragment.Builder builderForValue) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
result.fragments_.add(builderForValue.build());
return this;
}
public Builder addAllFragments(
java.lang.Iterable extends edu.brown.hstore.Hstore.PartitionFragment> values) {
if (result.fragments_.isEmpty()) {
result.fragments_ = new java.util.ArrayList();
}
super.addAll(values, result.fragments_);
return this;
}
public Builder clearFragments() {
result.fragments_ = java.util.Collections.emptyList();
return this;
}
// required int32 sender_id = 3;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.SendDataRequest)
}
static {
defaultInstance = new SendDataRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.SendDataRequest)
}
public static final class SendDataResponse extends
com.google.protobuf.GeneratedMessage {
// Use SendDataResponse.newBuilder() to construct.
private SendDataResponse() {
initFields();
}
private SendDataResponse(boolean noInit) {}
private static final SendDataResponse defaultInstance;
public static SendDataResponse getDefaultInstance() {
return defaultInstance;
}
public SendDataResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_SendDataResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_SendDataResponse_fieldAccessorTable;
}
// required int64 transaction_id = 1;
public static final int TRANSACTION_ID_FIELD_NUMBER = 1;
private boolean hasTransactionId;
private long transactionId_ = 0L;
public boolean hasTransactionId() { return hasTransactionId; }
public long getTransactionId() { return transactionId_; }
// repeated int32 partitions = 2 [packed = true];
public static final int PARTITIONS_FIELD_NUMBER = 2;
private java.util.List partitions_ =
java.util.Collections.emptyList();
public java.util.List getPartitionsList() {
return partitions_;
}
public int getPartitionsCount() { return partitions_.size(); }
public int getPartitions(int index) {
return partitions_.get(index);
}
private int partitionsMemoizedSerializedSize = -1;
// required int32 sender_id = 3;
public static final int SENDER_ID_FIELD_NUMBER = 3;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required .edu.brown.hstore.Status status = 4;
public static final int STATUS_FIELD_NUMBER = 4;
private boolean hasStatus;
private edu.brown.hstore.Hstore.Status status_;
public boolean hasStatus() { return hasStatus; }
public edu.brown.hstore.Hstore.Status getStatus() { return status_; }
private void initFields() {
status_ = edu.brown.hstore.Hstore.Status.OK;
}
public final boolean isInitialized() {
if (!hasTransactionId) return false;
if (!hasSenderId) return false;
if (!hasStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasTransactionId()) {
output.writeInt64(1, getTransactionId());
}
if (getPartitionsList().size() > 0) {
output.writeRawVarint32(18);
output.writeRawVarint32(partitionsMemoizedSerializedSize);
}
for (int element : getPartitionsList()) {
output.writeInt32NoTag(element);
}
if (hasSenderId()) {
output.writeInt32(3, getSenderId());
}
if (hasStatus()) {
output.writeEnum(4, getStatus().getNumber());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasTransactionId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(1, getTransactionId());
}
{
int dataSize = 0;
for (int element : getPartitionsList()) {
dataSize += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(element);
}
size += dataSize;
if (!getPartitionsList().isEmpty()) {
size += 1;
size += com.google.protobuf.CodedOutputStream
.computeInt32SizeNoTag(dataSize);
}
partitionsMemoizedSerializedSize = dataSize;
}
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(3, getSenderId());
}
if (hasStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeEnumSize(4, getStatus().getNumber());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.SendDataResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.SendDataResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.SendDataResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.SendDataResponse result;
// Construct using edu.brown.hstore.Hstore.SendDataResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.SendDataResponse();
return builder;
}
protected edu.brown.hstore.Hstore.SendDataResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.SendDataResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.SendDataResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.SendDataResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.SendDataResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.SendDataResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.SendDataResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.SendDataResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
if (result.partitions_ != java.util.Collections.EMPTY_LIST) {
result.partitions_ =
java.util.Collections.unmodifiableList(result.partitions_);
}
edu.brown.hstore.Hstore.SendDataResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.SendDataResponse) {
return mergeFrom((edu.brown.hstore.Hstore.SendDataResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.SendDataResponse other) {
if (other == edu.brown.hstore.Hstore.SendDataResponse.getDefaultInstance()) return this;
if (other.hasTransactionId()) {
setTransactionId(other.getTransactionId());
}
if (!other.partitions_.isEmpty()) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.addAll(other.partitions_);
}
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasStatus()) {
setStatus(other.getStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setTransactionId(input.readInt64());
break;
}
case 16: {
addPartitions(input.readInt32());
break;
}
case 18: {
int length = input.readRawVarint32();
int limit = input.pushLimit(length);
while (input.getBytesUntilLimit() > 0) {
addPartitions(input.readInt32());
}
input.popLimit(limit);
break;
}
case 24: {
setSenderId(input.readInt32());
break;
}
case 32: {
int rawValue = input.readEnum();
edu.brown.hstore.Hstore.Status value = edu.brown.hstore.Hstore.Status.valueOf(rawValue);
if (value == null) {
unknownFields.mergeVarintField(4, rawValue);
} else {
setStatus(value);
}
break;
}
}
}
}
// required int64 transaction_id = 1;
public boolean hasTransactionId() {
return result.hasTransactionId();
}
public long getTransactionId() {
return result.getTransactionId();
}
public Builder setTransactionId(long value) {
result.hasTransactionId = true;
result.transactionId_ = value;
return this;
}
public Builder clearTransactionId() {
result.hasTransactionId = false;
result.transactionId_ = 0L;
return this;
}
// repeated int32 partitions = 2 [packed = true];
public java.util.List getPartitionsList() {
return java.util.Collections.unmodifiableList(result.partitions_);
}
public int getPartitionsCount() {
return result.getPartitionsCount();
}
public int getPartitions(int index) {
return result.getPartitions(index);
}
public Builder setPartitions(int index, int value) {
result.partitions_.set(index, value);
return this;
}
public Builder addPartitions(int value) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
result.partitions_.add(value);
return this;
}
public Builder addAllPartitions(
java.lang.Iterable extends java.lang.Integer> values) {
if (result.partitions_.isEmpty()) {
result.partitions_ = new java.util.ArrayList();
}
super.addAll(values, result.partitions_);
return this;
}
public Builder clearPartitions() {
result.partitions_ = java.util.Collections.emptyList();
return this;
}
// required int32 sender_id = 3;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required .edu.brown.hstore.Status status = 4;
public boolean hasStatus() {
return result.hasStatus();
}
public edu.brown.hstore.Hstore.Status getStatus() {
return result.getStatus();
}
public Builder setStatus(edu.brown.hstore.Hstore.Status value) {
if (value == null) {
throw new NullPointerException();
}
result.hasStatus = true;
result.status_ = value;
return this;
}
public Builder clearStatus() {
result.hasStatus = false;
result.status_ = edu.brown.hstore.Hstore.Status.OK;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.SendDataResponse)
}
static {
defaultInstance = new SendDataResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.SendDataResponse)
}
public static final class ShutdownRequest extends
com.google.protobuf.GeneratedMessage {
// Use ShutdownRequest.newBuilder() to construct.
private ShutdownRequest() {
initFields();
}
private ShutdownRequest(boolean noInit) {}
private static final ShutdownRequest defaultInstance;
public static ShutdownRequest getDefaultInstance() {
return defaultInstance;
}
public ShutdownRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_ShutdownRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_ShutdownRequest_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required int32 exit_status = 2;
public static final int EXIT_STATUS_FIELD_NUMBER = 2;
private boolean hasExitStatus;
private int exitStatus_ = 0;
public boolean hasExitStatus() { return hasExitStatus; }
public int getExitStatus() { return exitStatus_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
if (!hasExitStatus) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
if (hasExitStatus()) {
output.writeInt32(2, getExitStatus());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
if (hasExitStatus()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(2, getExitStatus());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.ShutdownRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.ShutdownRequest result;
// Construct using edu.brown.hstore.Hstore.ShutdownRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.ShutdownRequest();
return builder;
}
protected edu.brown.hstore.Hstore.ShutdownRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.ShutdownRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.ShutdownRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.ShutdownRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.ShutdownRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.ShutdownRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.ShutdownRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.ShutdownRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.ShutdownRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.ShutdownRequest) {
return mergeFrom((edu.brown.hstore.Hstore.ShutdownRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.ShutdownRequest other) {
if (other == edu.brown.hstore.Hstore.ShutdownRequest.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasExitStatus()) {
setExitStatus(other.getExitStatus());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
case 16: {
setExitStatus(input.readInt32());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required int32 exit_status = 2;
public boolean hasExitStatus() {
return result.hasExitStatus();
}
public int getExitStatus() {
return result.getExitStatus();
}
public Builder setExitStatus(int value) {
result.hasExitStatus = true;
result.exitStatus_ = value;
return this;
}
public Builder clearExitStatus() {
result.hasExitStatus = false;
result.exitStatus_ = 0;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.ShutdownRequest)
}
static {
defaultInstance = new ShutdownRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.ShutdownRequest)
}
public static final class ShutdownResponse extends
com.google.protobuf.GeneratedMessage {
// Use ShutdownResponse.newBuilder() to construct.
private ShutdownResponse() {
initFields();
}
private ShutdownResponse(boolean noInit) {}
private static final ShutdownResponse defaultInstance;
public static ShutdownResponse getDefaultInstance() {
return defaultInstance;
}
public ShutdownResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_ShutdownResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_ShutdownResponse_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.ShutdownResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.ShutdownResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.ShutdownResponse result;
// Construct using edu.brown.hstore.Hstore.ShutdownResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.ShutdownResponse();
return builder;
}
protected edu.brown.hstore.Hstore.ShutdownResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.ShutdownResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.ShutdownResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.ShutdownResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.ShutdownResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.ShutdownResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.ShutdownResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.ShutdownResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.ShutdownResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.ShutdownResponse) {
return mergeFrom((edu.brown.hstore.Hstore.ShutdownResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.ShutdownResponse other) {
if (other == edu.brown.hstore.Hstore.ShutdownResponse.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.ShutdownResponse)
}
static {
defaultInstance = new ShutdownResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.ShutdownResponse)
}
public static final class TimeSyncRequest extends
com.google.protobuf.GeneratedMessage {
// Use TimeSyncRequest.newBuilder() to construct.
private TimeSyncRequest() {
initFields();
}
private TimeSyncRequest(boolean noInit) {}
private static final TimeSyncRequest defaultInstance;
public static TimeSyncRequest getDefaultInstance() {
return defaultInstance;
}
public TimeSyncRequest getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TimeSyncRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TimeSyncRequest_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required int64 t0_s = 2;
public static final int T0_S_FIELD_NUMBER = 2;
private boolean hasT0S;
private long t0S_ = 0L;
public boolean hasT0S() { return hasT0S; }
public long getT0S() { return t0S_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
if (!hasT0S) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
if (hasT0S()) {
output.writeInt64(2, getT0S());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
if (hasT0S()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(2, getT0S());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TimeSyncRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TimeSyncRequest result;
// Construct using edu.brown.hstore.Hstore.TimeSyncRequest.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TimeSyncRequest();
return builder;
}
protected edu.brown.hstore.Hstore.TimeSyncRequest internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TimeSyncRequest();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TimeSyncRequest.getDescriptor();
}
public edu.brown.hstore.Hstore.TimeSyncRequest getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TimeSyncRequest.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TimeSyncRequest build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TimeSyncRequest buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TimeSyncRequest buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TimeSyncRequest returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TimeSyncRequest) {
return mergeFrom((edu.brown.hstore.Hstore.TimeSyncRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TimeSyncRequest other) {
if (other == edu.brown.hstore.Hstore.TimeSyncRequest.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasT0S()) {
setT0S(other.getT0S());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
case 16: {
setT0S(input.readInt64());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required int64 t0_s = 2;
public boolean hasT0S() {
return result.hasT0S();
}
public long getT0S() {
return result.getT0S();
}
public Builder setT0S(long value) {
result.hasT0S = true;
result.t0S_ = value;
return this;
}
public Builder clearT0S() {
result.hasT0S = false;
result.t0S_ = 0L;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TimeSyncRequest)
}
static {
defaultInstance = new TimeSyncRequest(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TimeSyncRequest)
}
public static final class TimeSyncResponse extends
com.google.protobuf.GeneratedMessage {
// Use TimeSyncResponse.newBuilder() to construct.
private TimeSyncResponse() {
initFields();
}
private TimeSyncResponse(boolean noInit) {}
private static final TimeSyncResponse defaultInstance;
public static TimeSyncResponse getDefaultInstance() {
return defaultInstance;
}
public TimeSyncResponse getDefaultInstanceForType() {
return defaultInstance;
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TimeSyncResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
return edu.brown.hstore.Hstore.internal_static_edu_brown_hstore_TimeSyncResponse_fieldAccessorTable;
}
// required int32 sender_id = 1;
public static final int SENDER_ID_FIELD_NUMBER = 1;
private boolean hasSenderId;
private int senderId_ = 0;
public boolean hasSenderId() { return hasSenderId; }
public int getSenderId() { return senderId_; }
// required int64 t0_s = 2;
public static final int T0_S_FIELD_NUMBER = 2;
private boolean hasT0S;
private long t0S_ = 0L;
public boolean hasT0S() { return hasT0S; }
public long getT0S() { return t0S_; }
// required int64 t0_r = 3;
public static final int T0_R_FIELD_NUMBER = 3;
private boolean hasT0R;
private long t0R_ = 0L;
public boolean hasT0R() { return hasT0R; }
public long getT0R() { return t0R_; }
// required int64 t1_s = 4;
public static final int T1_S_FIELD_NUMBER = 4;
private boolean hasT1S;
private long t1S_ = 0L;
public boolean hasT1S() { return hasT1S; }
public long getT1S() { return t1S_; }
private void initFields() {
}
public final boolean isInitialized() {
if (!hasSenderId) return false;
if (!hasT0S) return false;
if (!hasT0R) return false;
if (!hasT1S) return false;
return true;
}
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
if (hasSenderId()) {
output.writeInt32(1, getSenderId());
}
if (hasT0S()) {
output.writeInt64(2, getT0S());
}
if (hasT0R()) {
output.writeInt64(3, getT0R());
}
if (hasT1S()) {
output.writeInt64(4, getT1S());
}
getUnknownFields().writeTo(output);
}
private int memoizedSerializedSize = -1;
public int getSerializedSize() {
int size = memoizedSerializedSize;
if (size != -1) return size;
size = 0;
if (hasSenderId()) {
size += com.google.protobuf.CodedOutputStream
.computeInt32Size(1, getSenderId());
}
if (hasT0S()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(2, getT0S());
}
if (hasT0R()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(3, getT0R());
}
if (hasT1S()) {
size += com.google.protobuf.CodedOutputStream
.computeInt64Size(4, getT1S());
}
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
return newBuilder().mergeFrom(data, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
Builder builder = newBuilder();
if (builder.mergeDelimitedFrom(input)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseDelimitedFrom(
java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
Builder builder = newBuilder();
} else {
if (builder.mergeDelimitedFrom(input, extensionRegistry)) {
return builder.buildParsed();
} else {
return null;
}
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return newBuilder().mergeFrom(input).buildParsed();
}
public static edu.brown.hstore.Hstore.TimeSyncResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
return newBuilder().mergeFrom(input, extensionRegistry)
.buildParsed();
}
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
public static Builder newBuilder(edu.brown.hstore.Hstore.TimeSyncResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder {
private edu.brown.hstore.Hstore.TimeSyncResponse result;
// Construct using edu.brown.hstore.Hstore.TimeSyncResponse.newBuilder()
private Builder() {}
private static Builder create() {
Builder builder = new Builder();
builder.result = new edu.brown.hstore.Hstore.TimeSyncResponse();
return builder;
}
protected edu.brown.hstore.Hstore.TimeSyncResponse internalGetResult() {
return result;
}
public Builder clear() {
if (result == null) {
throw new IllegalStateException(
"Cannot call clear() after build().");
}
result = new edu.brown.hstore.Hstore.TimeSyncResponse();
return this;
}
public Builder clone() {
return create().mergeFrom(result);
}
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
return edu.brown.hstore.Hstore.TimeSyncResponse.getDescriptor();
}
public edu.brown.hstore.Hstore.TimeSyncResponse getDefaultInstanceForType() {
return edu.brown.hstore.Hstore.TimeSyncResponse.getDefaultInstance();
}
public boolean isInitialized() {
return result.isInitialized();
}
public edu.brown.hstore.Hstore.TimeSyncResponse build() {
if (result != null && !isInitialized()) {
throw newUninitializedMessageException(result);
}
return buildPartial();
}
private edu.brown.hstore.Hstore.TimeSyncResponse buildParsed()
throws com.google.protobuf.InvalidProtocolBufferException {
if (!isInitialized()) {
throw newUninitializedMessageException(
result).asInvalidProtocolBufferException();
}
return buildPartial();
}
public edu.brown.hstore.Hstore.TimeSyncResponse buildPartial() {
if (result == null) {
throw new IllegalStateException(
"build() has already been called on this Builder.");
}
edu.brown.hstore.Hstore.TimeSyncResponse returnMe = result;
result = null;
return returnMe;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
if (other instanceof edu.brown.hstore.Hstore.TimeSyncResponse) {
return mergeFrom((edu.brown.hstore.Hstore.TimeSyncResponse)other);
super.mergeFrom(other);
return this;
}
}
public Builder mergeFrom(edu.brown.hstore.Hstore.TimeSyncResponse other) {
if (other == edu.brown.hstore.Hstore.TimeSyncResponse.getDefaultInstance()) return this;
if (other.hasSenderId()) {
setSenderId(other.getSenderId());
}
if (other.hasT0S()) {
setT0S(other.getT0S());
}
if (other.hasT0R()) {
setT0R(other.getT0R());
}
if (other.hasT1S()) {
setT1S(other.getT1S());
}
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
public Builder mergeFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
com.google.protobuf.UnknownFieldSet.Builder unknownFields =
com.google.protobuf.UnknownFieldSet.newBuilder(
this.getUnknownFields());
while (true) {
int tag = input.readTag();
switch (tag) {
case 0:
this.setUnknownFields(unknownFields.build());
return this;
default: {
if (!parseUnknownField(input, unknownFields,
extensionRegistry, tag)) {
this.setUnknownFields(unknownFields.build());
return this;
}
break;
}
case 8: {
setSenderId(input.readInt32());
break;
}
case 16: {
setT0S(input.readInt64());
break;
}
case 24: {
setT0R(input.readInt64());
break;
}
case 32: {
setT1S(input.readInt64());
break;
}
}
}
}
// required int32 sender_id = 1;
public boolean hasSenderId() {
return result.hasSenderId();
}
public int getSenderId() {
return result.getSenderId();
}
public Builder setSenderId(int value) {
result.hasSenderId = true;
result.senderId_ = value;
return this;
}
public Builder clearSenderId() {
result.hasSenderId = false;
result.senderId_ = 0;
return this;
}
// required int64 t0_s = 2;
public boolean hasT0S() {
return result.hasT0S();
}
public long getT0S() {
return result.getT0S();
}
public Builder setT0S(long value) {
result.hasT0S = true;
result.t0S_ = value;
return this;
}
public Builder clearT0S() {
result.hasT0S = false;
result.t0S_ = 0L;
return this;
}
// required int64 t0_r = 3;
public boolean hasT0R() {
return result.hasT0R();
}
public long getT0R() {
return result.getT0R();
}
public Builder setT0R(long value) {
result.hasT0R = true;
result.t0R_ = value;
return this;
}
public Builder clearT0R() {
result.hasT0R = false;
result.t0R_ = 0L;
return this;
}
// required int64 t1_s = 4;
public boolean hasT1S() {
return result.hasT1S();
}
public long getT1S() {
return result.getT1S();
}
public Builder setT1S(long value) {
result.hasT1S = true;
result.t1S_ = value;
return this;
}
public Builder clearT1S() {
result.hasT1S = false;
result.t1S_ = 0L;
return this;
}
// @@protoc_insertion_point(builder_scope:edu.brown.hstore.TimeSyncResponse)
}
static {
defaultInstance = new TimeSyncResponse(true);
edu.brown.hstore.Hstore.internalForceInit();
defaultInstance.initFields();
}
// @@protoc_insertion_point(class_scope:edu.brown.hstore.TimeSyncResponse)
}
public static abstract class HStoreService
implements com.google.protobuf.Service {
protected HStoreService() {}
public interface Interface {
public abstract void transactionInit(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionInitRequest request,
com.google.protobuf.RpcCallback done);
public abstract void transactionWork(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionWorkRequest request,
com.google.protobuf.RpcCallback done);
public abstract void transactionMap(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionMapRequest request,
com.google.protobuf.RpcCallback done);
public abstract void transactionReduce(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionReduceRequest request,
com.google.protobuf.RpcCallback done);
public abstract void transactionPrepare(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionPrepareRequest request,
com.google.protobuf.RpcCallback done);
public abstract void transactionFinish(
com.google.protobuf.RpcController controller,
edu.brown.hstore.Hstore.TransactionFinishRequest request,
com.google.protobuf.RpcCallback |