You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ja...@apache.org on 2014/10/28 21:16:26 UTC
[1/2] git commit: Rename method in MetaDataService
Repository: phoenix
Updated Branches:
refs/heads/master f3ac84780 -> 172dd0698
Rename method in MetaDataService
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/c32c60e3
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c32c60e3
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c32c60e3
Branch: refs/heads/master
Commit: c32c60e37b283419970306d304f393f036fd86fd
Parents: f3ac847
Author: James Taylor <jt...@salesforce.com>
Authored: Tue Oct 28 13:01:47 2014 -0700
Committer: James Taylor <jt...@salesforce.com>
Committed: Tue Oct 28 13:03:01 2014 -0700
----------------------------------------------------------------------
.../coprocessor/MetaDataEndpointImpl.java | 8 +-
.../coprocessor/generated/MetaDataProtos.java | 351 +++++++++----------
.../query/ConnectionQueryServicesImpl.java | 14 +-
phoenix-protocol/src/main/MetaDataService.proto | 8 +-
4 files changed, 190 insertions(+), 191 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/c32c60e3/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
index ba4d8d9..0c1d1c8 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java
@@ -94,14 +94,14 @@ import org.apache.phoenix.coprocessor.generated.MetaDataProtos;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.AddColumnRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearCacheRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearCacheResponse;
+import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest;
+import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.DropColumnRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.DropTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse;
-import org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest;
-import org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.MetaDataResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.UpdateIndexStateRequest;
import org.apache.phoenix.hbase.index.util.GenericKeyValueBuilder;
@@ -1682,8 +1682,8 @@ public class MetaDataEndpointImpl extends MetaDataProtocol implements Coprocesso
}
@Override
- public void incrementTableTimeStamp(RpcController controller, IncrementTableTimeStampRequest request,
- RpcCallback<IncrementTableTimeStampResponse> done) {
+ public void clearTableFromCache(RpcController controller, ClearTableFromCacheRequest request,
+ RpcCallback<ClearTableFromCacheResponse> done) {
byte[] schemaName = request.getSchemaName().toByteArray();
byte[] tableName = request.getTableName().toByteArray();
try {
http://git-wip-us.apache.org/repos/asf/phoenix/blob/c32c60e3/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 8d153b2..f49a35e 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
@@ -6316,7 +6316,7 @@ public final class MetaDataProtos {
// @@protoc_insertion_point(class_scope:GetVersionResponse)
}
- public interface IncrementTableTimeStampRequestOrBuilder
+ public interface ClearTableFromCacheRequestOrBuilder
extends com.google.protobuf.MessageOrBuilder {
// required bytes tenantId = 1;
@@ -6360,24 +6360,24 @@ public final class MetaDataProtos {
long getClientTimestamp();
}
/**
- * Protobuf type {@code IncrementTableTimeStampRequest}
+ * Protobuf type {@code ClearTableFromCacheRequest}
*/
- public static final class IncrementTableTimeStampRequest extends
+ public static final class ClearTableFromCacheRequest extends
com.google.protobuf.GeneratedMessage
- implements IncrementTableTimeStampRequestOrBuilder {
- // Use IncrementTableTimeStampRequest.newBuilder() to construct.
- private IncrementTableTimeStampRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ implements ClearTableFromCacheRequestOrBuilder {
+ // Use ClearTableFromCacheRequest.newBuilder() to construct.
+ private ClearTableFromCacheRequest(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
super(builder);
this.unknownFields = builder.getUnknownFields();
}
- private IncrementTableTimeStampRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+ private ClearTableFromCacheRequest(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
- private static final IncrementTableTimeStampRequest defaultInstance;
- public static IncrementTableTimeStampRequest getDefaultInstance() {
+ private static final ClearTableFromCacheRequest defaultInstance;
+ public static ClearTableFromCacheRequest getDefaultInstance() {
return defaultInstance;
}
- public IncrementTableTimeStampRequest getDefaultInstanceForType() {
+ public ClearTableFromCacheRequest getDefaultInstanceForType() {
return defaultInstance;
}
@@ -6387,7 +6387,7 @@ public final class MetaDataProtos {
getUnknownFields() {
return this.unknownFields;
}
- private IncrementTableTimeStampRequest(
+ private ClearTableFromCacheRequest(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
@@ -6444,28 +6444,28 @@ public final class MetaDataProtos {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampRequest_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampRequest_fieldAccessorTable
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheRequest_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.Builder.class);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.Builder.class);
}
- public static com.google.protobuf.Parser<IncrementTableTimeStampRequest> PARSER =
- new com.google.protobuf.AbstractParser<IncrementTableTimeStampRequest>() {
- public IncrementTableTimeStampRequest parsePartialFrom(
+ public static com.google.protobuf.Parser<ClearTableFromCacheRequest> PARSER =
+ new com.google.protobuf.AbstractParser<ClearTableFromCacheRequest>() {
+ public ClearTableFromCacheRequest parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
- return new IncrementTableTimeStampRequest(input, extensionRegistry);
+ return new ClearTableFromCacheRequest(input, extensionRegistry);
}
};
@java.lang.Override
- public com.google.protobuf.Parser<IncrementTableTimeStampRequest> getParserForType() {
+ public com.google.protobuf.Parser<ClearTableFromCacheRequest> getParserForType() {
return PARSER;
}
@@ -6622,10 +6622,10 @@ public final class MetaDataProtos {
if (obj == this) {
return true;
}
- if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest)) {
+ if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest)) {
return super.equals(obj);
}
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest) obj;
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest) obj;
boolean result = true;
result = result && (hasTenantId() == other.hasTenantId());
@@ -6682,53 +6682,53 @@ public final class MetaDataProtos {
return hash;
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest 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.IncrementTableTimeStampRequest parseFrom(byte[] data)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest 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.IncrementTableTimeStampRequest parseFrom(java.io.InputStream input)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseFrom(java.io.InputStream input)
throws java.io.IOException {
return PARSER.parseFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest 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.IncrementTableTimeStampRequest parseDelimitedFrom(java.io.InputStream input)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return PARSER.parseDelimitedFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseDelimitedFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest 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.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return PARSER.parseFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -6737,7 +6737,7 @@ public final class MetaDataProtos {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest prototype) {
+ public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
@@ -6749,24 +6749,24 @@ public final class MetaDataProtos {
return builder;
}
/**
- * Protobuf type {@code IncrementTableTimeStampRequest}
+ * Protobuf type {@code ClearTableFromCacheRequest}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequestOrBuilder {
+ implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequestOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampRequest_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheRequest_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampRequest_fieldAccessorTable
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheRequest_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.Builder.class);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.Builder.class);
}
- // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.newBuilder()
+ // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@@ -6803,23 +6803,23 @@ public final class MetaDataProtos {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampRequest_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheRequest_descriptor;
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest getDefaultInstanceForType() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.getDefaultInstance();
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest getDefaultInstanceForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.getDefaultInstance();
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest build() {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest result = buildPartial();
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest build() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest buildPartial() {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest(this);
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest buildPartial() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest(this);
int from_bitField0_ = bitField0_;
int to_bitField0_ = 0;
if (((from_bitField0_ & 0x00000001) == 0x00000001)) {
@@ -6844,16 +6844,16 @@ public final class MetaDataProtos {
}
public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest) {
- return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest)other);
+ if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest) {
+ return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest)other);
} else {
super.mergeFrom(other);
return this;
}
}
- public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest other) {
- if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.getDefaultInstance()) return this;
+ public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest other) {
+ if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.getDefaultInstance()) return this;
if (other.hasTenantId()) {
setTenantId(other.getTenantId());
}
@@ -6894,11 +6894,11 @@ public final class MetaDataProtos {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest parsedMessage = null;
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest) e.getUnfinishedMessage();
+ parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest) e.getUnfinishedMessage();
throw e;
} finally {
if (parsedMessage != null) {
@@ -7050,39 +7050,39 @@ public final class MetaDataProtos {
return this;
}
- // @@protoc_insertion_point(builder_scope:IncrementTableTimeStampRequest)
+ // @@protoc_insertion_point(builder_scope:ClearTableFromCacheRequest)
}
static {
- defaultInstance = new IncrementTableTimeStampRequest(true);
+ defaultInstance = new ClearTableFromCacheRequest(true);
defaultInstance.initFields();
}
- // @@protoc_insertion_point(class_scope:IncrementTableTimeStampRequest)
+ // @@protoc_insertion_point(class_scope:ClearTableFromCacheRequest)
}
- public interface IncrementTableTimeStampResponseOrBuilder
+ public interface ClearTableFromCacheResponseOrBuilder
extends com.google.protobuf.MessageOrBuilder {
}
/**
- * Protobuf type {@code IncrementTableTimeStampResponse}
+ * Protobuf type {@code ClearTableFromCacheResponse}
*/
- public static final class IncrementTableTimeStampResponse extends
+ public static final class ClearTableFromCacheResponse extends
com.google.protobuf.GeneratedMessage
- implements IncrementTableTimeStampResponseOrBuilder {
- // Use IncrementTableTimeStampResponse.newBuilder() to construct.
- private IncrementTableTimeStampResponse(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
+ implements ClearTableFromCacheResponseOrBuilder {
+ // Use ClearTableFromCacheResponse.newBuilder() to construct.
+ private ClearTableFromCacheResponse(com.google.protobuf.GeneratedMessage.Builder<?> builder) {
super(builder);
this.unknownFields = builder.getUnknownFields();
}
- private IncrementTableTimeStampResponse(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
+ private ClearTableFromCacheResponse(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); }
- private static final IncrementTableTimeStampResponse defaultInstance;
- public static IncrementTableTimeStampResponse getDefaultInstance() {
+ private static final ClearTableFromCacheResponse defaultInstance;
+ public static ClearTableFromCacheResponse getDefaultInstance() {
return defaultInstance;
}
- public IncrementTableTimeStampResponse getDefaultInstanceForType() {
+ public ClearTableFromCacheResponse getDefaultInstanceForType() {
return defaultInstance;
}
@@ -7092,7 +7092,7 @@ public final class MetaDataProtos {
getUnknownFields() {
return this.unknownFields;
}
- private IncrementTableTimeStampResponse(
+ private ClearTableFromCacheResponse(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
@@ -7128,28 +7128,28 @@ public final class MetaDataProtos {
}
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampResponse_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampResponse_fieldAccessorTable
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheResponse_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.Builder.class);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.Builder.class);
}
- public static com.google.protobuf.Parser<IncrementTableTimeStampResponse> PARSER =
- new com.google.protobuf.AbstractParser<IncrementTableTimeStampResponse>() {
- public IncrementTableTimeStampResponse parsePartialFrom(
+ public static com.google.protobuf.Parser<ClearTableFromCacheResponse> PARSER =
+ new com.google.protobuf.AbstractParser<ClearTableFromCacheResponse>() {
+ public ClearTableFromCacheResponse parsePartialFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws com.google.protobuf.InvalidProtocolBufferException {
- return new IncrementTableTimeStampResponse(input, extensionRegistry);
+ return new ClearTableFromCacheResponse(input, extensionRegistry);
}
};
@java.lang.Override
- public com.google.protobuf.Parser<IncrementTableTimeStampResponse> getParserForType() {
+ public com.google.protobuf.Parser<ClearTableFromCacheResponse> getParserForType() {
return PARSER;
}
@@ -7193,10 +7193,10 @@ public final class MetaDataProtos {
if (obj == this) {
return true;
}
- if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse)) {
+ if (!(obj instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse)) {
return super.equals(obj);
}
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse) obj;
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse other = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse) obj;
boolean result = true;
result = result &&
@@ -7217,53 +7217,53 @@ public final class MetaDataProtos {
return hash;
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseFrom(
com.google.protobuf.ByteString data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse 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.IncrementTableTimeStampResponse parseFrom(byte[] data)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseFrom(byte[] data)
throws com.google.protobuf.InvalidProtocolBufferException {
return PARSER.parseFrom(data);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse 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.IncrementTableTimeStampResponse parseFrom(java.io.InputStream input)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseFrom(java.io.InputStream input)
throws java.io.IOException {
return PARSER.parseFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse 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.IncrementTableTimeStampResponse parseDelimitedFrom(java.io.InputStream input)
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseDelimitedFrom(java.io.InputStream input)
throws java.io.IOException {
return PARSER.parseDelimitedFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseDelimitedFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse 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.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseFrom(
com.google.protobuf.CodedInputStream input)
throws java.io.IOException {
return PARSER.parseFrom(input);
}
- public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parseFrom(
+ public static org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parseFrom(
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
@@ -7272,7 +7272,7 @@ public final class MetaDataProtos {
public static Builder newBuilder() { return Builder.create(); }
public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse prototype) {
+ public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse prototype) {
return newBuilder().mergeFrom(prototype);
}
public Builder toBuilder() { return newBuilder(this); }
@@ -7284,24 +7284,24 @@ public final class MetaDataProtos {
return builder;
}
/**
- * Protobuf type {@code IncrementTableTimeStampResponse}
+ * Protobuf type {@code ClearTableFromCacheResponse}
*/
public static final class Builder extends
com.google.protobuf.GeneratedMessage.Builder<Builder>
- implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponseOrBuilder {
+ implements org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponseOrBuilder {
public static final com.google.protobuf.Descriptors.Descriptor
getDescriptor() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampResponse_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheResponse_descriptor;
}
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable
internalGetFieldAccessorTable() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampResponse_fieldAccessorTable
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheResponse_fieldAccessorTable
.ensureFieldAccessorsInitialized(
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.Builder.class);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.class, org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.Builder.class);
}
- // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.newBuilder()
+ // Construct using org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.newBuilder()
private Builder() {
maybeForceBuilderInitialization();
}
@@ -7330,38 +7330,38 @@ public final class MetaDataProtos {
public com.google.protobuf.Descriptors.Descriptor
getDescriptorForType() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_IncrementTableTimeStampResponse_descriptor;
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.internal_static_ClearTableFromCacheResponse_descriptor;
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse getDefaultInstanceForType() {
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance();
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse getDefaultInstanceForType() {
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance();
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse build() {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse result = buildPartial();
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse build() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse result = buildPartial();
if (!result.isInitialized()) {
throw newUninitializedMessageException(result);
}
return result;
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse buildPartial() {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse(this);
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse buildPartial() {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse result = new org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse(this);
onBuilt();
return result;
}
public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse) {
- return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse)other);
+ if (other instanceof org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse) {
+ return mergeFrom((org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse)other);
} else {
super.mergeFrom(other);
return this;
}
}
- public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse other) {
- if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance()) return this;
+ public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse other) {
+ if (other == org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance()) return this;
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
@@ -7374,11 +7374,11 @@ public final class MetaDataProtos {
com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry)
throws java.io.IOException {
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse parsedMessage = null;
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse parsedMessage = null;
try {
parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse) e.getUnfinishedMessage();
+ parsedMessage = (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse) e.getUnfinishedMessage();
throw e;
} finally {
if (parsedMessage != null) {
@@ -7388,15 +7388,15 @@ public final class MetaDataProtos {
return this;
}
- // @@protoc_insertion_point(builder_scope:IncrementTableTimeStampResponse)
+ // @@protoc_insertion_point(builder_scope:ClearTableFromCacheResponse)
}
static {
- defaultInstance = new IncrementTableTimeStampResponse(true);
+ defaultInstance = new ClearTableFromCacheResponse(true);
defaultInstance.initFields();
}
- // @@protoc_insertion_point(class_scope:IncrementTableTimeStampResponse)
+ // @@protoc_insertion_point(class_scope:ClearTableFromCacheResponse)
}
/**
@@ -7472,12 +7472,12 @@ public final class MetaDataProtos {
com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse> done);
/**
- * <code>rpc incrementTableTimeStamp(.IncrementTableTimeStampRequest) returns (.IncrementTableTimeStampResponse);</code>
+ * <code>rpc clearTableFromCache(.ClearTableFromCacheRequest) returns (.ClearTableFromCacheResponse);</code>
*/
- public abstract void incrementTableTimeStamp(
+ public abstract void clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request,
- com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse> done);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request,
+ com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse> done);
}
@@ -7549,11 +7549,11 @@ public final class MetaDataProtos {
}
@java.lang.Override
- public void incrementTableTimeStamp(
+ public void clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request,
- com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse> done) {
- impl.incrementTableTimeStamp(controller, request, done);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request,
+ com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse> done) {
+ impl.clearTableFromCache(controller, request, done);
}
};
@@ -7595,7 +7595,7 @@ public final class MetaDataProtos {
case 7:
return impl.getVersion(controller, (org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest)request);
case 8:
- return impl.incrementTableTimeStamp(controller, (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest)request);
+ return impl.clearTableFromCache(controller, (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest)request);
default:
throw new java.lang.AssertionError("Can't get here.");
}
@@ -7627,7 +7627,7 @@ public final class MetaDataProtos {
case 7:
return org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest.getDefaultInstance();
case 8:
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.getDefaultInstance();
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.getDefaultInstance();
default:
throw new java.lang.AssertionError("Can't get here.");
}
@@ -7659,7 +7659,7 @@ public final class MetaDataProtos {
case 7:
return org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse.getDefaultInstance();
case 8:
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance();
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance();
default:
throw new java.lang.AssertionError("Can't get here.");
}
@@ -7733,12 +7733,12 @@ public final class MetaDataProtos {
com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse> done);
/**
- * <code>rpc incrementTableTimeStamp(.IncrementTableTimeStampRequest) returns (.IncrementTableTimeStampResponse);</code>
+ * <code>rpc clearTableFromCache(.ClearTableFromCacheRequest) returns (.ClearTableFromCacheResponse);</code>
*/
- public abstract void incrementTableTimeStamp(
+ public abstract void clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request,
- com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse> done);
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request,
+ com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse> done);
public static final
com.google.protobuf.Descriptors.ServiceDescriptor
@@ -7803,8 +7803,8 @@ public final class MetaDataProtos {
done));
return;
case 8:
- this.incrementTableTimeStamp(controller, (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest)request,
- com.google.protobuf.RpcUtil.<org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse>specializeCallback(
+ this.clearTableFromCache(controller, (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest)request,
+ com.google.protobuf.RpcUtil.<org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse>specializeCallback(
done));
return;
default:
@@ -7838,7 +7838,7 @@ public final class MetaDataProtos {
case 7:
return org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest.getDefaultInstance();
case 8:
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest.getDefaultInstance();
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest.getDefaultInstance();
default:
throw new java.lang.AssertionError("Can't get here.");
}
@@ -7870,7 +7870,7 @@ public final class MetaDataProtos {
case 7:
return org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse.getDefaultInstance();
case 8:
- return org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance();
+ return org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance();
default:
throw new java.lang.AssertionError("Can't get here.");
}
@@ -8012,19 +8012,19 @@ public final class MetaDataProtos {
org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse.getDefaultInstance()));
}
- public void incrementTableTimeStamp(
+ public void clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request,
- com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse> done) {
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request,
+ com.google.protobuf.RpcCallback<org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse> done) {
channel.callMethod(
getDescriptor().getMethods().get(8),
controller,
request,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance(),
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance(),
com.google.protobuf.RpcUtil.generalizeCallback(
done,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.class,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance()));
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.class,
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance()));
}
}
@@ -8074,9 +8074,9 @@ public final class MetaDataProtos {
org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest request)
throws com.google.protobuf.ServiceException;
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse incrementTableTimeStamp(
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request)
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request)
throws com.google.protobuf.ServiceException;
}
@@ -8183,15 +8183,15 @@ public final class MetaDataProtos {
}
- public org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse incrementTableTimeStamp(
+ public org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse clearTableFromCache(
com.google.protobuf.RpcController controller,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest request)
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest request)
throws com.google.protobuf.ServiceException {
- return (org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse) channel.callBlockingMethod(
+ return (org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse) channel.callBlockingMethod(
getDescriptor().getMethods().get(8),
controller,
request,
- org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse.getDefaultInstance());
+ org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse.getDefaultInstance());
}
}
@@ -8255,15 +8255,15 @@ public final class MetaDataProtos {
com.google.protobuf.GeneratedMessage.FieldAccessorTable
internal_static_GetVersionResponse_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
- internal_static_IncrementTableTimeStampRequest_descriptor;
+ internal_static_ClearTableFromCacheRequest_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_IncrementTableTimeStampRequest_fieldAccessorTable;
+ internal_static_ClearTableFromCacheRequest_fieldAccessorTable;
private static com.google.protobuf.Descriptors.Descriptor
- internal_static_IncrementTableTimeStampResponse_descriptor;
+ internal_static_ClearTableFromCacheResponse_descriptor;
private static
com.google.protobuf.GeneratedMessage.FieldAccessorTable
- internal_static_IncrementTableTimeStampResponse_fieldAccessorTable;
+ internal_static_ClearTableFromCacheResponse_fieldAccessorTable;
public static com.google.protobuf.Descriptors.FileDescriptor
getDescriptor() {
@@ -8291,33 +8291,32 @@ public final class MetaDataProtos {
"st\022\036\n\026tableMetadataMutations\030\001 \003(\014\"\023\n\021Cl" +
"earCacheRequest\"\024\n\022ClearCacheResponse\"\023\n" +
"\021GetVersionRequest\"%\n\022GetVersionResponse" +
- "\022\017\n\007version\030\001 \002(\003\"r\n\036IncrementTableTimeS" +
- "tampRequest\022\020\n\010tenantId\030\001 \002(\014\022\022\n\nschemaN",
- "ame\030\002 \002(\014\022\021\n\ttableName\030\003 \002(\014\022\027\n\017clientTi" +
- "mestamp\030\004 \002(\003\"!\n\037IncrementTableTimeStamp" +
- "Response*\212\002\n\014MutationCode\022\030\n\024TABLE_ALREA" +
- "DY_EXISTS\020\000\022\023\n\017TABLE_NOT_FOUND\020\001\022\024\n\020COLU" +
- "MN_NOT_FOUND\020\002\022\031\n\025COLUMN_ALREADY_EXISTS\020" +
- "\003\022\035\n\031CONCURRENT_TABLE_MUTATION\020\004\022\027\n\023TABL" +
- "E_NOT_IN_REGION\020\005\022\025\n\021NEWER_TABLE_FOUND\020\006" +
- "\022\034\n\030UNALLOWED_TABLE_MUTATION\020\007\022\021\n\rNO_PK_" +
- "COLUMNS\020\010\022\032\n\026PARENT_TABLE_NOT_FOUND\020\t2\241\004" +
- "\n\017MetaDataService\022/\n\010getTable\022\020.GetTable",
- "Request\032\021.MetaDataResponse\0225\n\013createTabl" +
- "e\022\023.CreateTableRequest\032\021.MetaDataRespons" +
- "e\0221\n\tdropTable\022\021.DropTableRequest\032\021.Meta" +
- "DataResponse\0221\n\taddColumn\022\021.AddColumnReq" +
- "uest\032\021.MetaDataResponse\0223\n\ndropColumn\022\022." +
- "DropColumnRequest\032\021.MetaDataResponse\022?\n\020" +
- "updateIndexState\022\030.UpdateIndexStateReque" +
- "st\032\021.MetaDataResponse\0225\n\nclearCache\022\022.Cl" +
- "earCacheRequest\032\023.ClearCacheResponse\0225\n\n" +
- "getVersion\022\022.GetVersionRequest\032\023.GetVers",
- "ionResponse\022\\\n\027incrementTableTimeStamp\022\037" +
- ".IncrementTableTimeStampRequest\032 .Increm" +
- "entTableTimeStampResponseBB\n(org.apache." +
- "phoenix.coprocessor.generatedB\016MetaDataP" +
- "rotosH\001\210\001\001\240\001\001"
+ "\022\017\n\007version\030\001 \002(\003\"n\n\032ClearTableFromCache" +
+ "Request\022\020\n\010tenantId\030\001 \002(\014\022\022\n\nschemaName\030",
+ "\002 \002(\014\022\021\n\ttableName\030\003 \002(\014\022\027\n\017clientTimest" +
+ "amp\030\004 \002(\003\"\035\n\033ClearTableFromCacheResponse" +
+ "*\212\002\n\014MutationCode\022\030\n\024TABLE_ALREADY_EXIST" +
+ "S\020\000\022\023\n\017TABLE_NOT_FOUND\020\001\022\024\n\020COLUMN_NOT_F" +
+ "OUND\020\002\022\031\n\025COLUMN_ALREADY_EXISTS\020\003\022\035\n\031CON" +
+ "CURRENT_TABLE_MUTATION\020\004\022\027\n\023TABLE_NOT_IN" +
+ "_REGION\020\005\022\025\n\021NEWER_TABLE_FOUND\020\006\022\034\n\030UNAL" +
+ "LOWED_TABLE_MUTATION\020\007\022\021\n\rNO_PK_COLUMNS\020" +
+ "\010\022\032\n\026PARENT_TABLE_NOT_FOUND\020\t2\225\004\n\017MetaDa" +
+ "taService\022/\n\010getTable\022\020.GetTableRequest\032",
+ "\021.MetaDataResponse\0225\n\013createTable\022\023.Crea" +
+ "teTableRequest\032\021.MetaDataResponse\0221\n\tdro" +
+ "pTable\022\021.DropTableRequest\032\021.MetaDataResp" +
+ "onse\0221\n\taddColumn\022\021.AddColumnRequest\032\021.M" +
+ "etaDataResponse\0223\n\ndropColumn\022\022.DropColu" +
+ "mnRequest\032\021.MetaDataResponse\022?\n\020updateIn" +
+ "dexState\022\030.UpdateIndexStateRequest\032\021.Met" +
+ "aDataResponse\0225\n\nclearCache\022\022.ClearCache" +
+ "Request\032\023.ClearCacheResponse\0225\n\ngetVersi" +
+ "on\022\022.GetVersionRequest\032\023.GetVersionRespo",
+ "nse\022P\n\023clearTableFromCache\022\033.ClearTableF" +
+ "romCacheRequest\032\034.ClearTableFromCacheRes" +
+ "ponseBB\n(org.apache.phoenix.coprocessor." +
+ "generatedB\016MetaDataProtosH\001\210\001\001\240\001\001"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@@ -8390,17 +8389,17 @@ public final class MetaDataProtos {
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_GetVersionResponse_descriptor,
new java.lang.String[] { "Version", });
- internal_static_IncrementTableTimeStampRequest_descriptor =
+ internal_static_ClearTableFromCacheRequest_descriptor =
getDescriptor().getMessageTypes().get(11);
- internal_static_IncrementTableTimeStampRequest_fieldAccessorTable = new
+ internal_static_ClearTableFromCacheRequest_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_IncrementTableTimeStampRequest_descriptor,
+ internal_static_ClearTableFromCacheRequest_descriptor,
new java.lang.String[] { "TenantId", "SchemaName", "TableName", "ClientTimestamp", });
- internal_static_IncrementTableTimeStampResponse_descriptor =
+ internal_static_ClearTableFromCacheResponse_descriptor =
getDescriptor().getMessageTypes().get(12);
- internal_static_IncrementTableTimeStampResponse_fieldAccessorTable = new
+ internal_static_ClearTableFromCacheResponse_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
- internal_static_IncrementTableTimeStampResponse_descriptor,
+ internal_static_ClearTableFromCacheResponse_descriptor,
new java.lang.String[] { });
return null;
}
http://git-wip-us.apache.org/repos/asf/phoenix/blob/c32c60e3/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
index dbf786a..a267b47 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/query/ConnectionQueryServicesImpl.java
@@ -80,14 +80,14 @@ import org.apache.phoenix.coprocessor.generated.MetaDataProtos;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.AddColumnRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearCacheRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearCacheResponse;
+import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheRequest;
+import org.apache.phoenix.coprocessor.generated.MetaDataProtos.ClearTableFromCacheResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.CreateTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.DropColumnRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.DropTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetTableRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionRequest;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.GetVersionResponse;
-import org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampRequest;
-import org.apache.phoenix.coprocessor.generated.MetaDataProtos.IncrementTableTimeStampResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.MetaDataResponse;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.MetaDataService;
import org.apache.phoenix.coprocessor.generated.MetaDataProtos.UpdateIndexStateRequest;
@@ -1895,17 +1895,17 @@ public class ConnectionQueryServicesImpl extends DelegateQueryServices implement
HTableInterface htable = this.getTable(PhoenixDatabaseMetaData.SYSTEM_CATALOG_NAME_BYTES);
try {
htable.coprocessorService(MetaDataService.class, HConstants.EMPTY_START_ROW, HConstants.EMPTY_END_ROW,
- new Batch.Call<MetaDataService, IncrementTableTimeStampResponse>() {
+ new Batch.Call<MetaDataService, ClearTableFromCacheResponse>() {
@Override
- public IncrementTableTimeStampResponse call(MetaDataService instance) throws IOException {
+ public ClearTableFromCacheResponse call(MetaDataService instance) throws IOException {
ServerRpcController controller = new ServerRpcController();
- BlockingRpcCallback<IncrementTableTimeStampResponse> rpcCallback = new BlockingRpcCallback<IncrementTableTimeStampResponse>();
- IncrementTableTimeStampRequest.Builder builder = IncrementTableTimeStampRequest.newBuilder();
+ BlockingRpcCallback<ClearTableFromCacheResponse> rpcCallback = new BlockingRpcCallback<ClearTableFromCacheResponse>();
+ ClearTableFromCacheRequest.Builder builder = ClearTableFromCacheRequest.newBuilder();
builder.setTenantId(HBaseZeroCopyByteString.wrap(tenantId));
builder.setTableName(HBaseZeroCopyByteString.wrap(tableName));
builder.setSchemaName(HBaseZeroCopyByteString.wrap(schemaName));
builder.setClientTimestamp(clientTS);
- instance.incrementTableTimeStamp(controller, builder.build(), rpcCallback);
+ instance.clearTableFromCache(controller, builder.build(), rpcCallback);
if (controller.getFailedOn() != null) { throw controller.getFailedOn(); }
return rpcCallback.get();
}
http://git-wip-us.apache.org/repos/asf/phoenix/blob/c32c60e3/phoenix-protocol/src/main/MetaDataService.proto
----------------------------------------------------------------------
diff --git a/phoenix-protocol/src/main/MetaDataService.proto b/phoenix-protocol/src/main/MetaDataService.proto
index accd5f2..a8d72da 100644
--- a/phoenix-protocol/src/main/MetaDataService.proto
+++ b/phoenix-protocol/src/main/MetaDataService.proto
@@ -92,14 +92,14 @@ message GetVersionResponse {
required int64 version = 1;
}
-message IncrementTableTimeStampRequest {
+message ClearTableFromCacheRequest {
required bytes tenantId = 1;
required bytes schemaName = 2;
required bytes tableName = 3;
required int64 clientTimestamp = 4;
}
-message IncrementTableTimeStampResponse {
+message ClearTableFromCacheResponse {
}
service MetaDataService {
@@ -127,6 +127,6 @@ service MetaDataService {
rpc getVersion(GetVersionRequest)
returns (GetVersionResponse);
- rpc incrementTableTimeStamp(IncrementTableTimeStampRequest)
- returns (IncrementTableTimeStampResponse);
+ rpc clearTableFromCache(ClearTableFromCacheRequest)
+ returns (ClearTableFromCacheResponse);
}
[2/2] git commit: Serialize table ts of when stats calculated
Posted by ja...@apache.org.
Serialize table ts of when stats calculated
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/172dd069
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/172dd069
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/172dd069
Branch: refs/heads/master
Commit: 172dd069843df995d7e7f3dd762573a14c84c3a2
Parents: c32c60e
Author: James Taylor <jt...@salesforce.com>
Authored: Tue Oct 28 13:16:12 2014 -0700
Committer: James Taylor <jt...@salesforce.com>
Committed: Tue Oct 28 13:16:12 2014 -0700
----------------------------------------------------------------------
.../coprocessor/generated/PTableProtos.java | 103 +++++++++++++++++--
.../org/apache/phoenix/schema/PTableImpl.java | 5 +-
phoenix-protocol/src/main/PTable.proto | 1 +
3 files changed, 101 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/172dd069/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/PTableProtos.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/PTableProtos.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/PTableProtos.java
index f1b3be1..ff2cfe4 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/PTableProtos.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/generated/PTableProtos.java
@@ -2722,6 +2722,16 @@ public final class PTableProtos {
* <code>optional bytes indexType = 22;</code>
*/
com.google.protobuf.ByteString getIndexType();
+
+ // optional int64 statsTimeStamp = 23;
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ boolean hasStatsTimeStamp();
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ long getStatsTimeStamp();
}
/**
* Protobuf type {@code PTable}
@@ -2902,6 +2912,11 @@ public final class PTableProtos {
indexType_ = input.readBytes();
break;
}
+ case 184: {
+ bitField0_ |= 0x00040000;
+ statsTimeStamp_ = input.readInt64();
+ break;
+ }
}
}
} catch (com.google.protobuf.InvalidProtocolBufferException e) {
@@ -3400,6 +3415,22 @@ public final class PTableProtos {
return indexType_;
}
+ // optional int64 statsTimeStamp = 23;
+ public static final int STATSTIMESTAMP_FIELD_NUMBER = 23;
+ private long statsTimeStamp_;
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public boolean hasStatsTimeStamp() {
+ return ((bitField0_ & 0x00040000) == 0x00040000);
+ }
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public long getStatsTimeStamp() {
+ return statsTimeStamp_;
+ }
+
private void initFields() {
schemaNameBytes_ = com.google.protobuf.ByteString.EMPTY;
tableNameBytes_ = com.google.protobuf.ByteString.EMPTY;
@@ -3423,6 +3454,7 @@ public final class PTableProtos {
tenantId_ = com.google.protobuf.ByteString.EMPTY;
viewIndexId_ = 0;
indexType_ = com.google.protobuf.ByteString.EMPTY;
+ statsTimeStamp_ = 0L;
}
private byte memoizedIsInitialized = -1;
public final boolean isInitialized() {
@@ -3556,6 +3588,9 @@ public final class PTableProtos {
if (((bitField0_ & 0x00020000) == 0x00020000)) {
output.writeBytes(22, indexType_);
}
+ if (((bitField0_ & 0x00040000) == 0x00040000)) {
+ output.writeInt64(23, statsTimeStamp_);
+ }
getUnknownFields().writeTo(output);
}
@@ -3658,6 +3693,10 @@ public final class PTableProtos {
size += com.google.protobuf.CodedOutputStream
.computeBytesSize(22, indexType_);
}
+ if (((bitField0_ & 0x00040000) == 0x00040000)) {
+ size += com.google.protobuf.CodedOutputStream
+ .computeInt64Size(23, statsTimeStamp_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSerializedSize = size;
return size;
@@ -3779,6 +3818,11 @@ public final class PTableProtos {
result = result && getIndexType()
.equals(other.getIndexType());
}
+ result = result && (hasStatsTimeStamp() == other.hasStatsTimeStamp());
+ if (hasStatsTimeStamp()) {
+ result = result && (getStatsTimeStamp()
+ == other.getStatsTimeStamp());
+ }
result = result &&
getUnknownFields().equals(other.getUnknownFields());
return result;
@@ -3880,6 +3924,10 @@ public final class PTableProtos {
hash = (37 * hash) + INDEXTYPE_FIELD_NUMBER;
hash = (53 * hash) + getIndexType().hashCode();
}
+ if (hasStatsTimeStamp()) {
+ hash = (37 * hash) + STATSTIMESTAMP_FIELD_NUMBER;
+ hash = (53 * hash) + hashLong(getStatsTimeStamp());
+ }
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
@@ -4048,6 +4096,8 @@ public final class PTableProtos {
bitField0_ = (bitField0_ & ~0x00100000);
indexType_ = com.google.protobuf.ByteString.EMPTY;
bitField0_ = (bitField0_ & ~0x00200000);
+ statsTimeStamp_ = 0L;
+ bitField0_ = (bitField0_ & ~0x00400000);
return this;
}
@@ -4180,6 +4230,10 @@ public final class PTableProtos {
to_bitField0_ |= 0x00020000;
}
result.indexType_ = indexType_;
+ if (((from_bitField0_ & 0x00400000) == 0x00400000)) {
+ to_bitField0_ |= 0x00040000;
+ }
+ result.statsTimeStamp_ = statsTimeStamp_;
result.bitField0_ = to_bitField0_;
onBuilt();
return result;
@@ -4340,6 +4394,9 @@ public final class PTableProtos {
if (other.hasIndexType()) {
setIndexType(other.getIndexType());
}
+ if (other.hasStatsTimeStamp()) {
+ setStatsTimeStamp(other.getStatsTimeStamp());
+ }
this.mergeUnknownFields(other.getUnknownFields());
return this;
}
@@ -5878,6 +5935,39 @@ public final class PTableProtos {
return this;
}
+ // optional int64 statsTimeStamp = 23;
+ private long statsTimeStamp_ ;
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public boolean hasStatsTimeStamp() {
+ return ((bitField0_ & 0x00400000) == 0x00400000);
+ }
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public long getStatsTimeStamp() {
+ return statsTimeStamp_;
+ }
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public Builder setStatsTimeStamp(long value) {
+ bitField0_ |= 0x00400000;
+ statsTimeStamp_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ * <code>optional int64 statsTimeStamp = 23;</code>
+ */
+ public Builder clearStatsTimeStamp() {
+ bitField0_ = (bitField0_ & ~0x00400000);
+ statsTimeStamp_ = 0L;
+ onChanged();
+ return this;
+ }
+
// @@protoc_insertion_point(builder_scope:PTable)
}
@@ -5922,7 +6012,7 @@ public final class PTableProtos {
"ed\030\013 \001(\010\"w\n\013PTableStats\022\013\n\003key\030\001 \002(\014\022\016\n\006" +
"values\030\002 \003(\014\022\033\n\023guidePostsByteCount\030\003 \001(" +
"\003\022\025\n\rkeyBytesCount\030\004 \001(\003\022\027\n\017guidePostsCo" +
- "unt\030\005 \001(\005\"\212\004\n\006PTable\022\027\n\017schemaNameBytes\030",
+ "unt\030\005 \001(\005\"\242\004\n\006PTable\022\027\n\017schemaNameBytes\030",
"\001 \002(\014\022\026\n\016tableNameBytes\030\002 \002(\014\022\036\n\ttableTy" +
"pe\030\003 \002(\0162\013.PTableType\022\022\n\nindexState\030\004 \001(" +
"\t\022\026\n\016sequenceNumber\030\005 \002(\003\022\021\n\ttimeStamp\030\006" +
@@ -5935,10 +6025,11 @@ public final class PTableProtos {
"Tenant\030\020 \002(\010\022\020\n\010viewType\030\021 \001(\014\022\025\n\rviewSt",
"atement\030\022 \001(\014\022\025\n\rphysicalNames\030\023 \003(\014\022\020\n\010" +
"tenantId\030\024 \001(\014\022\023\n\013viewIndexId\030\025 \001(\005\022\021\n\ti" +
- "ndexType\030\026 \001(\014*A\n\nPTableType\022\n\n\006SYSTEM\020\000" +
- "\022\010\n\004USER\020\001\022\010\n\004VIEW\020\002\022\t\n\005INDEX\020\003\022\010\n\004JOIN\020" +
- "\004B@\n(org.apache.phoenix.coprocessor.gene" +
- "ratedB\014PTableProtosH\001\210\001\001\240\001\001"
+ "ndexType\030\026 \001(\014\022\026\n\016statsTimeStamp\030\027 \001(\003*A" +
+ "\n\nPTableType\022\n\n\006SYSTEM\020\000\022\010\n\004USER\020\001\022\010\n\004VI" +
+ "EW\020\002\022\t\n\005INDEX\020\003\022\010\n\004JOIN\020\004B@\n(org.apache." +
+ "phoenix.coprocessor.generatedB\014PTablePro" +
+ "tosH\001\210\001\001\240\001\001"
};
com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner =
new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() {
@@ -5962,7 +6053,7 @@ public final class PTableProtos {
internal_static_PTable_fieldAccessorTable = new
com.google.protobuf.GeneratedMessage.FieldAccessorTable(
internal_static_PTable_descriptor,
- new java.lang.String[] { "SchemaNameBytes", "TableNameBytes", "TableType", "IndexState", "SequenceNumber", "TimeStamp", "PkNameBytes", "BucketNum", "Columns", "Indexes", "IsImmutableRows", "GuidePosts", "DataTableNameBytes", "DefaultFamilyName", "DisableWAL", "MultiTenant", "ViewType", "ViewStatement", "PhysicalNames", "TenantId", "ViewIndexId", "IndexType", });
+ new java.lang.String[] { "SchemaNameBytes", "TableNameBytes", "TableType", "IndexState", "SequenceNumber", "TimeStamp", "PkNameBytes", "BucketNum", "Columns", "Indexes", "IsImmutableRows", "GuidePosts", "DataTableNameBytes", "DefaultFamilyName", "DisableWAL", "MultiTenant", "ViewType", "ViewStatement", "PhysicalNames", "TenantId", "ViewIndexId", "IndexType", "StatsTimeStamp", });
return null;
}
};
http://git-wip-us.apache.org/repos/asf/phoenix/blob/172dd069/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
index 8f85ccc..66cfa0b 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/schema/PTableImpl.java
@@ -886,7 +886,7 @@ public class PTableImpl implements PTable {
GuidePostsInfo info = new GuidePostsInfo(pTableStatsProto.getGuidePostsByteCount(), value);
tableGuidePosts.put(pTableStatsProto.getKey().toByteArray(), info);
}
- PTableStats stats = new PTableStatsImpl(tableGuidePosts, timeStamp);
+ PTableStats stats = new PTableStatsImpl(tableGuidePosts, table.getStatsTimeStamp());
PName dataTableName = null;
if (table.hasDataTableNameBytes()) {
@@ -979,7 +979,8 @@ public class PTableImpl implements PTable {
}
statsBuilder.setGuidePostsByteCount(entry.getValue().getByteCount());
builder.addGuidePosts(statsBuilder.build());
- }
+ }
+ builder.setStatsTimeStamp(table.getTableStats().getTimestamp());
if (table.getParentName() != null) {
builder.setDataTableNameBytes(HBaseZeroCopyByteString.wrap(table.getParentTableName().getBytes()));
http://git-wip-us.apache.org/repos/asf/phoenix/blob/172dd069/phoenix-protocol/src/main/PTable.proto
----------------------------------------------------------------------
diff --git a/phoenix-protocol/src/main/PTable.proto b/phoenix-protocol/src/main/PTable.proto
index b622a26..772d51d 100644
--- a/phoenix-protocol/src/main/PTable.proto
+++ b/phoenix-protocol/src/main/PTable.proto
@@ -77,4 +77,5 @@ message PTable {
optional bytes tenantId = 20;
optional int32 viewIndexId = 21;
optional bytes indexType = 22;
+ optional int64 statsTimeStamp = 23;
}