Repository: kylin Updated Branches: refs/heads/master 707b05598 -> 43c056672
http://git-wip-us.apache.org/repos/asf/kylin/blob/43c05667/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/generated/CubeVisitProtos.java ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/generated/CubeVisitProtos.java b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/generated/CubeVisitProtos.java index 4b6fc95..b9f2771 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/generated/CubeVisitProtos.java +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/generated/CubeVisitProtos.java @@ -121,10 +121,18 @@ public final class CubeVisitProtos { // optional int64 maxScanBytes = 8; /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ boolean hasMaxScanBytes(); /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ long getMaxScanBytes(); } @@ -972,12 +980,20 @@ public final class CubeVisitProtos { private long maxScanBytes_; /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public boolean hasMaxScanBytes() { return ((bitField0_ & 0x00000040) == 0x00000040); } /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public long getMaxScanBytes() { return maxScanBytes_; @@ -2050,18 +2066,30 @@ public final class CubeVisitProtos { private long maxScanBytes_ ; /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public boolean hasMaxScanBytes() { return ((bitField0_ & 0x00000080) == 0x00000080); } /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public long getMaxScanBytes() { return maxScanBytes_; } /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public Builder setMaxScanBytes(long value) { bitField0_ |= 0x00000080; @@ -2071,6 +2099,10 @@ public final class CubeVisitProtos { } /** * <code>optional int64 maxScanBytes = 8;</code> + * + * <pre> + * 0 means no limit + * </pre> */ public Builder clearMaxScanBytes() { bitField0_ = (bitField0_ & ~0x00000080); @@ -2116,6 +2148,32 @@ public final class CubeVisitProtos { * <code>required .CubeVisitResponse.Stats stats = 2;</code> */ org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.StatsOrBuilder getStatsOrBuilder(); + + // optional .CubeVisitResponse.ErrorInfo errorInfo = 3; + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + boolean hasErrorInfo(); + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo getErrorInfo(); + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder getErrorInfoOrBuilder(); } /** * Protobuf type {@code CubeVisitResponse} @@ -2186,6 +2244,19 @@ public final class CubeVisitProtos { bitField0_ |= 0x00000002; break; } + case 26: { + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder subBuilder = null; + if (((bitField0_ & 0x00000004) == 0x00000004)) { + subBuilder = errorInfo_.toBuilder(); + } + errorInfo_ = input.readMessage(org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(errorInfo_); + errorInfo_ = subBuilder.buildPartial(); + } + bitField0_ |= 0x00000004; + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -2225,6 +2296,97 @@ public final class CubeVisitProtos { return PARSER; } + /** + * Protobuf enum {@code CubeVisitResponse.ErrorType} + */ + public enum ErrorType + implements com.google.protobuf.ProtocolMessageEnum { + /** + * <code>UNKNOWN_TYPE = 0;</code> + */ + UNKNOWN_TYPE(0, 0), + /** + * <code>TIMEOUT = 1;</code> + */ + TIMEOUT(1, 1), + /** + * <code>RESOURCE_LIMIT_EXCEEDED = 2;</code> + */ + RESOURCE_LIMIT_EXCEEDED(2, 2), + ; + + /** + * <code>UNKNOWN_TYPE = 0;</code> + */ + public static final int UNKNOWN_TYPE_VALUE = 0; + /** + * <code>TIMEOUT = 1;</code> + */ + public static final int TIMEOUT_VALUE = 1; + /** + * <code>RESOURCE_LIMIT_EXCEEDED = 2;</code> + */ + public static final int RESOURCE_LIMIT_EXCEEDED_VALUE = 2; + + + public final int getNumber() { return value; } + + public static ErrorType valueOf(int value) { + switch (value) { + case 0: return UNKNOWN_TYPE; + case 1: return TIMEOUT; + case 2: return RESOURCE_LIMIT_EXCEEDED; + default: return null; + } + } + + public static com.google.protobuf.Internal.EnumLiteMap<ErrorType> + internalGetValueMap() { + return internalValueMap; + } + private static com.google.protobuf.Internal.EnumLiteMap<ErrorType> + internalValueMap = + new com.google.protobuf.Internal.EnumLiteMap<ErrorType>() { + public ErrorType findValueByNumber(int number) { + return ErrorType.valueOf(number); + } + }; + + public final com.google.protobuf.Descriptors.EnumValueDescriptor + getValueDescriptor() { + return getDescriptor().getValues().get(index); + } + public final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptorForType() { + return getDescriptor(); + } + public static final com.google.protobuf.Descriptors.EnumDescriptor + getDescriptor() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.getDescriptor().getEnumTypes().get(0); + } + + private static final ErrorType[] VALUES = values(); + + public static ErrorType valueOf( + com.google.protobuf.Descriptors.EnumValueDescriptor desc) { + if (desc.getType() != getDescriptor()) { + throw new java.lang.IllegalArgumentException( + "EnumValueDescriptor is not for this type."); + } + return VALUES[desc.getIndex()]; + } + + private final int index; + private final int value; + + private ErrorType(int index, int value) { + this.index = index; + this.value = value; + } + + // @@protoc_insertion_point(enum_scope:CubeVisitResponse.ErrorType) + } + public interface StatsOrBuilder extends com.google.protobuf.MessageOrBuilder { @@ -2331,18 +2493,10 @@ public final class CubeVisitProtos { // optional int32 normalComplete = 10; /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ boolean hasNormalComplete(); /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ int getNormalComplete(); @@ -2705,20 +2859,12 @@ public final class CubeVisitProtos { private int normalComplete_; /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public boolean hasNormalComplete() { return ((bitField0_ & 0x00000200) == 0x00000200); } /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public int getNormalComplete() { return normalComplete_; @@ -3652,30 +3798,18 @@ public final class CubeVisitProtos { private int normalComplete_ ; /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public boolean hasNormalComplete() { return ((bitField0_ & 0x00000200) == 0x00000200); } /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public int getNormalComplete() { return normalComplete_; } /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public Builder setNormalComplete(int value) { bitField0_ |= 0x00000200; @@ -3685,10 +3819,6 @@ public final class CubeVisitProtos { } /** * <code>optional int32 normalComplete = 10;</code> - * - * <pre> - *when time outs, normalComplete will be false - * </pre> */ public Builder clearNormalComplete() { bitField0_ = (bitField0_ & ~0x00000200); @@ -3741,99 +3871,771 @@ public final class CubeVisitProtos { // @@protoc_insertion_point(class_scope:CubeVisitResponse.Stats) } - private int bitField0_; - // required bytes compressedRows = 1; - public static final int COMPRESSEDROWS_FIELD_NUMBER = 1; - private com.google.protobuf.ByteString compressedRows_; - /** - * <code>required bytes compressedRows = 1;</code> - */ - public boolean hasCompressedRows() { - return ((bitField0_ & 0x00000001) == 0x00000001); - } - /** - * <code>required bytes compressedRows = 1;</code> - */ - public com.google.protobuf.ByteString getCompressedRows() { - return compressedRows_; - } + public interface ErrorInfoOrBuilder + extends com.google.protobuf.MessageOrBuilder { - // required .CubeVisitResponse.Stats stats = 2; - public static final int STATS_FIELD_NUMBER = 2; - private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats stats_; - /** - * <code>required .CubeVisitResponse.Stats stats = 2;</code> - */ - public boolean hasStats() { - return ((bitField0_ & 0x00000002) == 0x00000002); - } - /** - * <code>required .CubeVisitResponse.Stats stats = 2;</code> - */ - public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats getStats() { - return stats_; + // required .CubeVisitResponse.ErrorType type = 1; + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + boolean hasType(); + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType getType(); + + // required string message = 2; + /** + * <code>required string message = 2;</code> + */ + boolean hasMessage(); + /** + * <code>required string message = 2;</code> + */ + java.lang.String getMessage(); + /** + * <code>required string message = 2;</code> + */ + com.google.protobuf.ByteString + getMessageBytes(); } /** - * <code>required .CubeVisitResponse.Stats stats = 2;</code> + * Protobuf type {@code CubeVisitResponse.ErrorInfo} */ - public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.StatsOrBuilder getStatsOrBuilder() { - return stats_; - } - - private void initFields() { - compressedRows_ = com.google.protobuf.ByteString.EMPTY; - stats_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats.getDefaultInstance(); - } - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized != -1) return isInitialized == 1; + public static final class ErrorInfo extends + com.google.protobuf.GeneratedMessage + implements ErrorInfoOrBuilder { + // Use ErrorInfo.newBuilder() to construct. + private ErrorInfo(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private ErrorInfo(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } - if (!hasCompressedRows()) { - memoizedIsInitialized = 0; - return false; + private static final ErrorInfo defaultInstance; + public static ErrorInfo getDefaultInstance() { + return defaultInstance; } - if (!hasStats()) { - memoizedIsInitialized = 0; - return false; + + public ErrorInfo getDefaultInstanceForType() { + return defaultInstance; } - memoizedIsInitialized = 1; - return true; - } - public void writeTo(com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - getSerializedSize(); - if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBytes(1, compressedRows_); + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - output.writeMessage(2, stats_); + private ErrorInfo( + 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: { + int rawValue = input.readEnum(); + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType value = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType.valueOf(rawValue); + if (value == null) { + unknownFields.mergeVarintField(1, rawValue); + } else { + bitField0_ |= 0x00000001; + type_ = value; + } + break; + } + case 18: { + bitField0_ |= 0x00000002; + message_ = input.readBytes(); + 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.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.internal_static_CubeVisitResponse_ErrorInfo_descriptor; } - getUnknownFields().writeTo(output); - } - - private int memoizedSerializedSize = -1; - public int getSerializedSize() { - int size = memoizedSerializedSize; - if (size != -1) return size; - size = 0; - if (((bitField0_ & 0x00000001) == 0x00000001)) { - size += com.google.protobuf.CodedOutputStream - .computeBytesSize(1, compressedRows_); + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.internal_static_CubeVisitResponse_ErrorInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.class, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder.class); } - if (((bitField0_ & 0x00000002) == 0x00000002)) { - size += com.google.protobuf.CodedOutputStream - .computeMessageSize(2, stats_); + + public static com.google.protobuf.Parser<ErrorInfo> PARSER = + new com.google.protobuf.AbstractParser<ErrorInfo>() { + public ErrorInfo parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new ErrorInfo(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<ErrorInfo> getParserForType() { + return PARSER; } - size += getUnknownFields().getSerializedSize(); - memoizedSerializedSize = size; - return size; - } - private static final long serialVersionUID = 0L; - @java.lang.Override + private int bitField0_; + // required .CubeVisitResponse.ErrorType type = 1; + public static final int TYPE_FIELD_NUMBER = 1; + private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType type_; + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public boolean hasType() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType getType() { + return type_; + } + + // required string message = 2; + public static final int MESSAGE_FIELD_NUMBER = 2; + private java.lang.Object message_; + /** + * <code>required string message = 2;</code> + */ + public boolean hasMessage() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required string message = 2;</code> + */ + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + return (java.lang.String) ref; + } else { + com.google.protobuf.ByteString bs = + (com.google.protobuf.ByteString) ref; + java.lang.String s = bs.toStringUtf8(); + if (bs.isValidUtf8()) { + message_ = s; + } + return s; + } + } + /** + * <code>required string message = 2;</code> + */ + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + private void initFields() { + type_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType.UNKNOWN_TYPE; + message_ = ""; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasType()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasMessage()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeEnum(1, type_.getNumber()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeBytes(2, getMessageBytes()); + } + 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 + .computeEnumSize(1, type_.getNumber()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(2, getMessageBytes()); + } + 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.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo)) { + return super.equals(obj); + } + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo other = (org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo) obj; + + boolean result = true; + result = result && (hasType() == other.hasType()); + if (hasType()) { + result = result && + (getType() == other.getType()); + } + result = result && (hasMessage() == other.hasMessage()); + if (hasMessage()) { + result = result && getMessage() + .equals(other.getMessage()); + } + 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 (hasType()) { + hash = (37 * hash) + TYPE_FIELD_NUMBER; + hash = (53 * hash) + hashEnum(getType()); + } + if (hasMessage()) { + hash = (37 * hash) + MESSAGE_FIELD_NUMBER; + hash = (53 * hash) + getMessage().hashCode(); + } + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo 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.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom( + byte[] data, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data, extensionRegistry); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseDelimitedFrom( + java.io.InputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input, extensionRegistry); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo 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.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo 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 CubeVisitResponse.ErrorInfo} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.internal_static_CubeVisitResponse_ErrorInfo_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.internal_static_CubeVisitResponse_ErrorInfo_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.class, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder.class); + } + + // Construct using org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.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(); + type_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType.UNKNOWN_TYPE; + bitField0_ = (bitField0_ & ~0x00000001); + message_ = ""; + bitField0_ = (bitField0_ & ~0x00000002); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.internal_static_CubeVisitResponse_ErrorInfo_descriptor; + } + + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo getDefaultInstanceForType() { + return org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance(); + } + + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo build() { + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo buildPartial() { + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo result = new org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.type_ = type_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.message_ = message_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo) { + return mergeFrom((org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo other) { + if (other == org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance()) return this; + if (other.hasType()) { + setType(other.getType()); + } + if (other.hasMessage()) { + bitField0_ |= 0x00000002; + message_ = other.message_; + onChanged(); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasType()) { + + return false; + } + if (!hasMessage()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required .CubeVisitResponse.ErrorType type = 1; + private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType type_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType.UNKNOWN_TYPE; + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public boolean hasType() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType getType() { + return type_; + } + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public Builder setType(org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + type_ = value; + onChanged(); + return this; + } + /** + * <code>required .CubeVisitResponse.ErrorType type = 1;</code> + */ + public Builder clearType() { + bitField0_ = (bitField0_ & ~0x00000001); + type_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorType.UNKNOWN_TYPE; + onChanged(); + return this; + } + + // required string message = 2; + private java.lang.Object message_ = ""; + /** + * <code>required string message = 2;</code> + */ + public boolean hasMessage() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required string message = 2;</code> + */ + public java.lang.String getMessage() { + java.lang.Object ref = message_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + message_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string message = 2;</code> + */ + public com.google.protobuf.ByteString + getMessageBytes() { + java.lang.Object ref = message_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + message_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string message = 2;</code> + */ + public Builder setMessage( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000002; + message_ = value; + onChanged(); + return this; + } + /** + * <code>required string message = 2;</code> + */ + public Builder clearMessage() { + bitField0_ = (bitField0_ & ~0x00000002); + message_ = getDefaultInstance().getMessage(); + onChanged(); + return this; + } + /** + * <code>required string message = 2;</code> + */ + public Builder setMessageBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000002; + message_ = value; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:CubeVisitResponse.ErrorInfo) + } + + static { + defaultInstance = new ErrorInfo(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:CubeVisitResponse.ErrorInfo) + } + + private int bitField0_; + // required bytes compressedRows = 1; + public static final int COMPRESSEDROWS_FIELD_NUMBER = 1; + private com.google.protobuf.ByteString compressedRows_; + /** + * <code>required bytes compressedRows = 1;</code> + */ + public boolean hasCompressedRows() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required bytes compressedRows = 1;</code> + */ + public com.google.protobuf.ByteString getCompressedRows() { + return compressedRows_; + } + + // required .CubeVisitResponse.Stats stats = 2; + public static final int STATS_FIELD_NUMBER = 2; + private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats stats_; + /** + * <code>required .CubeVisitResponse.Stats stats = 2;</code> + */ + public boolean hasStats() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required .CubeVisitResponse.Stats stats = 2;</code> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats getStats() { + return stats_; + } + /** + * <code>required .CubeVisitResponse.Stats stats = 2;</code> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.StatsOrBuilder getStatsOrBuilder() { + return stats_; + } + + // optional .CubeVisitResponse.ErrorInfo errorInfo = 3; + public static final int ERRORINFO_FIELD_NUMBER = 3; + private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo errorInfo_; + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public boolean hasErrorInfo() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo getErrorInfo() { + return errorInfo_; + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder getErrorInfoOrBuilder() { + return errorInfo_; + } + + private void initFields() { + compressedRows_ = com.google.protobuf.ByteString.EMPTY; + stats_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.Stats.getDefaultInstance(); + errorInfo_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance(); + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasCompressedRows()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasStats()) { + memoizedIsInitialized = 0; + return false; + } + if (hasErrorInfo()) { + if (!getErrorInfo().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + getSerializedSize(); + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeBytes(1, compressedRows_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeMessage(2, stats_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeMessage(3, errorInfo_); + } + getUnknownFields().writeTo(output); + } + + private int memoizedSerializedSize = -1; + public int getSerializedSize() { + int size = memoizedSerializedSize; + if (size != -1) return size; + + size = 0; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(1, compressedRows_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(2, stats_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(3, errorInfo_); + } + 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(); @@ -3860,6 +4662,11 @@ public final class CubeVisitProtos { result = result && getStats() .equals(other.getStats()); } + result = result && (hasErrorInfo() == other.hasErrorInfo()); + if (hasErrorInfo()) { + result = result && getErrorInfo() + .equals(other.getErrorInfo()); + } result = result && getUnknownFields().equals(other.getUnknownFields()); return result; @@ -3881,6 +4688,10 @@ public final class CubeVisitProtos { hash = (37 * hash) + STATS_FIELD_NUMBER; hash = (53 * hash) + getStats().hashCode(); } + if (hasErrorInfo()) { + hash = (37 * hash) + ERRORINFO_FIELD_NUMBER; + hash = (53 * hash) + getErrorInfo().hashCode(); + } hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -3983,6 +4794,7 @@ public final class CubeVisitProtos { private void maybeForceBuilderInitialization() { if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { getStatsFieldBuilder(); + getErrorInfoFieldBuilder(); } } private static Builder create() { @@ -3999,6 +4811,12 @@ public final class CubeVisitProtos { statsBuilder_.clear(); } bitField0_ = (bitField0_ & ~0x00000002); + if (errorInfoBuilder_ == null) { + errorInfo_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance(); + } else { + errorInfoBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000004); return this; } @@ -4039,6 +4857,14 @@ public final class CubeVisitProtos { } else { result.stats_ = statsBuilder_.build(); } + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + if (errorInfoBuilder_ == null) { + result.errorInfo_ = errorInfo_; + } else { + result.errorInfo_ = errorInfoBuilder_.build(); + } result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -4061,6 +4887,9 @@ public final class CubeVisitProtos { if (other.hasStats()) { mergeStats(other.getStats()); } + if (other.hasErrorInfo()) { + mergeErrorInfo(other.getErrorInfo()); + } this.mergeUnknownFields(other.getUnknownFields()); return this; } @@ -4074,6 +4903,12 @@ public final class CubeVisitProtos { return false; } + if (hasErrorInfo()) { + if (!getErrorInfo().isInitialized()) { + + return false; + } + } return true; } @@ -4249,6 +5084,159 @@ public final class CubeVisitProtos { return statsBuilder_; } + // optional .CubeVisitResponse.ErrorInfo errorInfo = 3; + private org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo errorInfo_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance(); + private com.google.protobuf.SingleFieldBuilder< + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder> errorInfoBuilder_; + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public boolean hasErrorInfo() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo getErrorInfo() { + if (errorInfoBuilder_ == null) { + return errorInfo_; + } else { + return errorInfoBuilder_.getMessage(); + } + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public Builder setErrorInfo(org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo value) { + if (errorInfoBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + errorInfo_ = value; + onChanged(); + } else { + errorInfoBuilder_.setMessage(value); + } + bitField0_ |= 0x00000004; + return this; + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public Builder setErrorInfo( + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder builderForValue) { + if (errorInfoBuilder_ == null) { + errorInfo_ = builderForValue.build(); + onChanged(); + } else { + errorInfoBuilder_.setMessage(builderForValue.build()); + } + bitField0_ |= 0x00000004; + return this; + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public Builder mergeErrorInfo(org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo value) { + if (errorInfoBuilder_ == null) { + if (((bitField0_ & 0x00000004) == 0x00000004) && + errorInfo_ != org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance()) { + errorInfo_ = + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.newBuilder(errorInfo_).mergeFrom(value).buildPartial(); + } else { + errorInfo_ = value; + } + onChanged(); + } else { + errorInfoBuilder_.mergeFrom(value); + } + bitField0_ |= 0x00000004; + return this; + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public Builder clearErrorInfo() { + if (errorInfoBuilder_ == null) { + errorInfo_ = org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.getDefaultInstance(); + onChanged(); + } else { + errorInfoBuilder_.clear(); + } + bitField0_ = (bitField0_ & ~0x00000004); + return this; + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder getErrorInfoBuilder() { + bitField0_ |= 0x00000004; + onChanged(); + return getErrorInfoFieldBuilder().getBuilder(); + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + public org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder getErrorInfoOrBuilder() { + if (errorInfoBuilder_ != null) { + return errorInfoBuilder_.getMessageOrBuilder(); + } else { + return errorInfo_; + } + } + /** + * <code>optional .CubeVisitResponse.ErrorInfo errorInfo = 3;</code> + * + * <pre> + * should be set when stats.normalComplete == false + * </pre> + */ + private com.google.protobuf.SingleFieldBuilder< + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder> + getErrorInfoFieldBuilder() { + if (errorInfoBuilder_ == null) { + errorInfoBuilder_ = new com.google.protobuf.SingleFieldBuilder< + org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfo.Builder, org.apache.kylin.storage.hbase.cube.v2.coprocessor.endpoint.generated.CubeVisitProtos.CubeVisitResponse.ErrorInfoOrBuilder>( + errorInfo_, + getParentForChildren(), + isClean()); + errorInfo_ = null; + } + return errorInfoBuilder_; + } + // @@protoc_insertion_point(builder_scope:CubeVisitResponse) } @@ -4512,6 +5500,11 @@ public final class CubeVisitProtos { private static com.google.protobuf.GeneratedMessage.FieldAccessorTable internal_static_CubeVisitResponse_Stats_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_CubeVisitResponse_ErrorInfo_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_CubeVisitResponse_ErrorInfo_fieldAccessorTable; public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { @@ -4530,20 +5523,25 @@ public final class CubeVisitProtos { "eVisitRequest.IntList\022\027\n\017kylinProperties" + "\030\005 \002(\t\022\017\n\007queryId\030\006 \001(\t\022\032\n\014spillEnabled\030" + "\007 \001(\010:\004true\022\024\n\014maxScanBytes\030\010 \001(\003\032\027\n\007Int" + - "List\022\014\n\004ints\030\001 \003(\005\"\347\002\n\021CubeVisitResponse", + "List\022\014\n\004ints\030\001 \003(\005\"\253\004\n\021CubeVisitResponse", "\022\026\n\016compressedRows\030\001 \002(\014\022\'\n\005stats\030\002 \002(\0132" + - "\030.CubeVisitResponse.Stats\032\220\002\n\005Stats\022\030\n\020s" + - "erviceStartTime\030\001 \001(\003\022\026\n\016serviceEndTime\030" + - "\002 \001(\003\022\027\n\017scannedRowCount\030\003 \001(\003\022\032\n\022aggreg" + - "atedRowCount\030\004 \001(\003\022\025\n\rsystemCpuLoad\030\005 \001(" + - "\001\022\036\n\026freePhysicalMemorySize\030\006 \001(\001\022\031\n\021fre" + - "eSwapSpaceSize\030\007 \001(\001\022\020\n\010hostname\030\010 \001(\t\022\016" + - "\n\006etcMsg\030\t \001(\t\022\026\n\016normalComplete\030\n \001(\005\022\024" + - "\n\014scannedBytes\030\013 \001(\0032F\n\020CubeVisitService" + - "\0222\n\tvisitCube\022\021.CubeVisitRequest\032\022.CubeV", - "isitResponseB`\nEorg.apache.kylin.storage" + - ".hbase.cube.v2.coprocessor.endpoint.gene" + - "ratedB\017CubeVisitProtosH\001\210\001\001\240\001\001" + "\030.CubeVisitResponse.Stats\022/\n\terrorInfo\030\003" + + " \001(\0132\034.CubeVisitResponse.ErrorInfo\032\220\002\n\005S" + + "tats\022\030\n\020serviceStartTime\030\001 \001(\003\022\026\n\016servic" + + "eEndTime\030\002 \001(\003\022\027\n\017scannedRowCount\030\003 \001(\003\022" + + "\032\n\022aggregatedRowCount\030\004 \001(\003\022\025\n\rsystemCpu" + + "Load\030\005 \001(\001\022\036\n\026freePhysicalMemorySize\030\006 \001" + + "(\001\022\031\n\021freeSwapSpaceSize\030\007 \001(\001\022\020\n\010hostnam" + + "e\030\010 \001(\t\022\016\n\006etcMsg\030\t \001(\t\022\026\n\016normalComplet" + + "e\030\n \001(\005\022\024\n\014scannedBytes\030\013 \001(\003\032H\n\tErrorIn", + "fo\022*\n\004type\030\001 \002(\0162\034.CubeVisitResponse.Err" + + "orType\022\017\n\007message\030\002 \002(\t\"G\n\tErrorType\022\020\n\014" + + "UNKNOWN_TYPE\020\000\022\013\n\007TIMEOUT\020\001\022\033\n\027RESOURCE_" + + "LIMIT_EXCEEDED\020\0022F\n\020CubeVisitService\0222\n\t" + + "visitCube\022\021.CubeVisitRequest\032\022.CubeVisit" + + "ResponseB`\nEorg.apache.kylin.storage.hba" + + "se.cube.v2.coprocessor.endpoint.generate" + + "dB\017CubeVisitProtosH\001\210\001\001\240\001\001" }; com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { @@ -4567,13 +5565,19 @@ public final class CubeVisitProtos { internal_static_CubeVisitResponse_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CubeVisitResponse_descriptor, - new java.lang.String[] { "CompressedRows", "Stats", }); + new java.lang.String[] { "CompressedRows", "Stats", "ErrorInfo", }); internal_static_CubeVisitResponse_Stats_descriptor = internal_static_CubeVisitResponse_descriptor.getNestedTypes().get(0); internal_static_CubeVisitResponse_Stats_fieldAccessorTable = new com.google.protobuf.GeneratedMessage.FieldAccessorTable( internal_static_CubeVisitResponse_Stats_descriptor, new java.lang.String[] { "ServiceStartTime", "ServiceEndTime", "ScannedRowCount", "AggregatedRowCount", "SystemCpuLoad", "FreePhysicalMemorySize", "FreeSwapSpaceSize", "Hostname", "EtcMsg", "NormalComplete", "ScannedBytes", }); + internal_static_CubeVisitResponse_ErrorInfo_descriptor = + internal_static_CubeVisitResponse_descriptor.getNestedTypes().get(1); + internal_static_CubeVisitResponse_ErrorInfo_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_CubeVisitResponse_ErrorInfo_descriptor, + new java.lang.String[] { "Type", "Message", }); return null; } }; http://git-wip-us.apache.org/repos/asf/kylin/blob/43c05667/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/protobuf/CubeVisit.proto ---------------------------------------------------------------------- diff --git a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/protobuf/CubeVisit.proto b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/protobuf/CubeVisit.proto index 00015fc..e01ff52 100644 --- a/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/protobuf/CubeVisit.proto +++ b/storage-hbase/src/main/java/org/apache/kylin/storage/hbase/cube/v2/coprocessor/endpoint/protobuf/CubeVisit.proto @@ -54,11 +54,21 @@ message CubeVisitResponse { optional double freeSwapSpaceSize = 7; optional string hostname = 8; optional string etcMsg = 9; - optional int32 normalComplete =10;//when time outs, normalComplete will be false + optional int32 normalComplete =10; optional int64 scannedBytes = 11; } + enum ErrorType { + UNKNOWN_TYPE = 0; + TIMEOUT = 1; + RESOURCE_LIMIT_EXCEEDED = 2; + } + message ErrorInfo { + required ErrorType type = 1; + required string message = 2; + } required bytes compressedRows = 1; required Stats stats = 2; + optional ErrorInfo errorInfo = 3; // should be set when stats.normalComplete == false } service CubeVisitService {
