You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by sa...@apache.org on 2016/04/25 20:53:06 UTC
[22/52] [abbrv] phoenix git commit: PHOENIX-1311 HBase namespaces
surfaced in phoenix
http://git-wip-us.apache.org/repos/asf/phoenix/blob/7e432be7/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/MetaDataProtos.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/MetaDataProtos.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/MetaDataProtos.java
index ae72382..62e300a 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/MetaDataProtos.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/MetaDataProtos.java
@@ -69,6 +69,30 @@ public final class MetaDataProtos {
* <code>FUNCTION_NOT_IN_REGION = 13;</code>
*/
FUNCTION_NOT_IN_REGION(13, 13),
+ /**
+ * <code>SCHEMA_ALREADY_EXISTS = 14;</code>
+ */
+ SCHEMA_ALREADY_EXISTS(14, 14),
+ /**
+ * <code>NEWER_SCHEMA_FOUND = 15;</code>
+ */
+ NEWER_SCHEMA_FOUND(15, 15),
+ /**
+ * <code>SCHEMA_NOT_FOUND = 16;</code>
+ */
+ SCHEMA_NOT_FOUND(16, 16),
+ /**
+ * <code>SCHEMA_NOT_IN_REGION = 17;</code>
+ */
+ SCHEMA_NOT_IN_REGION(17, 17),
+ /**
+ * <code>TABLES_EXIST_ON_SCHEMA = 18;</code>
+ */
+ TABLES_EXIST_ON_SCHEMA(18, 18),
+ /**
+ * <code>UNALLOWED_SCHEMA_MUTATION = 19;</code>
+ */
+ UNALLOWED_SCHEMA_MUTATION(19, 19),
;
/**
@@ -127,6 +151,30 @@ public final class MetaDataProtos {
* <code>FUNCTION_NOT_IN_REGION = 13;</code>
*/
public static final int FUNCTION_NOT_IN_REGION_VALUE = 13;
+ /**
+ * <code>SCHEMA_ALREADY_EXISTS = 14;</code>
+ */
+ public static final int SCHEMA_ALREADY_EXISTS_VALUE = 14;
+ /**
+ * <code>NEWER_SCHEMA_FOUND = 15;</code>
+ */
+ public static final int NEWER_SCHEMA_FOUND_VALUE = 15;
+ /**
+ * <code>SCHEMA_NOT_FOUND = 16;</code>
+ */
+ public static final int SCHEMA_NOT_FOUND_VALUE = 16;
+ /**
+ * <code>SCHEMA_NOT_IN_REGION = 17;</code>
+ */
+ public static final int SCHEMA_NOT_IN_REGION_VALUE = 17;
+ /**
+ * <code>TABLES_EXIST_ON_SCHEMA = 18;</code>
+ */
+ public static final int TABLES_EXIST_ON_SCHEMA_VALUE = 18;
+ /**
+ * <code>UNALLOWED_SCHEMA_MUTATION = 19;</code>
+ */
+ public static final int UNALLOWED_SCHEMA_MUTATION_VALUE = 19;
public final int getNumber() { return value; }
@@ -147,6 +195,12 @@ public final class MetaDataProtos {
case 11: return FUNCTION_NOT_FOUND;
case 12: return NEWER_FUNCTION_FOUND;
case 13: return FUNCTION_NOT_IN_REGION;
+ case 14: return SCHEMA_ALREADY_EXISTS;
+ case 15: return NEWER_SCHEMA_FOUND;
+ case 16: return SCHEMA_NOT_FOUND;
+ case 17: return SCHEMA_NOT_IN_REGION;
+ case 18: return TABLES_EXIST_ON_SCHEMA;
+ case 19: return UNALLOWED_SCHEMA_MUTATION;
default: return null;
}
}
@@ -1601,6 +1655,20 @@ public final class MetaDataProtos {
*/
org.apache.phoenix.coprocessor.generated.MetaDataProtos.SharedTableStateOrBuilder getSharedTablesToDeleteOrBuilder(
int index);
+
+ // optional .PSchema schema = 10;
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ boolean hasSchema();
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema getSchema();
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder getSchemaOrBuilder();
}
/**
* Protobuf type {@code MetaDataResponse}
@@ -1721,6 +1789,19 @@ public final class MetaDataProtos {
sharedTablesToDelete_.add(input.readMessage(org.apache.phoenix.coprocessor.generated.MetaDataProtos.SharedTableState.PARSER, extensionRegistry));
break;
}
+ case 82: {
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder subBuilder = null;
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
+ subBuilder = schema_.toBuilder();
+ }
+ schema_ = input.readMessage(org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.PARSER, extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(schema_);
+ schema_ = subBuilder.buildPartial();
+ }
+ bitField0_ |= 0x00000040;
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -1967,6 +2048,28 @@ public final class MetaDataProtos {
return sharedTablesToDelete_.get(index);
}
+ // optional .PSchema schema = 10;
+ public static final int SCHEMA_FIELD_NUMBER = 10;
+ private org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema schema_;
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public boolean hasSchema() {
+ return ((bitField0_ & 0x00000040) == 0x00000040);
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema getSchema() {
+ return schema_;
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder getSchemaOrBuilder() {
+ return schema_;
+ }
+
private void initFields() {
returnCode_ = org.apache.phoenix.coprocessor.generated.MetaDataProtos.MutationCode.TABLE_ALREADY_EXISTS;
mutationTime_ = 0L;
@@ -1977,6 +2080,7 @@ public final class MetaDataProtos {
functionName_ = com.google.protobuf.ByteString.EMPTY;
function_ = java.util.Collections.emptyList();
sharedTablesToDelete_ = java.util.Collections.emptyList();
+ schema_ = org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.getDefaultInstance();
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
@@ -2001,6 +2105,12 @@ public final class MetaDataProtos {
return false;
}
}
+ if (hasSchema()) {
+ if (!getSchema().isInitialized()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ }
memoizedIsInitialized = 1;
return true;
}
@@ -2035,6 +2145,9 @@ public final class MetaDataProtos {
for (int i = 0; i < sharedTablesToDelete_.size(); i++) {
output.writeMessage(9, sharedTablesToDelete_.get(i));
}
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
+ output.writeMessage(10, schema_);
+ }
getUnknownFields().writeTo(output);
}
@@ -2085,6 +2198,10 @@ public final class MetaDataProtos {
size += com.google.protobuf.CodedOutputStream
.computeMessageSize(9, sharedTablesToDelete_.get(i));
}
+ if (((bitField0_ & 0x00000040) == 0x00000040)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeMessageSize(10, schema_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
@@ -2144,6 +2261,11 @@ public final class MetaDataProtos {
.equals(other.getFunctionList());
result = result && getSharedTablesToDeleteList()
.equals(other.getSharedTablesToDeleteList());
+ result = result && (hasSchema() == other.hasSchema());
+ if (hasSchema()) {
+ result = result && getSchema()
+ .equals(other.getSchema());
+ }
result = result &&
getUnknownFields().equals(other.getUnknownFields());
return result;
@@ -2193,6 +2315,10 @@ public final class MetaDataProtos {
hash = (37 * hash) + SHAREDTABLESTODELETE_FIELD_NUMBER;
hash = (53 * hash) + getSharedTablesToDeleteList().hashCode();
}
+ if (hasSchema()) {
+ hash = (37 * hash) + SCHEMA_FIELD_NUMBER;
+ hash = (53 * hash) + getSchema().hashCode();
+ }
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
@@ -2297,6 +2423,7 @@ public final class MetaDataProtos {
getTableFieldBuilder();
getFunctionFieldBuilder();
getSharedTablesToDeleteFieldBuilder();
+ getSchemaFieldBuilder();
}
}
private static Builder create() {
@@ -2335,6 +2462,12 @@ public final class MetaDataProtos {
} else {
sharedTablesToDeleteBuilder_.clear();
}
+ if (schemaBuilder_ == null) {
+ schema_ = org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.getDefaultInstance();
+ } else {
+ schemaBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000200);
return this;
}
@@ -2414,6 +2547,14 @@ public final class MetaDataProtos {
} else {
result.sharedTablesToDelete_ = sharedTablesToDeleteBuilder_.build();
}
+ if (((from_bitField0_ & 0x00000200) == 0x00000200)) {
+ to_bitField0_ |= 0x00000040;
+ }
+ if (schemaBuilder_ == null) {
+ result.schema_ = schema_;
+ } else {
+ result.schema_ = schemaBuilder_.build();
+ }
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@@ -2510,6 +2651,9 @@ public final class MetaDataProtos {
}
}
}
+ if (other.hasSchema()) {
+ mergeSchema(other.getSchema());
+ }
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
@@ -2533,6 +2677,12 @@ public final class MetaDataProtos {
return false;
}
}
+ if (hasSchema()) {
+ if (!getSchema().isInitialized()) {
+
+ return false;
+ }
+ }
return true;
}
@@ -3401,6 +3551,123 @@ public final class MetaDataProtos {
return sharedTablesToDeleteBuilder_;
}
+ // optional .PSchema schema = 10;
+ private org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema schema_ = org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.getDefaultInstance();
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder> schemaBuilder_;
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public boolean hasSchema() {
+ return ((bitField0_ & 0x00000200) == 0x00000200);
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema getSchema() {
+ if (schemaBuilder_ == null) {
+ return schema_;
+ } else {
+ return schemaBuilder_.getMessage();
+ }
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public Builder setSchema(org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema value) {
+ if (schemaBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ schema_ = value;
+ onChanged();
+ } else {
+ schemaBuilder_.setMessage(value);
+ }
+ bitField0_ |= 0x00000200;
+ return this;
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public Builder setSchema(
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder builderForValue) {
+ if (schemaBuilder_ == null) {
+ schema_ = builderForValue.build();
+ onChanged();
+ } else {
+ schemaBuilder_.setMessage(builderForValue.build());
+ }
+ bitField0_ |= 0x00000200;
+ return this;
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public Builder mergeSchema(org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema value) {
+ if (schemaBuilder_ == null) {
+ if (((bitField0_ & 0x00000200) == 0x00000200) &&
+ schema_ != org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.getDefaultInstance()) {
+ schema_ =
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.newBuilder(schema_).mergeFrom(value).buildPartial();
+ } else {
+ schema_ = value;
+ }
+ onChanged();
+ } else {
+ schemaBuilder_.mergeFrom(value);
+ }
+ bitField0_ |= 0x00000200;
+ return this;
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public Builder clearSchema() {
+ if (schemaBuilder_ == null) {
+ schema_ = org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.getDefaultInstance();
+ onChanged();
+ } else {
+ schemaBuilder_.clear();
+ }
+ bitField0_ = (bitField0_ & ~0x00000200);
+ return this;
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder getSchemaBuilder() {
+ bitField0_ |= 0x00000200;
+ onChanged();
+ return getSchemaFieldBuilder().getBuilder();
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ public org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder getSchemaOrBuilder() {
+ if (schemaBuilder_ != null) {
+ return schemaBuilder_.getMessageOrBuilder();
+ } else {
+ return schema_;
+ }
+ }
+ /**
+ * <code>optional .PSchema schema = 10;</code>
+ */
+ private com.google.protobuf.SingleFieldBuilder<
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder>
+ getSchemaFieldBuilder() {
+ if (schemaBuilder_ == null) {
+ schemaBuilder_ = new com.google.protobuf.SingleFieldBuilder<
+ org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchema.Builder, org.apache.phoenix.coprocessor.generated.PSchemaProtos.PSchemaOrBuilder>(
+ schema_,
+ getParentForChildren(),
+ isClean());
+ schema_ = null;
+ }
+ return schemaBuilder_;
+ }
+
// @@protoc_insertion_point(builder_scope:MetaDataResponse)
}
@@ -5297,56 +5564,63 @@ public final class MetaDataProtos {
// @@protoc_insertion_point(class_scope:GetFunctionsRequest)
}
- public interface CreateTableRequestOrBuilder
+ public interface GetSchemaRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder {
- // repeated bytes tableMetadataMutations = 1;
+ // required string schemaName = 1;
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- java.util.List<com.google.protobuf.ByteString> getTableMetadataMutationsList();
+ boolean hasSchemaName();
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- int getTableMetadataMutationsCount();
+ java.lang.String getSchemaName();
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- com.google.protobuf.ByteString getTableMetadataMutations(int index);
+ com.google.protobuf.ByteString
+ getSchemaNameBytes();
- // optional int32 clientVersion = 2;
+ // required int64 clientTimestamp = 2;
/**
- * <code>optional int32 clientVersion = 2;</code>
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ boolean hasClientTimestamp();
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ long getClientTimestamp();
+
+ // required int32 clientVersion = 3;
+ /**
+ * <code>required int32 clientVersion = 3;</code>
*/
boolean hasClientVersion();
/**
- * <code>optional int32 clientVersion = 2;</code>
+ * <code>required int32 clientVersion = 3;</code>
*/
int getClientVersion();
}
/**
- * Protobuf type {@code CreateTableRequest}
- *
- * <pre>
- * each byte array represents a MutationProto instance
- * </pre>
+ * Protobuf type {@code GetSchemaRequest}
*/
- public static final class CreateTableRequest extends
+ public static final class GetSchemaRequest extends
com.google.protobuf.GeneratedMessage
- implements CreateTableRequestOrBuilder {
- // Use CreateTableRequest.newBuilder() to construct.
- private CreateTableRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ implements GetSchemaRequestOrBuilder {
+ // Use GetSchemaRequest.newBuilder() to construct.
+ private GetSchemaRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
super(builder);
this.unknownFields = builder.getUnknownFields();
}
- private CreateTableRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+ private GetSchemaRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
- private static final CreateTableRequest defaultInstance;
- public static CreateTableRequest getDefaultInstance() {
+ private static final GetSchemaRequest defaultInstance;
+ public static GetSchemaRequest getDefaultInstance() {
return defaultInstance;
}
- public CreateTableRequest getDefaultInstanceForType() {
+ public GetSchemaRequest getDefaultInstanceForType() {
return defaultInstance;
}
@@ -5356,7 +5630,7 @@ public final class MetaDataProtos {
getUnknownFields() {
return this.unknownFields;
}
- private CreateTableRequest(
+ private GetSchemaRequest(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
@@ -5380,15 +5654,17 @@ public final class MetaDataProtos {
break;
}
case 10: {
- if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
- tableMetadataMutations_ = new java.util.ArrayList<com.google.protobuf.ByteString>();
- mutable_bitField0_ |= 0x00000001;
- }
- tableMetadataMutations_.add(input.readBytes());
+ bitField0_ |= 0x00000001;
+ schemaName_ = input.readBytes();
break;
}
case 16: {
- bitField0_ |= 0x00000001;
+ bitField0_ |= 0x00000002;
+ clientTimestamp_ = input.readInt64();
+ break;
+ }
+ case 24: {
+ bitField0_ |= 0x00000004;
clientVersion_ = input.readInt32();
break;
}
@@ -5400,82 +5676,116 @@ public final class MetaDataProtos {
throw new com.google.protobuf.InvalidProtocolBufferException(
e.getMessage()).setUnfinishedMessage(this);
} finally {
- if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
- tableMetadataMutations_ = java.util.Collections.unmodifiableList(tableMetadataMutations_);
- }
this.unknownFields = unknownFields.build();
makeExtensionsImmutable();
}
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_GetSchemaRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_fieldAccessorTable
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_GetSchemaRequest_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.Builder.class);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.Builder.class);
}
- public static com.google.protobuf.Parser<CreateTableRequest> PARSER =
- new com.google.protobuf.AbstractParser<CreateTableRequest>() {
- public CreateTableRequest parsePartialFrom(
+ public static com.google.protobuf.Parser<GetSchemaRequest> PARSER =
+ new com.google.protobuf.AbstractParser<GetSchemaRequest>() {
+ public GetSchemaRequest parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
- return new CreateTableRequest(input, extensionRegistry);
+ return new GetSchemaRequest(input, extensionRegistry);
}
};
@java.lang.Override
- public com.google.protobuf.Parser<CreateTableRequest> getParserForType() {
+ public com.google.protobuf.Parser<GetSchemaRequest> getParserForType() {
return PARSER;
}
private int bitField0_;
- // repeated bytes tableMetadataMutations = 1;
- public static final int TABLEMETADATAMUTATIONS_FIELD_NUMBER = 1;
- private java.util.List<com.google.protobuf.ByteString> tableMetadataMutations_;
+ // required string schemaName = 1;
+ public static final int SCHEMANAME_FIELD_NUMBER = 1;
+ private java.lang.Object schemaName_;
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- public java.util.List<com.google.protobuf.ByteString>
- getTableMetadataMutationsList() {
- return tableMetadataMutations_;
+ public boolean hasSchemaName() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
}
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- public int getTableMetadataMutationsCount() {
- return tableMetadataMutations_.size();
+ public java.lang.String getSchemaName() {
+ java.lang.Object ref = schemaName_;
+ if (ref instanceof java.lang.String) {
+ return (java.lang.String) ref;
+ } else {
+ com.google.protobuf.ByteString bs =
+ (com.google.protobuf.ByteString) ref;
+ java.lang.String s = bs.toStringUtf8();
+ if (bs.isValidUtf8()) {
+ schemaName_ = s;
+ }
+ return s;
+ }
}
/**
- * <code>repeated bytes tableMetadataMutations = 1;</code>
+ * <code>required string schemaName = 1;</code>
*/
- public com.google.protobuf.ByteString getTableMetadataMutations(int index) {
- return tableMetadataMutations_.get(index);
+ public com.google.protobuf.ByteString
+ getSchemaNameBytes() {
+ java.lang.Object ref = schemaName_;
+ if (ref instanceof java.lang.String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ schemaName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
}
- // optional int32 clientVersion = 2;
- public static final int CLIENTVERSION_FIELD_NUMBER = 2;
+ // required int64 clientTimestamp = 2;
+ public static final int CLIENTTIMESTAMP_FIELD_NUMBER = 2;
+ private long clientTimestamp_;
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public boolean hasClientTimestamp() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public long getClientTimestamp() {
+ return clientTimestamp_;
+ }
+
+ // required int32 clientVersion = 3;
+ public static final int CLIENTVERSION_FIELD_NUMBER = 3;
private int clientVersion_;
/**
- * <code>optional int32 clientVersion = 2;</code>
+ * <code>required int32 clientVersion = 3;</code>
*/
public boolean hasClientVersion() {
- return ((bitField0_ & 0x00000001) == 0x00000001);
+ return ((bitField0_ & 0x00000004) == 0x00000004);
}
/**
- * <code>optional int32 clientVersion = 2;</code>
+ * <code>required int32 clientVersion = 3;</code>
*/
public int getClientVersion() {
return clientVersion_;
}
private void initFields() {
- tableMetadataMutations_ = java.util.Collections.emptyList();
+ schemaName_ = "";
+ clientTimestamp_ = 0L;
clientVersion_ = 0;
}
private byte memoizedIsInitialized = -1;
@@ -5483,6 +5793,18 @@ public final class MetaDataProtos {
byte isInitialized = memoizedIsInitialized;
if (isInitialized != -1) return isInitialized == 1;
+ if (!hasSchemaName()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasClientTimestamp()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ if (!hasClientVersion()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
memoizedIsInitialized = 1;
return true;
}
@@ -5490,15 +5812,2128 @@ public final class MetaDataProtos {
public void writeTo(com.google.protobuf.CodedOutputStream output)
throws java.io.IOException {
getSerializedSize();
- for (int i = 0; i < tableMetadataMutations_.size(); i++) {
- output.writeBytes(1, tableMetadataMutations_.get(i));
- }
if (((bitField0_ & 0x00000001) == 0x00000001)) {
- output.writeInt32(2, clientVersion_);
+ output.writeBytes(1, getSchemaNameBytes());
}
- getUnknownFields().writeTo(output);
- }
-
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ output.writeInt64(2, clientTimestamp_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ output.writeInt32(3, clientVersion_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBytesSize(1, getSchemaNameBytes());
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(2, clientTimestamp_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(3, clientVersion_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest)) {
+ return super.equals(obj);
+ }
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest) obj;
+
+ boolean result = true;
+ result = result && (hasSchemaName() == other.hasSchemaName());
+ if (hasSchemaName()) {
+ result = result && getSchemaName()
+ .equals(other.getSchemaName());
+ }
+ result = result && (hasClientTimestamp() == other.hasClientTimestamp());
+ if (hasClientTimestamp()) {
+ result = result && (getClientTimestamp()
+ == other.getClientTimestamp());
+ }
+ result = result && (hasClientVersion() == other.hasClientVersion());
+ if (hasClientVersion()) {
+ result = result && (getClientVersion()
+ == other.getClientVersion());
+ }
+ result = result &&
+ getUnknownFields().equals(other.getUnknownFields());
+ return result;
+ }
+
+ private int memoizedHashCode = 0;
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptorForType().hashCode();
+ if (hasSchemaName()) {
+ hash = (37 * hash) + SCHEMANAME_FIELD_NUMBER;
+ hash = (53 * hash) + getSchemaName().hashCode();
+ }
+ if (hasClientTimestamp()) {
+ hash = (37 * hash) + CLIENTTIMESTAMP_FIELD_NUMBER;
+ hash = (53 * hash) + hashLong(getClientTimestamp());
+ }
+ if (hasClientVersion()) {
+ hash = (37 * hash) + CLIENTVERSION_FIELD_NUMBER;
+ hash = (53 * hash) + getClientVersion();
+ }
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() { return Builder.create(); }
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() { return newBuilder(this); }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code GetSchemaRequest}
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequestOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_GetSchemaRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_GetSchemaRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.Builder.class);
+ }
+
+ // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ schemaName_ = "";
+ bitField0_ = (bitField0_ & ~0x00000001);
+ clientTimestamp_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ clientVersion_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000004);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_GetSchemaRequest_descriptor;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest getDefaultInstanceForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.getDefaultInstance();
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest build() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest buildPartial() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.schemaName_ = schemaName_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ result.clientTimestamp_ = clientTimestamp_;
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000004;
+ }
+ result.clientVersion_ = clientVersion_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest) {
+ return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest other) {
+ if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest.getDefaultInstance()) return this;
+ if (other.hasSchemaName()) {
+ bitField0_ |= 0x00000001;
+ schemaName_ = other.schemaName_;
+ onChanged();
+ }
+ if (other.hasClientTimestamp()) {
+ setClientTimestamp(other.getClientTimestamp());
+ }
+ if (other.hasClientVersion()) {
+ setClientVersion(other.getClientVersion());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ return this;
+ }
+
+ public final boolean isInitialized() {
+ if (!hasSchemaName()) {
+
+ return false;
+ }
+ if (!hasClientTimestamp()) {
+
+ return false;
+ }
+ if (!hasClientVersion()) {
+
+ return false;
+ }
+ return true;
+ }
+
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetSchemaRequest) e.getUnfinishedMessage();
+ throw e;
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+ private int bitField0_;
+
+ // required string schemaName = 1;
+ private java.lang.Object schemaName_ = "";
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public boolean hasSchemaName() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public java.lang.String getSchemaName() {
+ java.lang.Object ref = schemaName_;
+ if (!(ref instanceof java.lang.String)) {
+ java.lang.String s = ((com.google.protobuf.ByteString) ref)
+ .toStringUtf8();
+ schemaName_ = s;
+ return s;
+ } else {
+ return (java.lang.String) ref;
+ }
+ }
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public com.google.protobuf.ByteString
+ getSchemaNameBytes() {
+ java.lang.Object ref = schemaName_;
+ if (ref instanceof String) {
+ com.google.protobuf.ByteString b =
+ com.google.protobuf.ByteString.copyFromUtf8(
+ (java.lang.String) ref);
+ schemaName_ = b;
+ return b;
+ } else {
+ return (com.google.protobuf.ByteString) ref;
+ }
+ }
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public Builder setSchemaName(
+ java.lang.String value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000001;
+ schemaName_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public Builder clearSchemaName() {
+ bitField0_ = (bitField0_ & ~0x00000001);
+ schemaName_ = getDefaultInstance().getSchemaName();
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>required string schemaName = 1;</code>
+ */
+ public Builder setSchemaNameBytes(
+ com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ bitField0_ |= 0x00000001;
+ schemaName_ = value;
+ onChanged();
+ return this;
+ }
+
+ // required int64 clientTimestamp = 2;
+ private long clientTimestamp_ ;
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public boolean hasClientTimestamp() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public long getClientTimestamp() {
+ return clientTimestamp_;
+ }
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public Builder setClientTimestamp(long value) {
+ bitField0_ |= 0x00000002;
+ clientTimestamp_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>required int64 clientTimestamp = 2;</code>
+ */
+ public Builder clearClientTimestamp() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ clientTimestamp_ = 0L;
+ onChanged();
+ return this;
+ }
+
+ // required int32 clientVersion = 3;
+ private int clientVersion_ ;
+ /**
+ * <code>required int32 clientVersion = 3;</code>
+ */
+ public boolean hasClientVersion() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+ /**
+ * <code>required int32 clientVersion = 3;</code>
+ */
+ public int getClientVersion() {
+ return clientVersion_;
+ }
+ /**
+ * <code>required int32 clientVersion = 3;</code>
+ */
+ public Builder setClientVersion(int value) {
+ bitField0_ |= 0x00000004;
+ clientVersion_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>required int32 clientVersion = 3;</code>
+ */
+ public Builder clearClientVersion() {
+ bitField0_ = (bitField0_ & ~0x00000004);
+ clientVersion_ = 0;
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:GetSchemaRequest)
+ }
+
+ static {
+ defaultInstance = new GetSchemaRequest(true);
+ defaultInstance.initFields();
+ }
+
+ // @@protoc_insertion_point(class_scope:GetSchemaRequest)
+ }
+
+ public interface CreateTableRequestOrBuilder
+ extends com.google.protobuf.MessageOrBuilder {
+
+ // repeated bytes tableMetadataMutations = 1;
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ java.util.List<com.google.protobuf.ByteString> getTableMetadataMutationsList();
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ int getTableMetadataMutationsCount();
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ com.google.protobuf.ByteString getTableMetadataMutations(int index);
+
+ // optional int32 clientVersion = 2;
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ boolean hasClientVersion();
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ int getClientVersion();
+ }
+ /**
+ * Protobuf type {@code CreateTableRequest}
+ *
+ * <pre>
+ * each byte array represents a MutationProto instance
+ * </pre>
+ */
+ public static final class CreateTableRequest extends
+ com.google.protobuf.GeneratedMessage
+ implements CreateTableRequestOrBuilder {
+ // Use CreateTableRequest.newBuilder() to construct.
+ private CreateTableRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ super(builder);
+ this.unknownFields = builder.getUnknownFields();
+ }
+ private CreateTableRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+
+ private static final CreateTableRequest defaultInstance;
+ public static CreateTableRequest getDefaultInstance() {
+ return defaultInstance;
+ }
+
+ public CreateTableRequest getDefaultInstanceForType() {
+ return defaultInstance;
+ }
+
+ private final com.google.protobuf.UnknownFieldSet unknownFields;
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private CreateTableRequest(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ initFields();
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!parseUnknownField(input, unknownFields,
+ extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = new java.util.ArrayList<com.google.protobuf.ByteString>();
+ mutable_bitField0_ |= 0x00000001;
+ }
+ tableMetadataMutations_.add(input.readBytes());
+ break;
+ }
+ case 16: {
+ bitField0_ |= 0x00000001;
+ clientVersion_ = input.readInt32();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this);
+ } finally {
+ if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = java.util.Collections.unmodifiableList(tableMetadataMutations_);
+ }
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.Builder.class);
+ }
+
+ public static com.google.protobuf.Parser<CreateTableRequest> PARSER =
+ new com.google.protobuf.AbstractParser<CreateTableRequest>() {
+ public CreateTableRequest parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new CreateTableRequest(input, extensionRegistry);
+ }
+ };
+
+ @java.lang.Override
+ public com.google.protobuf.Parser<CreateTableRequest> getParserForType() {
+ return PARSER;
+ }
+
+ private int bitField0_;
+ // repeated bytes tableMetadataMutations = 1;
+ public static final int TABLEMETADATAMUTATIONS_FIELD_NUMBER = 1;
+ private java.util.List<com.google.protobuf.ByteString> tableMetadataMutations_;
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public java.util.List<com.google.protobuf.ByteString>
+ getTableMetadataMutationsList() {
+ return tableMetadataMutations_;
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public int getTableMetadataMutationsCount() {
+ return tableMetadataMutations_.size();
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public com.google.protobuf.ByteString getTableMetadataMutations(int index) {
+ return tableMetadataMutations_.get(index);
+ }
+
+ // optional int32 clientVersion = 2;
+ public static final int CLIENTVERSION_FIELD_NUMBER = 2;
+ private int clientVersion_;
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public boolean hasClientVersion() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public int getClientVersion() {
+ return clientVersion_;
+ }
+
+ private void initFields() {
+ tableMetadataMutations_ = java.util.Collections.emptyList();
+ clientVersion_ = 0;
+ }
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized != -1) return isInitialized == 1;
+
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ getSerializedSize();
+ for (int i = 0; i < tableMetadataMutations_.size(); i++) {
+ output.writeBytes(1, tableMetadataMutations_.get(i));
+ }
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ output.writeInt32(2, clientVersion_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ {
+ int dataSize = 0;
+ for (int i = 0; i < tableMetadataMutations_.size(); i++) {
+ dataSize += com.google.protobuf.CodedOutputStream
+ .computeBytesSizeNoTag(tableMetadataMutations_.get(i));
+ }
+ size += dataSize;
+ size += 1 * getTableMetadataMutationsList().size();
+ }
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(2, clientVersion_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest)) {
+ return super.equals(obj);
+ }
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest) obj;
+
+ boolean result = true;
+ result = result && getTableMetadataMutationsList()
+ .equals(other.getTableMetadataMutationsList());
+ result = result && (hasClientVersion() == other.hasClientVersion());
+ if (hasClientVersion()) {
+ result = result && (getClientVersion()
+ == other.getClientVersion());
+ }
+ result = result &&
+ getUnknownFields().equals(other.getUnknownFields());
+ return result;
+ }
+
+ private int memoizedHashCode = 0;
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptorForType().hashCode();
+ if (getTableMetadataMutationsCount() > 0) {
+ hash = (37 * hash) + TABLEMETADATAMUTATIONS_FIELD_NUMBER;
+ hash = (53 * hash) + getTableMetadataMutationsList().hashCode();
+ }
+ if (hasClientVersion()) {
+ hash = (37 * hash) + CLIENTVERSION_FIELD_NUMBER;
+ hash = (53 * hash) + getClientVersion();
+ }
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() { return Builder.create(); }
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() { return newBuilder(this); }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code CreateTableRequest}
+ *
+ * <pre>
+ * each byte array represents a MutationProto instance
+ * </pre>
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequestOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.Builder.class);
+ }
+
+ // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ tableMetadataMutations_ = java.util.Collections.emptyList();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ clientVersion_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateTableRequest_descriptor;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest getDefaultInstanceForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.getDefaultInstance();
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest build() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest buildPartial() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = java.util.Collections.unmodifiableList(tableMetadataMutations_);
+ bitField0_ = (bitField0_ & ~0x00000001);
+ }
+ result.tableMetadataMutations_ = tableMetadataMutations_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.clientVersion_ = clientVersion_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest) {
+ return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest other) {
+ if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest.getDefaultInstance()) return this;
+ if (!other.tableMetadataMutations_.isEmpty()) {
+ if (tableMetadataMutations_.isEmpty()) {
+ tableMetadataMutations_ = other.tableMetadataMutations_;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ } else {
+ ensureTableMetadataMutationsIsMutable();
+ tableMetadataMutations_.addAll(other.tableMetadataMutations_);
+ }
+ onChanged();
+ }
+ if (other.hasClientVersion()) {
+ setClientVersion(other.getClientVersion());
+ }
+ this.mergeUnknownFields(other.getUnknownFields());
+ return this;
+ }
+
+ public final boolean isInitialized() {
+ return true;
+ }
+
+ public Builder mergeFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest parsedMessage = null;
+ try {
+ parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest) e.getUnfinishedMessage();
+ throw e;
+ } finally {
+ if (parsedMessage != null) {
+ mergeFrom(parsedMessage);
+ }
+ }
+ return this;
+ }
+ private int bitField0_;
+
+ // repeated bytes tableMetadataMutations = 1;
+ private java.util.List<com.google.protobuf.ByteString> tableMetadataMutations_ = java.util.Collections.emptyList();
+ private void ensureTableMetadataMutationsIsMutable() {
+ if (!((bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = new java.util.ArrayList<com.google.protobuf.ByteString>(tableMetadataMutations_);
+ bitField0_ |= 0x00000001;
+ }
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public java.util.List<com.google.protobuf.ByteString>
+ getTableMetadataMutationsList() {
+ return java.util.Collections.unmodifiableList(tableMetadataMutations_);
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public int getTableMetadataMutationsCount() {
+ return tableMetadataMutations_.size();
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public com.google.protobuf.ByteString getTableMetadataMutations(int index) {
+ return tableMetadataMutations_.get(index);
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public Builder setTableMetadataMutations(
+ int index, com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureTableMetadataMutationsIsMutable();
+ tableMetadataMutations_.set(index, value);
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public Builder addTableMetadataMutations(com.google.protobuf.ByteString value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ ensureTableMetadataMutationsIsMutable();
+ tableMetadataMutations_.add(value);
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public Builder addAllTableMetadataMutations(
+ java.lang.Iterable<? extends com.google.protobuf.ByteString> values) {
+ ensureTableMetadataMutationsIsMutable();
+ super.addAll(values, tableMetadataMutations_);
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public Builder clearTableMetadataMutations() {
+ tableMetadataMutations_ = java.util.Collections.emptyList();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ onChanged();
+ return this;
+ }
+
+ // optional int32 clientVersion = 2;
+ private int clientVersion_ ;
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public boolean hasClientVersion() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public int getClientVersion() {
+ return clientVersion_;
+ }
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public Builder setClientVersion(int value) {
+ bitField0_ |= 0x00000002;
+ clientVersion_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional int32 clientVersion = 2;</code>
+ */
+ public Builder clearClientVersion() {
+ bitField0_ = (bitField0_ & ~0x00000002);
+ clientVersion_ = 0;
+ onChanged();
+ return this;
+ }
+
+ // @@protoc_insertion_point(builder_scope:CreateTableRequest)
+ }
+
+ static {
+ defaultInstance = new CreateTableRequest(true);
+ defaultInstance.initFields();
+ }
+
+ // @@protoc_insertion_point(class_scope:CreateTableRequest)
+ }
+
+ public interface CreateFunctionRequestOrBuilder
+ extends com.google.protobuf.MessageOrBuilder {
+
+ // repeated bytes tableMetadataMutations = 1;
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ java.util.List<com.google.protobuf.ByteString> getTableMetadataMutationsList();
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ int getTableMetadataMutationsCount();
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ com.google.protobuf.ByteString getTableMetadataMutations(int index);
+
+ // required bool temporary = 2;
+ /**
+ * <code>required bool temporary = 2;</code>
+ */
+ boolean hasTemporary();
+ /**
+ * <code>required bool temporary = 2;</code>
+ */
+ boolean getTemporary();
+
+ // optional bool replace = 3;
+ /**
+ * <code>optional bool replace = 3;</code>
+ */
+ boolean hasReplace();
+ /**
+ * <code>optional bool replace = 3;</code>
+ */
+ boolean getReplace();
+
+ // optional int32 clientVersion = 4;
+ /**
+ * <code>optional int32 clientVersion = 4;</code>
+ */
+ boolean hasClientVersion();
+ /**
+ * <code>optional int32 clientVersion = 4;</code>
+ */
+ int getClientVersion();
+ }
+ /**
+ * Protobuf type {@code CreateFunctionRequest}
+ *
+ * <pre>
+ * each byte array represents a MutationProto instance
+ * </pre>
+ */
+ public static final class CreateFunctionRequest extends
+ com.google.protobuf.GeneratedMessage
+ implements CreateFunctionRequestOrBuilder {
+ // Use CreateFunctionRequest.newBuilder() to construct.
+ private CreateFunctionRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ super(builder);
+ this.unknownFields = builder.getUnknownFields();
+ }
+ private CreateFunctionRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+
+ private static final CreateFunctionRequest defaultInstance;
+ public static CreateFunctionRequest getDefaultInstance() {
+ return defaultInstance;
+ }
+
+ public CreateFunctionRequest getDefaultInstanceForType() {
+ return defaultInstance;
+ }
+
+ private final com.google.protobuf.UnknownFieldSet unknownFields;
+ @java.lang.Override
+ public final com.google.protobuf.UnknownFieldSet
+ getUnknownFields() {
+ return this.unknownFields;
+ }
+ private CreateFunctionRequest(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ initFields();
+ int mutable_bitField0_ = 0;
+ com.google.protobuf.UnknownFieldSet.Builder unknownFields =
+ com.google.protobuf.UnknownFieldSet.newBuilder();
+ try {
+ boolean done = false;
+ while (!done) {
+ int tag = input.readTag();
+ switch (tag) {
+ case 0:
+ done = true;
+ break;
+ default: {
+ if (!parseUnknownField(input, unknownFields,
+ extensionRegistry, tag)) {
+ done = true;
+ }
+ break;
+ }
+ case 10: {
+ if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = new java.util.ArrayList<com.google.protobuf.ByteString>();
+ mutable_bitField0_ |= 0x00000001;
+ }
+ tableMetadataMutations_.add(input.readBytes());
+ break;
+ }
+ case 16: {
+ bitField0_ |= 0x00000001;
+ temporary_ = input.readBool();
+ break;
+ }
+ case 24: {
+ bitField0_ |= 0x00000002;
+ replace_ = input.readBool();
+ break;
+ }
+ case 32: {
+ bitField0_ |= 0x00000004;
+ clientVersion_ = input.readInt32();
+ break;
+ }
+ }
+ }
+ } catch (com.google.protobuf.InvalidProtocolBufferException e) {
+ throw e.setUnfinishedMessage(this);
+ } catch (java.io.IOException e) {
+ throw new com.google.protobuf.InvalidProtocolBufferException(
+ e.getMessage()).setUnfinishedMessage(this);
+ } finally {
+ if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = java.util.Collections.unmodifiableList(tableMetadataMutations_);
+ }
+ this.unknownFields = unknownFields.build();
+ makeExtensionsImmutable();
+ }
+ }
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateFunctionRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateFunctionRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.Builder.class);
+ }
+
+ public static com.google.protobuf.Parser<CreateFunctionRequest> PARSER =
+ new com.google.protobuf.AbstractParser<CreateFunctionRequest>() {
+ public CreateFunctionRequest parsePartialFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return new CreateFunctionRequest(input, extensionRegistry);
+ }
+ };
+
+ @java.lang.Override
+ public com.google.protobuf.Parser<CreateFunctionRequest> getParserForType() {
+ return PARSER;
+ }
+
+ private int bitField0_;
+ // repeated bytes tableMetadataMutations = 1;
+ public static final int TABLEMETADATAMUTATIONS_FIELD_NUMBER = 1;
+ private java.util.List<com.google.protobuf.ByteString> tableMetadataMutations_;
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public java.util.List<com.google.protobuf.ByteString>
+ getTableMetadataMutationsList() {
+ return tableMetadataMutations_;
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public int getTableMetadataMutationsCount() {
+ return tableMetadataMutations_.size();
+ }
+ /**
+ * <code>repeated bytes tableMetadataMutations = 1;</code>
+ */
+ public com.google.protobuf.ByteString getTableMetadataMutations(int index) {
+ return tableMetadataMutations_.get(index);
+ }
+
+ // required bool temporary = 2;
+ public static final int TEMPORARY_FIELD_NUMBER = 2;
+ private boolean temporary_;
+ /**
+ * <code>required bool temporary = 2;</code>
+ */
+ public boolean hasTemporary() {
+ return ((bitField0_ & 0x00000001) == 0x00000001);
+ }
+ /**
+ * <code>required bool temporary = 2;</code>
+ */
+ public boolean getTemporary() {
+ return temporary_;
+ }
+
+ // optional bool replace = 3;
+ public static final int REPLACE_FIELD_NUMBER = 3;
+ private boolean replace_;
+ /**
+ * <code>optional bool replace = 3;</code>
+ */
+ public boolean hasReplace() {
+ return ((bitField0_ & 0x00000002) == 0x00000002);
+ }
+ /**
+ * <code>optional bool replace = 3;</code>
+ */
+ public boolean getReplace() {
+ return replace_;
+ }
+
+ // optional int32 clientVersion = 4;
+ public static final int CLIENTVERSION_FIELD_NUMBER = 4;
+ private int clientVersion_;
+ /**
+ * <code>optional int32 clientVersion = 4;</code>
+ */
+ public boolean hasClientVersion() {
+ return ((bitField0_ & 0x00000004) == 0x00000004);
+ }
+ /**
+ * <code>optional int32 clientVersion = 4;</code>
+ */
+ public int getClientVersion() {
+ return clientVersion_;
+ }
+
+ private void initFields() {
+ tableMetadataMutations_ = java.util.Collections.emptyList();
+ temporary_ = false;
+ replace_ = false;
+ clientVersion_ = 0;
+ }
+ private byte memoizedIsInitialized = -1;
+ public final boolean isInitialized() {
+ byte isInitialized = memoizedIsInitialized;
+ if (isInitialized != -1) return isInitialized == 1;
+
+ if (!hasTemporary()) {
+ memoizedIsInitialized = 0;
+ return false;
+ }
+ memoizedIsInitialized = 1;
+ return true;
+ }
+
+ public void writeTo(com.google.protobuf.CodedOutputStream output)
+ throws java.io.IOException {
+ getSerializedSize();
+ for (int i = 0; i < tableMetadataMutations_.size(); i++) {
+ output.writeBytes(1, tableMetadataMutations_.get(i));
+ }
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ output.writeBool(2, temporary_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ output.writeBool(3, replace_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ output.writeInt32(4, clientVersion_);
+ }
+ getUnknownFields().writeTo(output);
+ }
+
+ private int memoizedSerializedSize = -1;
+ public int getSerializedSize() {
+ int size = memoizedSerializedSize;
+ if (size != -1) return size;
+
+ size = 0;
+ {
+ int dataSize = 0;
+ for (int i = 0; i < tableMetadataMutations_.size(); i++) {
+ dataSize += com.google.protobuf.CodedOutputStream
+ .computeBytesSizeNoTag(tableMetadataMutations_.get(i));
+ }
+ size += dataSize;
+ size += 1 * getTableMetadataMutationsList().size();
+ }
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBoolSize(2, temporary_);
+ }
+ if (((bitField0_ & 0x00000002) == 0x00000002)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeBoolSize(3, replace_);
+ }
+ if (((bitField0_ & 0x00000004) == 0x00000004)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt32Size(4, clientVersion_);
+ }
+ size += getUnknownFields().getSerializedSize();
+ memoizedSerializedSize = size;
+ return size;
+ }
+
+ private static final long serialVersionUID = 0L;
+ @java.lang.Override
+ protected java.lang.Object writeReplace()
+ throws java.io.ObjectStreamException {
+ return super.writeReplace();
+ }
+
+ @java.lang.Override
+ public boolean equals(final java.lang.Object obj) {
+ if (obj == this) {
+ return true;
+ }
+ if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest)) {
+ return super.equals(obj);
+ }
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest) obj;
+
+ boolean result = true;
+ result = result && getTableMetadataMutationsList()
+ .equals(other.getTableMetadataMutationsList());
+ result = result && (hasTemporary() == other.hasTemporary());
+ if (hasTemporary()) {
+ result = result && (getTemporary()
+ == other.getTemporary());
+ }
+ result = result && (hasReplace() == other.hasReplace());
+ if (hasReplace()) {
+ result = result && (getReplace()
+ == other.getReplace());
+ }
+ result = result && (hasClientVersion() == other.hasClientVersion());
+ if (hasClientVersion()) {
+ result = result && (getClientVersion()
+ == other.getClientVersion());
+ }
+ result = result &&
+ getUnknownFields().equals(other.getUnknownFields());
+ return result;
+ }
+
+ private int memoizedHashCode = 0;
+ @java.lang.Override
+ public int hashCode() {
+ if (memoizedHashCode != 0) {
+ return memoizedHashCode;
+ }
+ int hash = 41;
+ hash = (19 * hash) + getDescriptorForType().hashCode();
+ if (getTableMetadataMutationsCount() > 0) {
+ hash = (37 * hash) + TABLEMETADATAMUTATIONS_FIELD_NUMBER;
+ hash = (53 * hash) + getTableMetadataMutationsList().hashCode();
+ }
+ if (hasTemporary()) {
+ hash = (37 * hash) + TEMPORARY_FIELD_NUMBER;
+ hash = (53 * hash) + hashBoolean(getTemporary());
+ }
+ if (hasReplace()) {
+ hash = (37 * hash) + REPLACE_FIELD_NUMBER;
+ hash = (53 * hash) + hashBoolean(getReplace());
+ }
+ if (hasClientVersion()) {
+ hash = (37 * hash) + CLIENTVERSION_FIELD_NUMBER;
+ hash = (53 * hash) + getClientVersion();
+ }
+ hash = (29 * hash) + getUnknownFields().hashCode();
+ memoizedHashCode = hash;
+ return hash;
+ }
+
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ com.google.protobuf.ByteString data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ com.google.protobuf.ByteString data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(byte[] data)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ byte[] data,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws com.google.protobuf.InvalidProtocolBufferException {
+ return PARSER.parseFrom(data, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseDelimitedFrom(java.io.InputStream input)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseDelimitedFrom(
+ java.io.InputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseDelimitedFrom(input, extensionRegistry);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ com.google.protobuf.CodedInputStream input)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input);
+ }
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest parseFrom(
+ com.google.protobuf.CodedInputStream input,
+ com.google.protobuf.ExtensionRegistryLite extensionRegistry)
+ throws java.io.IOException {
+ return PARSER.parseFrom(input, extensionRegistry);
+ }
+
+ public static Builder newBuilder() { return Builder.create(); }
+ public Builder newBuilderForType() { return newBuilder(); }
+ public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest prototype) {
+ return newBuilder().mergeFrom(prototype);
+ }
+ public Builder toBuilder() { return newBuilder(this); }
+
+ @java.lang.Override
+ protected Builder newBuilderForType(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ Builder builder = new Builder(parent);
+ return builder;
+ }
+ /**
+ * Protobuf type {@code CreateFunctionRequest}
+ *
+ * <pre>
+ * each byte array represents a MutationProto instance
+ * </pre>
+ */
+ public static final class Builder extends
+ com.google.protobuf.GeneratedMessage.Builder<Builder>
+ implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequestOrBuilder {
+ public static final com.google.protobuf.Descriptors.Descriptor
+ getDescriptor() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateFunctionRequest_descriptor;
+ }
+
+ protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
+ internalGetFieldAccessorTable() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateFunctionRequest_fieldAccessorTable
+ .ensureFieldAccessorsInitialized(
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.Builder.class);
+ }
+
+ // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.newBuilder()
+ private Builder() {
+ maybeForceBuilderInitialization();
+ }
+
+ private Builder(
+ com.google.protobuf.GeneratedMessage.BuilderParent parent) {
+ super(parent);
+ maybeForceBuilderInitialization();
+ }
+ private void maybeForceBuilderInitialization() {
+ if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) {
+ }
+ }
+ private static Builder create() {
+ return new Builder();
+ }
+
+ public Builder clear() {
+ super.clear();
+ tableMetadataMutations_ = java.util.Collections.emptyList();
+ bitField0_ = (bitField0_ & ~0x00000001);
+ temporary_ = false;
+ bitField0_ = (bitField0_ & ~0x00000002);
+ replace_ = false;
+ bitField0_ = (bitField0_ & ~0x00000004);
+ clientVersion_ = 0;
+ bitField0_ = (bitField0_ & ~0x00000008);
+ return this;
+ }
+
+ public Builder clone() {
+ return create().mergeFrom(buildPartial());
+ }
+
+ public com.google.protobuf.Descriptors.Descriptor
+ getDescriptorForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_CreateFunctionRequest_descriptor;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest getDefaultInstanceForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.getDefaultInstance();
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest build() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest result = buildPartial();
+ if (!result.isInitialized()) {
+ throw newUninitializedMessageException(result);
+ }
+ return result;
+ }
+
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest buildPartial() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest(this);
+ int from_bitField0_ = bitField0_;
+ int to_bitField0_ = 0;
+ if (((bitField0_ & 0x00000001) == 0x00000001)) {
+ tableMetadataMutations_ = java.util.Collections.unmodifiableList(tableMetadataMutations_);
+ bitField0_ = (bitField0_ & ~0x00000001);
+ }
+ result.tableMetadataMutations_ = tableMetadataMutations_;
+ if (((from_bitField0_ & 0x00000002) == 0x00000002)) {
+ to_bitField0_ |= 0x00000001;
+ }
+ result.temporary_ = temporary_;
+ if (((from_bitField0_ & 0x00000004) == 0x00000004)) {
+ to_bitField0_ |= 0x00000002;
+ }
+ result.replace_ = replace_;
+ if (((from_bitField0_ & 0x00000008) == 0x00000008)) {
+ to_bitField0_ |= 0x00000004;
+ }
+ result.clientVersion_ = clientVersion_;
+ result.bitField0_ = to_bitField0_;
+ onBuilt();
+ return result;
+ }
+
+ public Builder mergeFrom(com.google.protobuf.Message other) {
+ if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest) {
+ return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest)other);
+ } else {
+ super.mergeFrom(other);
+ return this;
+ }
+ }
+
+ public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest other) {
+ if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateFunctionRequest.getDefaultInstance()) return this;
+ if (!other.tableMetadataMutations_.isEmpty()) {
+ if (tableMetadataMutations_.isEmpty()) {
+ tableMetadataMutations_ = other.tableMetadataMutations_;
+ bitField0_ = (bitField0_ & ~0x00000001);
+ } else {
+
<TRUNCATED>