diff --git a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java index f6968bc..87c9e23 100644 --- a/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java +++ b/hbase-client/src/test/java/org/apache/hadoop/hbase/client/TestClientNoCluster.java @@ -528,6 +528,16 @@ public class TestClientNoCluster extends Configured implements Tool { } @Override + public ClientProtos.PingResponse ping(RpcController controller, + ClientProtos.PingRequest request) + throws ServiceException { + PingResponse.Builder pingResponse = PingResponse.newBuilder(); + pingResponse.setProcessed(true); + return pingResponse.build(); + } + + + @Override public CoprocessorServiceResponse execRegionServerService(RpcController controller, CoprocessorServiceRequest request) throws ServiceException { throw new NotImplementedException(); diff --git a/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ClientProtos.java b/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ClientProtos.java index 3f7ba80..065d698 100644 --- a/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ClientProtos.java +++ b/hbase-protocol/src/main/java/org/apache/hadoop/hbase/protobuf/generated/ClientProtos.java @@ -13976,6 +13976,874 @@ public final class ClientProtos { // @@protoc_insertion_point(class_scope:MutateResponse) } + public interface PingRequestOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // optional bool processed = 1; + /** + * optional bool processed = 1; + */ + boolean hasProcessed(); + /** + * optional bool processed = 1; + */ + boolean getProcessed(); + } + /** + * Protobuf type {@code PingRequest} + */ + public static final class PingRequest extends + com.google.protobuf.GeneratedMessage + implements PingRequestOrBuilder { + // Use PingRequest.newBuilder() to construct. + private PingRequest(com.google.protobuf.GeneratedMessage.Builder builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private PingRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final PingRequest defaultInstance; + public static PingRequest getDefaultInstance() { + return defaultInstance; + } + + public PingRequest getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private PingRequest( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 8: { + bitField0_ |= 0x00000001; + processed_ = input.readBool(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.class, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.Builder.class); + } + + public static com.google.protobuf.Parser PARSER = + new com.google.protobuf.AbstractParser() { + public PingRequest parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new PingRequest(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + private int bitField0_; + // optional bool processed = 1; + public static final int PROCESSED_FIELD_NUMBER = 1; + private boolean processed_; + /** + * optional bool processed = 1; + */ + public boolean hasProcessed() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * optional bool processed = 1; + */ + public boolean getProcessed() { + return processed_; + } + + private void initFields() { + processed_ = false; + } + 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(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBool(1, processed_); + } + 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 + .computeBoolSize(1, processed_); + } + 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.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest)) { + return super.equals(obj); + } + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest other = (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest) obj; + + boolean result = true; + result = result && (hasProcessed() == other.hasProcessed()); + if (hasProcessed()) { + result = result && (getProcessed() + == other.getProcessed()); + } + 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 (hasProcessed()) { + hash = (37 * hash) + PROCESSED_FIELD_NUMBER; + hash = (53 * hash) + hashBoolean(getProcessed()); + } + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest 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.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest 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.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest 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 PingRequest} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder + implements org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequestOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingRequest_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingRequest_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.class, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.Builder.class); + } + + // Construct using org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.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(); + processed_ = false; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingRequest_descriptor; + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest getDefaultInstanceForType() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.getDefaultInstance(); + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest build() { + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest buildPartial() { + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest result = new org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.processed_ = processed_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest) { + return mergeFrom((org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest other) { + if (other == org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.getDefaultInstance()) return this; + if (other.hasProcessed()) { + setProcessed(other.getProcessed()); + } + 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.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // optional bool processed = 1; + private boolean processed_ ; + /** + * optional bool processed = 1; + */ + public boolean hasProcessed() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * optional bool processed = 1; + */ + public boolean getProcessed() { + return processed_; + } + /** + * optional bool processed = 1; + */ + public Builder setProcessed(boolean value) { + bitField0_ |= 0x00000001; + processed_ = value; + onChanged(); + return this; + } + /** + * optional bool processed = 1; + */ + public Builder clearProcessed() { + bitField0_ = (bitField0_ & ~0x00000001); + processed_ = false; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:PingRequest) + } + + static { + defaultInstance = new PingRequest(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:PingRequest) + } + + public interface PingResponseOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // optional bool processed = 1; + /** + * optional bool processed = 1; + */ + boolean hasProcessed(); + /** + * optional bool processed = 1; + */ + boolean getProcessed(); + } + /** + * Protobuf type {@code PingResponse} + */ + public static final class PingResponse extends + com.google.protobuf.GeneratedMessage + implements PingResponseOrBuilder { + // Use PingResponse.newBuilder() to construct. + private PingResponse(com.google.protobuf.GeneratedMessage.Builder builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private PingResponse(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final PingResponse defaultInstance; + public static PingResponse getDefaultInstance() { + return defaultInstance; + } + + public PingResponse getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private PingResponse( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 8: { + bitField0_ |= 0x00000001; + processed_ = input.readBool(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingResponse_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.class, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.Builder.class); + } + + public static com.google.protobuf.Parser PARSER = + new com.google.protobuf.AbstractParser() { + public PingResponse parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new PingResponse(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser getParserForType() { + return PARSER; + } + + private int bitField0_; + // optional bool processed = 1; + public static final int PROCESSED_FIELD_NUMBER = 1; + private boolean processed_; + /** + * optional bool processed = 1; + */ + public boolean hasProcessed() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * optional bool processed = 1; + */ + public boolean getProcessed() { + return processed_; + } + + private void initFields() { + processed_ = false; + } + 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(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBool(1, processed_); + } + 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 + .computeBoolSize(1, processed_); + } + 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.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse)) { + return super.equals(obj); + } + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse other = (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse) obj; + + boolean result = true; + result = result && (hasProcessed() == other.hasProcessed()); + if (hasProcessed()) { + result = result && (getProcessed() + == other.getProcessed()); + } + 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 (hasProcessed()) { + hash = (37 * hash) + PROCESSED_FIELD_NUMBER; + hash = (53 * hash) + hashBoolean(getProcessed()); + } + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse 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.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse 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.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse 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 PingResponse} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder + implements org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponseOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingResponse_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingResponse_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.class, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.Builder.class); + } + + // Construct using org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.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(); + processed_ = false; + bitField0_ = (bitField0_ & ~0x00000001); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.internal_static_PingResponse_descriptor; + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse getDefaultInstanceForType() { + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance(); + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse build() { + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse buildPartial() { + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse result = new org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.processed_ = processed_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse) { + return mergeFrom((org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse other) { + if (other == org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance()) return this; + if (other.hasProcessed()) { + setProcessed(other.getProcessed()); + } + 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.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // optional bool processed = 1; + private boolean processed_ ; + /** + * optional bool processed = 1; + */ + public boolean hasProcessed() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * optional bool processed = 1; + */ + public boolean getProcessed() { + return processed_; + } + /** + * optional bool processed = 1; + */ + public Builder setProcessed(boolean value) { + bitField0_ |= 0x00000001; + processed_ = value; + onChanged(); + return this; + } + /** + * optional bool processed = 1; + */ + public Builder clearProcessed() { + bitField0_ = (bitField0_ & ~0x00000001); + processed_ = false; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:PingResponse) + } + + static { + defaultInstance = new PingResponse(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:PingResponse) + } + public interface ScanOrBuilder extends com.google.protobuf.MessageOrBuilder { @@ -33557,6 +34425,14 @@ public final class ClientProtos { org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest request, com.google.protobuf.RpcCallback done); + /** + * rpc Ping(.PingRequest) returns (.PingResponse); + */ + public abstract void ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request, + com.google.protobuf.RpcCallback done); + } public static com.google.protobuf.Service newReflectiveService( @@ -33618,6 +34494,14 @@ public final class ClientProtos { impl.multi(controller, request, done); } + @java.lang.Override + public void ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request, + com.google.protobuf.RpcCallback done) { + impl.ping(controller, request, done); + } + }; } @@ -33654,6 +34538,8 @@ public final class ClientProtos { return impl.execRegionServerService(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceRequest)request); case 6: return impl.multi(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest)request); + case 7: + return impl.ping(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest)request); default: throw new java.lang.AssertionError("Can't get here."); } @@ -33682,6 +34568,8 @@ public final class ClientProtos { return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceRequest.getDefaultInstance(); case 6: return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest.getDefaultInstance(); + case 7: + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -33710,6 +34598,8 @@ public final class ClientProtos { return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceResponse.getDefaultInstance(); case 6: return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiResponse.getDefaultInstance(); + case 7: + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -33774,6 +34664,14 @@ public final class ClientProtos { org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest request, com.google.protobuf.RpcCallback done); + /** + * rpc Ping(.PingRequest) returns (.PingResponse); + */ + public abstract void ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request, + com.google.protobuf.RpcCallback done); + public static final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptor() { @@ -33831,6 +34729,11 @@ public final class ClientProtos { com.google.protobuf.RpcUtil.specializeCallback( done)); return; + case 7: + this.ping(controller, (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest)request, + com.google.protobuf.RpcUtil.specializeCallback( + done)); + return; default: throw new java.lang.AssertionError("Can't get here."); } @@ -33859,6 +34762,8 @@ public final class ClientProtos { return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceRequest.getDefaultInstance(); case 6: return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest.getDefaultInstance(); + case 7: + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -33887,6 +34792,8 @@ public final class ClientProtos { return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceResponse.getDefaultInstance(); case 6: return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiResponse.getDefaultInstance(); + case 7: + return org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -34012,6 +34919,21 @@ public final class ClientProtos { org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiResponse.class, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiResponse.getDefaultInstance())); } + + public void ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request, + com.google.protobuf.RpcCallback done) { + channel.callMethod( + getDescriptor().getMethods().get(7), + controller, + request, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance(), + com.google.protobuf.RpcUtil.generalizeCallback( + done, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.class, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance())); + } } public static BlockingInterface newBlockingStub( @@ -34054,6 +34976,11 @@ public final class ClientProtos { com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest request) throws com.google.protobuf.ServiceException; + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request) + throws com.google.protobuf.ServiceException; } private static final class BlockingStub implements BlockingInterface { @@ -34146,6 +35073,18 @@ public final class ClientProtos { org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiResponse.getDefaultInstance()); } + + public org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse ping( + com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingRequest request) + throws com.google.protobuf.ServiceException { + return (org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse) channel.callBlockingMethod( + getDescriptor().getMethods().get(7), + controller, + request, + org.apache.hadoop.hbase.protobuf.generated.ClientProtos.PingResponse.getDefaultInstance()); + } + } // @@protoc_insertion_point(class_scope:ClientService) @@ -34217,6 +35156,16 @@ public final class ClientProtos { com.google.protobuf.GeneratedMessage.FieldAccessorTable internal_static_MutateResponse_fieldAccessorTable; private static com.google.protobuf.Descriptors.Descriptor + internal_static_PingRequest_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_PingRequest_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_PingResponse_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_PingResponse_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor internal_static_Scan_descriptor; private static com.google.protobuf.GeneratedMessage.FieldAccessorTable @@ -34359,81 +35308,83 @@ public final class ClientProtos { "tion\030\002 \002(\0132\016.MutationProto\022\035\n\tcondition\030" + "\003 \001(\0132\n.Condition\022\023\n\013nonce_group\030\004 \001(\004\"<" + "\n\016MutateResponse\022\027\n\006result\030\001 \001(\0132\007.Resul" + - "t\022\021\n\tprocessed\030\002 \001(\010\"\207\004\n\004Scan\022\027\n\006column\030", - "\001 \003(\0132\007.Column\022!\n\tattribute\030\002 \003(\0132\016.Name" + - "BytesPair\022\021\n\tstart_row\030\003 \001(\014\022\020\n\010stop_row" + - "\030\004 \001(\014\022\027\n\006filter\030\005 \001(\0132\007.Filter\022\036\n\ntime_" + - "range\030\006 \001(\0132\n.TimeRange\022\027\n\014max_versions\030" + - "\007 \001(\r:\0011\022\032\n\014cache_blocks\030\010 \001(\010:\004true\022\022\n\n" + - "batch_size\030\t \001(\r\022\027\n\017max_result_size\030\n \001(" + - "\004\022\023\n\013store_limit\030\013 \001(\r\022\024\n\014store_offset\030\014" + - " \001(\r\022&\n\036load_column_families_on_demand\030\r" + - " \001(\010\022\r\n\005small\030\016 \001(\010\022\027\n\010reversed\030\017 \001(\010:\005f" + - "alse\022)\n\013consistency\030\020 \001(\0162\014.Consistency:", - "\006STRONG\022\017\n\007caching\030\021 \001(\r\022\035\n\025allow_partia" + - "l_results\030\022 \001(\010\022-\n\rcf_time_range\030\023 \003(\0132\026" + - ".ColumnFamilyTimeRange\"\224\002\n\013ScanRequest\022 " + - "\n\006region\030\001 \001(\0132\020.RegionSpecifier\022\023\n\004scan" + - "\030\002 \001(\0132\005.Scan\022\022\n\nscanner_id\030\003 \001(\004\022\026\n\016num" + - "ber_of_rows\030\004 \001(\r\022\025\n\rclose_scanner\030\005 \001(\010" + - "\022\025\n\rnext_call_seq\030\006 \001(\004\022\037\n\027client_handle" + - "s_partials\030\007 \001(\010\022!\n\031client_handles_heart" + - "beats\030\010 \001(\010\022\032\n\022track_scan_metrics\030\t \001(\010\022" + - "\024\n\005renew\030\n \001(\010:\005false\"\210\002\n\014ScanResponse\022\030", - "\n\020cells_per_result\030\001 \003(\r\022\022\n\nscanner_id\030\002" + - " \001(\004\022\024\n\014more_results\030\003 \001(\010\022\013\n\003ttl\030\004 \001(\r\022" + - "\030\n\007results\030\005 \003(\0132\007.Result\022\r\n\005stale\030\006 \001(\010" + - "\022\037\n\027partial_flag_per_result\030\007 \003(\010\022\036\n\026mor" + - "e_results_in_region\030\010 \001(\010\022\031\n\021heartbeat_m" + - "essage\030\t \001(\010\022\"\n\014scan_metrics\030\n \001(\0132\014.Sca" + - "nMetrics\"\263\001\n\024BulkLoadHFileRequest\022 \n\006reg" + - "ion\030\001 \002(\0132\020.RegionSpecifier\0225\n\013family_pa" + - "th\030\002 \003(\0132 .BulkLoadHFileRequest.FamilyPa" + - "th\022\026\n\016assign_seq_num\030\003 \001(\010\032*\n\nFamilyPath", - "\022\016\n\006family\030\001 \002(\014\022\014\n\004path\030\002 \002(\t\"\'\n\025BulkLo" + - "adHFileResponse\022\016\n\006loaded\030\001 \002(\010\"a\n\026Copro" + - "cessorServiceCall\022\013\n\003row\030\001 \002(\014\022\024\n\014servic" + - "e_name\030\002 \002(\t\022\023\n\013method_name\030\003 \002(\t\022\017\n\007req" + - "uest\030\004 \002(\014\"9\n\030CoprocessorServiceResult\022\035" + - "\n\005value\030\001 \001(\0132\016.NameBytesPair\"d\n\031Coproce" + - "ssorServiceRequest\022 \n\006region\030\001 \002(\0132\020.Reg" + - "ionSpecifier\022%\n\004call\030\002 \002(\0132\027.Coprocessor" + - "ServiceCall\"]\n\032CoprocessorServiceRespons" + - "e\022 \n\006region\030\001 \002(\0132\020.RegionSpecifier\022\035\n\005v", - "alue\030\002 \002(\0132\016.NameBytesPair\"{\n\006Action\022\r\n\005" + - "index\030\001 \001(\r\022 \n\010mutation\030\002 \001(\0132\016.Mutation" + - "Proto\022\021\n\003get\030\003 \001(\0132\004.Get\022-\n\014service_call" + - "\030\004 \001(\0132\027.CoprocessorServiceCall\"Y\n\014Regio" + - "nAction\022 \n\006region\030\001 \002(\0132\020.RegionSpecifie" + - "r\022\016\n\006atomic\030\002 \001(\010\022\027\n\006action\030\003 \003(\0132\007.Acti" + - "on\"c\n\017RegionLoadStats\022\027\n\014memstoreLoad\030\001 " + - "\001(\005:\0010\022\030\n\rheapOccupancy\030\002 \001(\005:\0010\022\035\n\022comp" + - "actionPressure\030\003 \001(\005:\0010\"\266\001\n\021ResultOrExce" + - "ption\022\r\n\005index\030\001 \001(\r\022\027\n\006result\030\002 \001(\0132\007.R", - "esult\022!\n\texception\030\003 \001(\0132\016.NameBytesPair" + - "\0221\n\016service_result\030\004 \001(\0132\031.CoprocessorSe" + - "rviceResult\022#\n\tloadStats\030\005 \001(\0132\020.RegionL" + - "oadStats\"f\n\022RegionActionResult\022-\n\021result" + - "OrException\030\001 \003(\0132\022.ResultOrException\022!\n" + - "\texception\030\002 \001(\0132\016.NameBytesPair\"f\n\014Mult" + - "iRequest\022#\n\014regionAction\030\001 \003(\0132\r.RegionA" + - "ction\022\022\n\nnonceGroup\030\002 \001(\004\022\035\n\tcondition\030\003" + - " \001(\0132\n.Condition\"S\n\rMultiResponse\022/\n\022reg" + - "ionActionResult\030\001 \003(\0132\023.RegionActionResu", - "lt\022\021\n\tprocessed\030\002 \001(\010*\'\n\013Consistency\022\n\n\006" + - "STRONG\020\000\022\014\n\010TIMELINE\020\0012\205\003\n\rClientService" + - "\022 \n\003Get\022\013.GetRequest\032\014.GetResponse\022)\n\006Mu" + - "tate\022\016.MutateRequest\032\017.MutateResponse\022#\n" + - "\004Scan\022\014.ScanRequest\032\r.ScanResponse\022>\n\rBu" + - "lkLoadHFile\022\025.BulkLoadHFileRequest\032\026.Bul" + - "kLoadHFileResponse\022F\n\013ExecService\022\032.Copr" + - "ocessorServiceRequest\032\033.CoprocessorServi" + - "ceResponse\022R\n\027ExecRegionServerService\022\032." + - "CoprocessorServiceRequest\032\033.CoprocessorS", - "erviceResponse\022&\n\005Multi\022\r.MultiRequest\032\016" + - ".MultiResponseBB\n*org.apache.hadoop.hbas" + - "e.protobuf.generatedB\014ClientProtosH\001\210\001\001\240" + - "\001\001" + "t\022\021\n\tprocessed\030\002 \001(\010\" \n\013PingRequest\022\021\n\tp", + "rocessed\030\001 \001(\010\"!\n\014PingResponse\022\021\n\tproces" + + "sed\030\001 \001(\010\"\207\004\n\004Scan\022\027\n\006column\030\001 \003(\0132\007.Col" + + "umn\022!\n\tattribute\030\002 \003(\0132\016.NameBytesPair\022\021" + + "\n\tstart_row\030\003 \001(\014\022\020\n\010stop_row\030\004 \001(\014\022\027\n\006f" + + "ilter\030\005 \001(\0132\007.Filter\022\036\n\ntime_range\030\006 \001(\013" + + "2\n.TimeRange\022\027\n\014max_versions\030\007 \001(\r:\0011\022\032\n" + + "\014cache_blocks\030\010 \001(\010:\004true\022\022\n\nbatch_size\030" + + "\t \001(\r\022\027\n\017max_result_size\030\n \001(\004\022\023\n\013store_" + + "limit\030\013 \001(\r\022\024\n\014store_offset\030\014 \001(\r\022&\n\036loa" + + "d_column_families_on_demand\030\r \001(\010\022\r\n\005sma", + "ll\030\016 \001(\010\022\027\n\010reversed\030\017 \001(\010:\005false\022)\n\013con" + + "sistency\030\020 \001(\0162\014.Consistency:\006STRONG\022\017\n\007" + + "caching\030\021 \001(\r\022\035\n\025allow_partial_results\030\022" + + " \001(\010\022-\n\rcf_time_range\030\023 \003(\0132\026.ColumnFami" + + "lyTimeRange\"\224\002\n\013ScanRequest\022 \n\006region\030\001 " + + "\001(\0132\020.RegionSpecifier\022\023\n\004scan\030\002 \001(\0132\005.Sc" + + "an\022\022\n\nscanner_id\030\003 \001(\004\022\026\n\016number_of_rows" + + "\030\004 \001(\r\022\025\n\rclose_scanner\030\005 \001(\010\022\025\n\rnext_ca" + + "ll_seq\030\006 \001(\004\022\037\n\027client_handles_partials\030" + + "\007 \001(\010\022!\n\031client_handles_heartbeats\030\010 \001(\010", + "\022\032\n\022track_scan_metrics\030\t \001(\010\022\024\n\005renew\030\n " + + "\001(\010:\005false\"\210\002\n\014ScanResponse\022\030\n\020cells_per" + + "_result\030\001 \003(\r\022\022\n\nscanner_id\030\002 \001(\004\022\024\n\014mor" + + "e_results\030\003 \001(\010\022\013\n\003ttl\030\004 \001(\r\022\030\n\007results\030" + + "\005 \003(\0132\007.Result\022\r\n\005stale\030\006 \001(\010\022\037\n\027partial" + + "_flag_per_result\030\007 \003(\010\022\036\n\026more_results_i" + + "n_region\030\010 \001(\010\022\031\n\021heartbeat_message\030\t \001(" + + "\010\022\"\n\014scan_metrics\030\n \001(\0132\014.ScanMetrics\"\263\001" + + "\n\024BulkLoadHFileRequest\022 \n\006region\030\001 \002(\0132\020" + + ".RegionSpecifier\0225\n\013family_path\030\002 \003(\0132 .", + "BulkLoadHFileRequest.FamilyPath\022\026\n\016assig" + + "n_seq_num\030\003 \001(\010\032*\n\nFamilyPath\022\016\n\006family\030" + + "\001 \002(\014\022\014\n\004path\030\002 \002(\t\"\'\n\025BulkLoadHFileResp" + + "onse\022\016\n\006loaded\030\001 \002(\010\"a\n\026CoprocessorServi" + + "ceCall\022\013\n\003row\030\001 \002(\014\022\024\n\014service_name\030\002 \002(" + + "\t\022\023\n\013method_name\030\003 \002(\t\022\017\n\007request\030\004 \002(\014\"" + + "9\n\030CoprocessorServiceResult\022\035\n\005value\030\001 \001" + + "(\0132\016.NameBytesPair\"d\n\031CoprocessorService" + + "Request\022 \n\006region\030\001 \002(\0132\020.RegionSpecifie" + + "r\022%\n\004call\030\002 \002(\0132\027.CoprocessorServiceCall", + "\"]\n\032CoprocessorServiceResponse\022 \n\006region" + + "\030\001 \002(\0132\020.RegionSpecifier\022\035\n\005value\030\002 \002(\0132" + + "\016.NameBytesPair\"{\n\006Action\022\r\n\005index\030\001 \001(\r" + + "\022 \n\010mutation\030\002 \001(\0132\016.MutationProto\022\021\n\003ge" + + "t\030\003 \001(\0132\004.Get\022-\n\014service_call\030\004 \001(\0132\027.Co" + + "processorServiceCall\"Y\n\014RegionAction\022 \n\006" + + "region\030\001 \002(\0132\020.RegionSpecifier\022\016\n\006atomic" + + "\030\002 \001(\010\022\027\n\006action\030\003 \003(\0132\007.Action\"c\n\017Regio" + + "nLoadStats\022\027\n\014memstoreLoad\030\001 \001(\005:\0010\022\030\n\rh" + + "eapOccupancy\030\002 \001(\005:\0010\022\035\n\022compactionPress", + "ure\030\003 \001(\005:\0010\"\266\001\n\021ResultOrException\022\r\n\005in" + + "dex\030\001 \001(\r\022\027\n\006result\030\002 \001(\0132\007.Result\022!\n\tex" + + "ception\030\003 \001(\0132\016.NameBytesPair\0221\n\016service" + + "_result\030\004 \001(\0132\031.CoprocessorServiceResult" + + "\022#\n\tloadStats\030\005 \001(\0132\020.RegionLoadStats\"f\n" + + "\022RegionActionResult\022-\n\021resultOrException" + + "\030\001 \003(\0132\022.ResultOrException\022!\n\texception\030" + + "\002 \001(\0132\016.NameBytesPair\"f\n\014MultiRequest\022#\n" + + "\014regionAction\030\001 \003(\0132\r.RegionAction\022\022\n\nno" + + "nceGroup\030\002 \001(\004\022\035\n\tcondition\030\003 \001(\0132\n.Cond", + "ition\"S\n\rMultiResponse\022/\n\022regionActionRe" + + "sult\030\001 \003(\0132\023.RegionActionResult\022\021\n\tproce" + + "ssed\030\002 \001(\010*\'\n\013Consistency\022\n\n\006STRONG\020\000\022\014\n" + + "\010TIMELINE\020\0012\252\003\n\rClientService\022 \n\003Get\022\013.G" + + "etRequest\032\014.GetResponse\022)\n\006Mutate\022\016.Muta" + + "teRequest\032\017.MutateResponse\022#\n\004Scan\022\014.Sca" + + "nRequest\032\r.ScanResponse\022>\n\rBulkLoadHFile" + + "\022\025.BulkLoadHFileRequest\032\026.BulkLoadHFileR" + + "esponse\022F\n\013ExecService\022\032.CoprocessorServ" + + "iceRequest\032\033.CoprocessorServiceResponse\022", + "R\n\027ExecRegionServerService\022\032.Coprocessor" + + "ServiceRequest\032\033.CoprocessorServiceRespo" + + "nse\022&\n\005Multi\022\r.MultiRequest\032\016.MultiRespo" + + "nse\022#\n\004Ping\022\014.PingRequest\032\r.PingResponse" + + "BB\n*org.apache.hadoop.hbase.protobuf.gen" + + "eratedB\014ClientProtosH\001\210\001\001\240\001\001" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -34518,26 +35469,38 @@ public final class ClientProtos { com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_MutateResponse_descriptor, new java.lang.String[] { "Result", "Processed", }); - internal_static_Scan_descriptor = + internal_static_PingRequest_descriptor = getDescriptor().getMessageTypes().get(11); + internal_static_PingRequest_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_PingRequest_descriptor, + new java.lang.String[] { "Processed", }); + internal_static_PingResponse_descriptor = + getDescriptor().getMessageTypes().get(12); + internal_static_PingResponse_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_PingResponse_descriptor, + new java.lang.String[] { "Processed", }); + internal_static_Scan_descriptor = + getDescriptor().getMessageTypes().get(13); internal_static_Scan_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_Scan_descriptor, new java.lang.String[] { "Column", "Attribute", "StartRow", "StopRow", "Filter", "TimeRange", "MaxVersions", "CacheBlocks", "BatchSize", "MaxResultSize", "StoreLimit", "StoreOffset", "LoadColumnFamiliesOnDemand", "Small", "Reversed", "Consistency", "Caching", "AllowPartialResults", "CfTimeRange", }); internal_static_ScanRequest_descriptor = - getDescriptor().getMessageTypes().get(12); + getDescriptor().getMessageTypes().get(14); internal_static_ScanRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_ScanRequest_descriptor, new java.lang.String[] { "Region", "Scan", "ScannerId", "NumberOfRows", "CloseScanner", "NextCallSeq", "ClientHandlesPartials", "ClientHandlesHeartbeats", "TrackScanMetrics", "Renew", }); internal_static_ScanResponse_descriptor = - getDescriptor().getMessageTypes().get(13); + getDescriptor().getMessageTypes().get(15); internal_static_ScanResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_ScanResponse_descriptor, new java.lang.String[] { "CellsPerResult", "ScannerId", "MoreResults", "Ttl", "Results", "Stale", "PartialFlagPerResult", "MoreResultsInRegion", "HeartbeatMessage", "ScanMetrics", }); internal_static_BulkLoadHFileRequest_descriptor = - getDescriptor().getMessageTypes().get(14); + getDescriptor().getMessageTypes().get(16); internal_static_BulkLoadHFileRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_BulkLoadHFileRequest_descriptor, @@ -34549,73 +35512,73 @@ public final class ClientProtos { internal_static_BulkLoadHFileRequest_FamilyPath_descriptor, new java.lang.String[] { "Family", "Path", }); internal_static_BulkLoadHFileResponse_descriptor = - getDescriptor().getMessageTypes().get(15); + getDescriptor().getMessageTypes().get(17); internal_static_BulkLoadHFileResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_BulkLoadHFileResponse_descriptor, new java.lang.String[] { "Loaded", }); internal_static_CoprocessorServiceCall_descriptor = - getDescriptor().getMessageTypes().get(16); + getDescriptor().getMessageTypes().get(18); internal_static_CoprocessorServiceCall_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CoprocessorServiceCall_descriptor, new java.lang.String[] { "Row", "ServiceName", "MethodName", "Request", }); internal_static_CoprocessorServiceResult_descriptor = - getDescriptor().getMessageTypes().get(17); + getDescriptor().getMessageTypes().get(19); internal_static_CoprocessorServiceResult_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CoprocessorServiceResult_descriptor, new java.lang.String[] { "Value", }); internal_static_CoprocessorServiceRequest_descriptor = - getDescriptor().getMessageTypes().get(18); + getDescriptor().getMessageTypes().get(20); internal_static_CoprocessorServiceRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CoprocessorServiceRequest_descriptor, new java.lang.String[] { "Region", "Call", }); internal_static_CoprocessorServiceResponse_descriptor = - getDescriptor().getMessageTypes().get(19); + getDescriptor().getMessageTypes().get(21); internal_static_CoprocessorServiceResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CoprocessorServiceResponse_descriptor, new java.lang.String[] { "Region", "Value", }); internal_static_Action_descriptor = - getDescriptor().getMessageTypes().get(20); + getDescriptor().getMessageTypes().get(22); internal_static_Action_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_Action_descriptor, new java.lang.String[] { "Index", "Mutation", "Get", "ServiceCall", }); internal_static_RegionAction_descriptor = - getDescriptor().getMessageTypes().get(21); + getDescriptor().getMessageTypes().get(23); internal_static_RegionAction_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_RegionAction_descriptor, new java.lang.String[] { "Region", "Atomic", "Action", }); internal_static_RegionLoadStats_descriptor = - getDescriptor().getMessageTypes().get(22); + getDescriptor().getMessageTypes().get(24); internal_static_RegionLoadStats_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_RegionLoadStats_descriptor, new java.lang.String[] { "MemstoreLoad", "HeapOccupancy", "CompactionPressure", }); internal_static_ResultOrException_descriptor = - getDescriptor().getMessageTypes().get(23); + getDescriptor().getMessageTypes().get(25); internal_static_ResultOrException_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_ResultOrException_descriptor, new java.lang.String[] { "Index", "Result", "Exception", "ServiceResult", "LoadStats", }); internal_static_RegionActionResult_descriptor = - getDescriptor().getMessageTypes().get(24); + getDescriptor().getMessageTypes().get(26); internal_static_RegionActionResult_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_RegionActionResult_descriptor, new java.lang.String[] { "ResultOrException", "Exception", }); internal_static_MultiRequest_descriptor = - getDescriptor().getMessageTypes().get(25); + getDescriptor().getMessageTypes().get(27); internal_static_MultiRequest_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_MultiRequest_descriptor, new java.lang.String[] { "RegionAction", "NonceGroup", "Condition", }); internal_static_MultiResponse_descriptor = - getDescriptor().getMessageTypes().get(26); + getDescriptor().getMessageTypes().get(28); internal_static_MultiResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_MultiResponse_descriptor, diff --git a/hbase-protocol/src/main/protobuf/Client.proto b/hbase-protocol/src/main/protobuf/Client.proto index fcd93fd..0362eb2 100644 --- a/hbase-protocol/src/main/protobuf/Client.proto +++ b/hbase-protocol/src/main/protobuf/Client.proto @@ -229,6 +229,14 @@ message MutateResponse { optional bool processed = 2; } +message PingRequest { + optional bool processed = 1; +} + +message PingResponse { + optional bool processed = 1; +} + /** * Instead of get from a table, you can scan it with optional filters. * You can specify the row key range, time range, the columns/families @@ -473,4 +481,7 @@ service ClientService { rpc Multi(MultiRequest) returns(MultiResponse); + + rpc Ping(PingRequest) + returns(PingResponse); } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index f28e726..1dc64d5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -2744,6 +2744,14 @@ public class RSRpcServices implements HBaseRPCErrorHandler, } @Override + public PingResponse ping(RpcController controller, ClientProtos.PingRequest request) + throws ServiceException { + PingResponse.Builder pingResponse = PingResponse.newBuilder(); + pingResponse.setProcessed(true); + return pingResponse.build(); + } + + @Override public CoprocessorServiceResponse execRegionServerService(RpcController controller, CoprocessorServiceRequest request) throws ServiceException { return regionServer.execRegionServerService(controller, request); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/MockRegionServer.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/MockRegionServer.java index 8aa38d6..2c796fb 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/MockRegionServer.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/MockRegionServer.java @@ -439,6 +439,14 @@ ClientProtos.ClientService.BlockingInterface, RegionServerServices { } @Override + public ClientProtos.PingResponse ping(RpcController controller, ClientProtos.PingRequest request) + throws ServiceException { + PingResponse.Builder pingResponse = PingResponse.newBuilder(); + pingResponse.setProcessed(true); + return pingResponse.build(); + } + + @Override public GetRegionInfoResponse getRegionInfo(RpcController controller, GetRegionInfoRequest request) throws ServiceException { GetRegionInfoResponse.Builder builder = GetRegionInfoResponse.newBuilder();