http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c7ff99b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/ServerCachingProtocol.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/ServerCachingProtocol.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/ServerCachingProtocol.java index b201c8e..139a69c 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/ServerCachingProtocol.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/ServerCachingProtocol.java @@ -36,7 +36,7 @@ import org.apache.phoenix.memory.MemoryManager.MemoryChunk; */ public interface ServerCachingProtocol { public static interface ServerCacheFactory extends Writable { - public Closeable newCache(ImmutableBytesWritable cachePtr, byte[] txState, MemoryChunk chunk) throws SQLException; + public Closeable newCache(ImmutableBytesWritable cachePtr, byte[] txState, MemoryChunk chunk, boolean useProtoForIndexMaintainer) throws SQLException; } /** * Add the cache to the region server cache.
http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c7ff99b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java ---------------------------------------------------------------------- diff --git a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java index db3c792..c5854d3 100644 --- a/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java +++ b/phoenix-core/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java @@ -101,7 +101,10 @@ import org.apache.phoenix.schema.ValueSchema.Field; import org.apache.phoenix.schema.stats.StatisticsCollectionRunTracker; import org.apache.phoenix.schema.stats.StatisticsCollector; import org.apache.phoenix.schema.stats.StatisticsCollectorFactory; +import org.apache.phoenix.schema.tuple.EncodedColumnQualiferCellsList; import org.apache.phoenix.schema.tuple.MultiKeyValueTuple; +import org.apache.phoenix.schema.tuple.PositionBasedMultiKeyValueTuple; +import org.apache.phoenix.schema.tuple.Tuple; import org.apache.phoenix.schema.types.PBinary; import org.apache.phoenix.schema.types.PChar; import org.apache.phoenix.schema.types.PDataType; @@ -109,6 +112,7 @@ import org.apache.phoenix.schema.types.PDouble; import org.apache.phoenix.schema.types.PFloat; import org.apache.phoenix.schema.types.PLong; import org.apache.phoenix.util.ByteUtil; +import org.apache.phoenix.util.EncodedColumnsUtil; import org.apache.phoenix.util.IndexUtil; import org.apache.phoenix.util.KeyValueUtil; import org.apache.phoenix.util.LogUtil; @@ -181,9 +185,9 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } private void commitBatch(Region region, List<Mutation> mutations, byte[] indexUUID, long blockingMemstoreSize, - byte[] indexMaintainersPtr, byte[] txState) throws IOException { + byte[] indexMaintainersPtr, byte[] txState, boolean useIndexProto) throws IOException { if (indexMaintainersPtr != null) { - mutations.get(0).setAttribute(PhoenixIndexCodec.INDEX_MD, indexMaintainersPtr); + mutations.get(0).setAttribute(useIndexProto ? PhoenixIndexCodec.INDEX_PROTO_MD : PhoenixIndexCodec.INDEX_MD, indexMaintainersPtr); } if (txState != null) { @@ -213,13 +217,13 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } private void commitBatchWithHTable(HTable table, Region region, List<Mutation> mutations, byte[] indexUUID, - long blockingMemstoreSize, byte[] indexMaintainersPtr, byte[] txState) throws IOException { + long blockingMemstoreSize, byte[] indexMaintainersPtr, byte[] txState, boolean useIndexProto) throws IOException { if (indexUUID != null) { // Need to add indexMaintainers for each mutation as table.batch can be distributed across servers for (Mutation m : mutations) { if (indexMaintainersPtr != null) { - m.setAttribute(PhoenixIndexCodec.INDEX_MD, indexMaintainersPtr); + m.setAttribute(useIndexProto ? PhoenixIndexCodec.INDEX_PROTO_MD : PhoenixIndexCodec.INDEX_MD, indexMaintainersPtr); } if (txState != null) { m.setAttribute(BaseScannerRegionObserver.TX_STATE, txState); @@ -328,8 +332,13 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } values = new byte[projectedTable.getPKColumns().size()][]; } - byte[] localIndexBytes = scan.getAttribute(LOCAL_INDEX_BUILD); - List<IndexMaintainer> indexMaintainers = localIndexBytes == null ? null : IndexMaintainer.deserialize(localIndexBytes); + boolean useProto = false; + byte[] localIndexBytes = scan.getAttribute(LOCAL_INDEX_BUILD_PROTO); + useProto = localIndexBytes != null; + if (localIndexBytes == null) { + localIndexBytes = scan.getAttribute(LOCAL_INDEX_BUILD); + } + List<IndexMaintainer> indexMaintainers = localIndexBytes == null ? null : IndexMaintainer.deserialize(localIndexBytes, useProto); List<Mutation> indexMutations = localIndexBytes == null ? Collections.<Mutation>emptyList() : Lists.<Mutation>newArrayListWithExpectedSize(1024); RegionScanner theScanner = s; @@ -370,6 +379,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver ColumnReference[] dataColumns = IndexUtil.deserializeDataTableColumnsToJoin(scan); final TupleProjector p = TupleProjector.deserializeProjectorFromScan(scan); final HashJoinInfo j = HashJoinInfo.deserializeHashJoinFromScan(scan); + boolean useQualifierAsIndex = EncodedColumnsUtil.useQualifierAsIndex(EncodedColumnsUtil.getMinMaxQualifiersFromScan(scan)); if ((localIndexScan && !isDelete && !isDescRowKeyOrderUpgrade) || (j == null && p != null)) { if (dataColumns != null) { tupleProjector = IndexUtil.getTupleProjector(scan, dataColumns); @@ -378,11 +388,11 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver ImmutableBytesWritable tempPtr = new ImmutableBytesWritable(); theScanner = getWrappedScanner(c, theScanner, offset, scan, dataColumns, tupleProjector, - region, indexMaintainers == null ? null : indexMaintainers.get(0), viewConstants, p, tempPtr); + region, indexMaintainers == null ? null : indexMaintainers.get(0), viewConstants, p, tempPtr, useQualifierAsIndex); } if (j != null) { - theScanner = new HashJoinRegionScanner(theScanner, p, j, ScanUtil.getTenantId(scan), env); + theScanner = new HashJoinRegionScanner(theScanner, p, j, ScanUtil.getTenantId(scan), env, useQualifierAsIndex, useNewValueColumnQualifier); } int batchSize = 0; @@ -421,13 +431,20 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver Aggregator[] rowAggregators = aggregators.getAggregators(); boolean hasMore; boolean hasAny = false; - MultiKeyValueTuple result = new MultiKeyValueTuple(); + Pair<Integer, Integer> minMaxQualifiers = EncodedColumnsUtil.getMinMaxQualifiersFromScan(scan); + Tuple result = useQualifierAsIndex ? new PositionBasedMultiKeyValueTuple() : new MultiKeyValueTuple(); if (logger.isDebugEnabled()) { logger.debug(LogUtil.addCustomAnnotations("Starting ungrouped coprocessor scan " + scan + " "+region.getRegionInfo(), ScanUtil.getCustomAnnotations(scan))); } long rowCount = 0; final RegionScanner innerScanner = theScanner; - byte[] indexMaintainersPtr = scan.getAttribute(PhoenixIndexCodec.INDEX_MD); + boolean useIndexProto = true; + byte[] indexMaintainersPtr = scan.getAttribute(PhoenixIndexCodec.INDEX_PROTO_MD); + // for backward compatiblity fall back to look by the old attribute + if (indexMaintainersPtr == null) { + indexMaintainersPtr = scan.getAttribute(PhoenixIndexCodec.INDEX_MD); + useIndexProto = false; + } boolean acquiredLock = false; try { if(needToWrite) { @@ -439,7 +456,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver acquiredLock = true; synchronized (innerScanner) { do { - List<Cell> results = new ArrayList<Cell>(); + List<Cell> results = useQualifierAsIndex ? new EncodedColumnQualiferCellsList(minMaxQualifiers.getFirst(), minMaxQualifiers.getSecond(), encodingScheme) : new ArrayList<Cell>(); // Results are potentially returned even when the return value of s.next is false // since this is an indication of whether or not there are more values after the // ones returned @@ -654,7 +671,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver MutationState.getMutationBatchList(batchSize, batchSizeBytes, mutations); for (List<Mutation> batchMutations : batchMutationList) { commit(region, batchMutations, indexUUID, blockingMemStoreSize, indexMaintainersPtr, - txState, areMutationInSameRegion, targetHTable); + txState, areMutationInSameRegion, targetHTable, useIndexProto); batchMutations.clear(); } mutations.clear(); @@ -662,7 +679,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver List<List<Mutation>> batchIndexMutationList = MutationState.getMutationBatchList(batchSize, batchSizeBytes, indexMutations); for (List<Mutation> batchIndexMutations : batchIndexMutationList) { - commitBatch(region, batchIndexMutations, null, blockingMemStoreSize, null, txState); + commitBatch(region, batchIndexMutations, null, blockingMemStoreSize, null, txState, useIndexProto); batchIndexMutations.clear(); } indexMutations.clear(); @@ -673,12 +690,12 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } while (hasMore); if (!mutations.isEmpty()) { commit(region, mutations, indexUUID, blockingMemStoreSize, indexMaintainersPtr, txState, - areMutationInSameRegion, targetHTable); + areMutationInSameRegion, targetHTable, useIndexProto); mutations.clear(); } if (!indexMutations.isEmpty()) { - commitBatch(region, indexMutations, null, blockingMemStoreSize, indexMaintainersPtr, txState); + commitBatch(region, indexMutations, null, blockingMemStoreSize, indexMaintainersPtr, txState, useIndexProto); indexMutations.clear(); } } @@ -735,14 +752,14 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } private void commit(Region region, List<Mutation> mutations, byte[] indexUUID, long blockingMemstoreSize, - byte[] indexMaintainersPtr, byte[] txState, boolean areMutationsForSameRegion, HTable hTable) + byte[] indexMaintainersPtr, byte[] txState, boolean areMutationsForSameRegion, HTable hTable, boolean useIndexProto) throws IOException { if (!areMutationsForSameRegion) { assert hTable != null;// table cannot be null commitBatchWithHTable(hTable, region, mutations, indexUUID, blockingMemstoreSize, indexMaintainersPtr, - txState); + txState, useIndexProto); } else { - commitBatch(region, mutations, indexUUID, blockingMemstoreSize, indexMaintainersPtr, txState); + commitBatch(region, mutations, indexUUID, blockingMemstoreSize, indexMaintainersPtr, txState, useIndexProto); } } @@ -804,7 +821,13 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver private RegionScanner rebuildIndices(final RegionScanner innerScanner, final Region region, final Scan scan, Configuration config) throws IOException { - byte[] indexMetaData = scan.getAttribute(PhoenixIndexCodec.INDEX_MD); + byte[] indexMetaData = scan.getAttribute(PhoenixIndexCodec.INDEX_PROTO_MD); + boolean useProto = true; + // for backward compatibility fall back to look up by the old attribute + if (indexMetaData == null) { + useProto = false; + indexMetaData = scan.getAttribute(PhoenixIndexCodec.INDEX_MD); + } boolean hasMore; long rowCount = 0; try { @@ -824,7 +847,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver if (KeyValue.Type.codeToType(cell.getTypeByte()) == KeyValue.Type.Put) { if (put == null) { put = new Put(CellUtil.cloneRow(cell)); - put.setAttribute(PhoenixIndexCodec.INDEX_MD, indexMetaData); + put.setAttribute(useProto ? PhoenixIndexCodec.INDEX_PROTO_MD : PhoenixIndexCodec.INDEX_MD, indexMetaData); put.setAttribute(PhoenixIndexCodec.INDEX_UUID, uuidValue); put.setAttribute(BaseScannerRegionObserver.IGNORE_NEWER_MUTATIONS, PDataType.TRUE_BYTES); @@ -834,7 +857,7 @@ public class UngroupedAggregateRegionObserver extends BaseScannerRegionObserver } else { if (del == null) { del = new Delete(CellUtil.cloneRow(cell)); - del.setAttribute(PhoenixIndexCodec.INDEX_MD, indexMetaData); + del.setAttribute(useProto ? PhoenixIndexCodec.INDEX_PROTO_MD : PhoenixIndexCodec.INDEX_MD, indexMetaData); del.setAttribute(PhoenixIndexCodec.INDEX_UUID, uuidValue); del.setAttribute(BaseScannerRegionObserver.IGNORE_NEWER_MUTATIONS, PDataType.TRUE_BYTES); http://git-wip-us.apache.org/repos/asf/phoenix/blob/3c7ff99b/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 b8b8b2f..b7ca46f 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 @@ -269,6 +269,16 @@ public final class PTableProtos { * <code>optional bool isDynamic = 14;</code> */ boolean getIsDynamic(); + + // optional bytes columnQualifierBytes = 15; + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + boolean hasColumnQualifierBytes(); + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + com.google.protobuf.ByteString getColumnQualifierBytes(); } /** * Protobuf type {@code PColumn} @@ -391,6 +401,11 @@ public final class PTableProtos { isDynamic_ = input.readBool(); break; } + case 122: { + bitField0_ |= 0x00004000; + columnQualifierBytes_ = input.readBytes(); + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -709,6 +724,22 @@ public final class PTableProtos { return isDynamic_; } + // optional bytes columnQualifierBytes = 15; + public static final int COLUMNQUALIFIERBYTES_FIELD_NUMBER = 15; + private com.google.protobuf.ByteString columnQualifierBytes_; + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public boolean hasColumnQualifierBytes() { + return ((bitField0_ & 0x00004000) == 0x00004000); + } + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public com.google.protobuf.ByteString getColumnQualifierBytes() { + return columnQualifierBytes_; + } + private void initFields() { columnNameBytes_ = com.google.protobuf.ByteString.EMPTY; familyNameBytes_ = com.google.protobuf.ByteString.EMPTY; @@ -724,6 +755,7 @@ public final class PTableProtos { expression_ = ""; isRowTimestamp_ = false; isDynamic_ = false; + columnQualifierBytes_ = com.google.protobuf.ByteString.EMPTY; } private byte memoizedIsInitialized = -1; public final boolean isInitialized() { @@ -799,6 +831,9 @@ public final class PTableProtos { if (((bitField0_ & 0x00002000) == 0x00002000)) { output.writeBool(14, isDynamic_); } + if (((bitField0_ & 0x00004000) == 0x00004000)) { + output.writeBytes(15, columnQualifierBytes_); + } getUnknownFields().writeTo(output); } @@ -864,6 +899,10 @@ public final class PTableProtos { size += com.google.protobuf.CodedOutputStream .computeBoolSize(14, isDynamic_); } + if (((bitField0_ & 0x00004000) == 0x00004000)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(15, columnQualifierBytes_); + } size += getUnknownFields().getSerializedSize(); memoizedSerializedSize = size; return size; @@ -957,6 +996,11 @@ public final class PTableProtos { result = result && (getIsDynamic() == other.getIsDynamic()); } + result = result && (hasColumnQualifierBytes() == other.hasColumnQualifierBytes()); + if (hasColumnQualifierBytes()) { + result = result && getColumnQualifierBytes() + .equals(other.getColumnQualifierBytes()); + } result = result && getUnknownFields().equals(other.getUnknownFields()); return result; @@ -1026,6 +1070,10 @@ public final class PTableProtos { hash = (37 * hash) + ISDYNAMIC_FIELD_NUMBER; hash = (53 * hash) + hashBoolean(getIsDynamic()); } + if (hasColumnQualifierBytes()) { + hash = (37 * hash) + COLUMNQUALIFIERBYTES_FIELD_NUMBER; + hash = (53 * hash) + getColumnQualifierBytes().hashCode(); + } hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -1163,6 +1211,8 @@ public final class PTableProtos { bitField0_ = (bitField0_ & ~0x00001000); isDynamic_ = false; bitField0_ = (bitField0_ & ~0x00002000); + columnQualifierBytes_ = com.google.protobuf.ByteString.EMPTY; + bitField0_ = (bitField0_ & ~0x00004000); return this; } @@ -1247,6 +1297,10 @@ public final class PTableProtos { to_bitField0_ |= 0x00002000; } result.isDynamic_ = isDynamic_; + if (((from_bitField0_ & 0x00004000) == 0x00004000)) { + to_bitField0_ |= 0x00004000; + } + result.columnQualifierBytes_ = columnQualifierBytes_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1309,6 +1363,9 @@ public final class PTableProtos { if (other.hasIsDynamic()) { setIsDynamic(other.getIsDynamic()); } + if (other.hasColumnQualifierBytes()) { + setColumnQualifierBytes(other.getColumnQualifierBytes()); + } this.mergeUnknownFields(other.getUnknownFields()); return this; } @@ -1909,6 +1966,42 @@ public final class PTableProtos { return this; } + // optional bytes columnQualifierBytes = 15; + private com.google.protobuf.ByteString columnQualifierBytes_ = com.google.protobuf.ByteString.EMPTY; + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public boolean hasColumnQualifierBytes() { + return ((bitField0_ & 0x00004000) == 0x00004000); + } + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public com.google.protobuf.ByteString getColumnQualifierBytes() { + return columnQualifierBytes_; + } + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public Builder setColumnQualifierBytes(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00004000; + columnQualifierBytes_ = value; + onChanged(); + return this; + } + /** + * <code>optional bytes columnQualifierBytes = 15;</code> + */ + public Builder clearColumnQualifierBytes() { + bitField0_ = (bitField0_ & ~0x00004000); + columnQualifierBytes_ = getDefaultInstance().getColumnQualifierBytes(); + onChanged(); + return this; + } + // @@protoc_insertion_point(builder_scope:PColumn) } @@ -3372,6 +3465,51 @@ public final class PTableProtos { * <code>optional bytes parentNameBytes = 33;</code> */ com.google.protobuf.ByteString getParentNameBytes(); + + // optional bytes storageScheme = 34; + /** + * <code>optional bytes storageScheme = 34;</code> + */ + boolean hasStorageScheme(); + /** + * <code>optional bytes storageScheme = 34;</code> + */ + com.google.protobuf.ByteString getStorageScheme(); + + // optional bytes encodingScheme = 35; + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + boolean hasEncodingScheme(); + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + com.google.protobuf.ByteString getEncodingScheme(); + + // repeated .EncodedCQCounter encodedCQCounters = 36; + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> + getEncodedCQCountersList(); + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter getEncodedCQCounters(int index); + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + int getEncodedCQCountersCount(); + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + java.util.List<? extends org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder> + getEncodedCQCountersOrBuilderList(); + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder getEncodedCQCountersOrBuilder( + int index); } /** * Protobuf type {@code PTable} @@ -3407,6 +3545,7 @@ public final class PTableProtos { throws com.google.protobuf.InvalidProtocolBufferException { initFields(); int mutable_bitField0_ = 0; + int mutable_bitField1_ = 0; com.google.protobuf.UnknownFieldSet.Builder unknownFields = com.google.protobuf.UnknownFieldSet.newBuilder(); try { @@ -3599,6 +3738,24 @@ public final class PTableProtos { parentNameBytes_ = input.readBytes(); break; } + case 274: { + bitField0_ |= 0x20000000; + storageScheme_ = input.readBytes(); + break; + } + case 282: { + bitField0_ |= 0x40000000; + encodingScheme_ = input.readBytes(); + break; + } + case 290: { + if (!((mutable_bitField1_ & 0x00000004) == 0x00000004)) { + encodedCQCounters_ = new java.util.ArrayList<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter>(); + mutable_bitField1_ |= 0x00000004; + } + encodedCQCounters_.add(input.readMessage(org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.PARSER, extensionRegistry)); + break; + } } } } catch (com.google.protobuf.InvalidProtocolBufferException e) { @@ -3616,6 +3773,9 @@ public final class PTableProtos { if (((mutable_bitField0_ & 0x00020000) == 0x00020000)) { physicalNames_ = java.util.Collections.unmodifiableList(physicalNames_); } + if (((mutable_bitField1_ & 0x00000004) == 0x00000004)) { + encodedCQCounters_ = java.util.Collections.unmodifiableList(encodedCQCounters_); + } this.unknownFields = unknownFields.build(); makeExtensionsImmutable(); } @@ -4275,6 +4435,74 @@ public final class PTableProtos { return parentNameBytes_; } + // optional bytes storageScheme = 34; + public static final int STORAGESCHEME_FIELD_NUMBER = 34; + private com.google.protobuf.ByteString storageScheme_; + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public boolean hasStorageScheme() { + return ((bitField0_ & 0x20000000) == 0x20000000); + } + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public com.google.protobuf.ByteString getStorageScheme() { + return storageScheme_; + } + + // optional bytes encodingScheme = 35; + public static final int ENCODINGSCHEME_FIELD_NUMBER = 35; + private com.google.protobuf.ByteString encodingScheme_; + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public boolean hasEncodingScheme() { + return ((bitField0_ & 0x40000000) == 0x40000000); + } + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public com.google.protobuf.ByteString getEncodingScheme() { + return encodingScheme_; + } + + // repeated .EncodedCQCounter encodedCQCounters = 36; + public static final int ENCODEDCQCOUNTERS_FIELD_NUMBER = 36; + private java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> encodedCQCounters_; + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> getEncodedCQCountersList() { + return encodedCQCounters_; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public java.util.List<? extends org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder> + getEncodedCQCountersOrBuilderList() { + return encodedCQCounters_; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public int getEncodedCQCountersCount() { + return encodedCQCounters_.size(); + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter getEncodedCQCounters(int index) { + return encodedCQCounters_.get(index); + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder getEncodedCQCountersOrBuilder( + int index) { + return encodedCQCounters_.get(index); + } + private void initFields() { schemaNameBytes_ = com.google.protobuf.ByteString.EMPTY; tableNameBytes_ = com.google.protobuf.ByteString.EMPTY; @@ -4308,6 +4536,9 @@ public final class PTableProtos { autoParititonSeqName_ = ""; isAppendOnlySchema_ = false; parentNameBytes_ = com.google.protobuf.ByteString.EMPTY; + storageScheme_ = com.google.protobuf.ByteString.EMPTY; + encodingScheme_ = com.google.protobuf.ByteString.EMPTY; + encodedCQCounters_ = java.util.Collections.emptyList(); } private byte memoizedIsInitialized = -1; public final boolean isInitialized() { @@ -4362,6 +4593,12 @@ public final class PTableProtos { return false; } } + for (int i = 0; i < getEncodedCQCountersCount(); i++) { + if (!getEncodedCQCounters(i).isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + } memoizedIsInitialized = 1; return true; } @@ -4465,6 +4702,15 @@ public final class PTableProtos { if (((bitField0_ & 0x10000000) == 0x10000000)) { output.writeBytes(33, parentNameBytes_); } + if (((bitField0_ & 0x20000000) == 0x20000000)) { + output.writeBytes(34, storageScheme_); + } + if (((bitField0_ & 0x40000000) == 0x40000000)) { + output.writeBytes(35, encodingScheme_); + } + for (int i = 0; i < encodedCQCounters_.size(); i++) { + output.writeMessage(36, encodedCQCounters_.get(i)); + } getUnknownFields().writeTo(output); } @@ -4607,6 +4853,18 @@ public final class PTableProtos { size += com.google.protobuf.CodedOutputStream .computeBytesSize(33, parentNameBytes_); } + if (((bitField0_ & 0x20000000) == 0x20000000)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(34, storageScheme_); + } + if (((bitField0_ & 0x40000000) == 0x40000000)) { + size += com.google.protobuf.CodedOutputStream + .computeBytesSize(35, encodingScheme_); + } + for (int i = 0; i < encodedCQCounters_.size(); i++) { + size += com.google.protobuf.CodedOutputStream + .computeMessageSize(36, encodedCQCounters_.get(i)); + } size += getUnknownFields().getSerializedSize(); memoizedSerializedSize = size; return size; @@ -4781,6 +5039,18 @@ public final class PTableProtos { result = result && getParentNameBytes() .equals(other.getParentNameBytes()); } + result = result && (hasStorageScheme() == other.hasStorageScheme()); + if (hasStorageScheme()) { + result = result && getStorageScheme() + .equals(other.getStorageScheme()); + } + result = result && (hasEncodingScheme() == other.hasEncodingScheme()); + if (hasEncodingScheme()) { + result = result && getEncodingScheme() + .equals(other.getEncodingScheme()); + } + result = result && getEncodedCQCountersList() + .equals(other.getEncodedCQCountersList()); result = result && getUnknownFields().equals(other.getUnknownFields()); return result; @@ -4922,6 +5192,18 @@ public final class PTableProtos { hash = (37 * hash) + PARENTNAMEBYTES_FIELD_NUMBER; hash = (53 * hash) + getParentNameBytes().hashCode(); } + if (hasStorageScheme()) { + hash = (37 * hash) + STORAGESCHEME_FIELD_NUMBER; + hash = (53 * hash) + getStorageScheme().hashCode(); + } + if (hasEncodingScheme()) { + hash = (37 * hash) + ENCODINGSCHEME_FIELD_NUMBER; + hash = (53 * hash) + getEncodingScheme().hashCode(); + } + if (getEncodedCQCountersCount() > 0) { + hash = (37 * hash) + ENCODEDCQCOUNTERS_FIELD_NUMBER; + hash = (53 * hash) + getEncodedCQCountersList().hashCode(); + } hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -5025,6 +5307,7 @@ public final class PTableProtos { if (com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders) { getColumnsFieldBuilder(); getIndexesFieldBuilder(); + getEncodedCQCountersFieldBuilder(); } } private static Builder create() { @@ -5105,6 +5388,16 @@ public final class PTableProtos { bitField0_ = (bitField0_ & ~0x40000000); parentNameBytes_ = com.google.protobuf.ByteString.EMPTY; bitField0_ = (bitField0_ & ~0x80000000); + storageScheme_ = com.google.protobuf.ByteString.EMPTY; + bitField1_ = (bitField1_ & ~0x00000001); + encodingScheme_ = com.google.protobuf.ByteString.EMPTY; + bitField1_ = (bitField1_ & ~0x00000002); + if (encodedCQCountersBuilder_ == null) { + encodedCQCounters_ = java.util.Collections.emptyList(); + bitField1_ = (bitField1_ & ~0x00000004); + } else { + encodedCQCountersBuilder_.clear(); + } return this; } @@ -5132,6 +5425,7 @@ public final class PTableProtos { public org.apache.phoenix.coprocessor.generated.PTableProtos.PTable buildPartial() { org.apache.phoenix.coprocessor.generated.PTableProtos.PTable result = new org.apache.phoenix.coprocessor.generated.PTableProtos.PTable(this); int from_bitField0_ = bitField0_; + int from_bitField1_ = bitField1_; int to_bitField0_ = 0; if (((from_bitField0_ & 0x00000001) == 0x00000001)) { to_bitField0_ |= 0x00000001; @@ -5272,6 +5566,23 @@ public final class PTableProtos { to_bitField0_ |= 0x10000000; } result.parentNameBytes_ = parentNameBytes_; + if (((from_bitField1_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x20000000; + } + result.storageScheme_ = storageScheme_; + if (((from_bitField1_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x40000000; + } + result.encodingScheme_ = encodingScheme_; + if (encodedCQCountersBuilder_ == null) { + if (((bitField1_ & 0x00000004) == 0x00000004)) { + encodedCQCounters_ = java.util.Collections.unmodifiableList(encodedCQCounters_); + bitField1_ = (bitField1_ & ~0x00000004); + } + result.encodedCQCounters_ = encodedCQCounters_; + } else { + result.encodedCQCounters_ = encodedCQCountersBuilder_.build(); + } result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -5441,6 +5752,38 @@ public final class PTableProtos { if (other.hasParentNameBytes()) { setParentNameBytes(other.getParentNameBytes()); } + if (other.hasStorageScheme()) { + setStorageScheme(other.getStorageScheme()); + } + if (other.hasEncodingScheme()) { + setEncodingScheme(other.getEncodingScheme()); + } + if (encodedCQCountersBuilder_ == null) { + if (!other.encodedCQCounters_.isEmpty()) { + if (encodedCQCounters_.isEmpty()) { + encodedCQCounters_ = other.encodedCQCounters_; + bitField1_ = (bitField1_ & ~0x00000004); + } else { + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.addAll(other.encodedCQCounters_); + } + onChanged(); + } + } else { + if (!other.encodedCQCounters_.isEmpty()) { + if (encodedCQCountersBuilder_.isEmpty()) { + encodedCQCountersBuilder_.dispose(); + encodedCQCountersBuilder_ = null; + encodedCQCounters_ = other.encodedCQCounters_; + bitField1_ = (bitField1_ & ~0x00000004); + encodedCQCountersBuilder_ = + com.google.protobuf.GeneratedMessage.alwaysUseFieldBuilders ? + getEncodedCQCountersFieldBuilder() : null; + } else { + encodedCQCountersBuilder_.addAllMessages(other.encodedCQCounters_); + } + } + } this.mergeUnknownFields(other.getUnknownFields()); return this; } @@ -5494,6 +5837,12 @@ public final class PTableProtos { return false; } } + for (int i = 0; i < getEncodedCQCountersCount(); i++) { + if (!getEncodedCQCounters(i).isInitialized()) { + + return false; + } + } return true; } @@ -5515,6 +5864,7 @@ public final class PTableProtos { return this; } private int bitField0_; + private int bitField1_; // required bytes schemaNameBytes = 1; private com.google.protobuf.ByteString schemaNameBytes_ = com.google.protobuf.ByteString.EMPTY; @@ -7168,101 +7518,1043 @@ public final class PTableProtos { return this; } - // @@protoc_insertion_point(builder_scope:PTable) - } - - static { - defaultInstance = new PTable(true); - defaultInstance.initFields(); - } + // optional bytes storageScheme = 34; + private com.google.protobuf.ByteString storageScheme_ = com.google.protobuf.ByteString.EMPTY; + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public boolean hasStorageScheme() { + return ((bitField1_ & 0x00000001) == 0x00000001); + } + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public com.google.protobuf.ByteString getStorageScheme() { + return storageScheme_; + } + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public Builder setStorageScheme(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField1_ |= 0x00000001; + storageScheme_ = value; + onChanged(); + return this; + } + /** + * <code>optional bytes storageScheme = 34;</code> + */ + public Builder clearStorageScheme() { + bitField1_ = (bitField1_ & ~0x00000001); + storageScheme_ = getDefaultInstance().getStorageScheme(); + onChanged(); + return this; + } - // @@protoc_insertion_point(class_scope:PTable) + // optional bytes encodingScheme = 35; + private com.google.protobuf.ByteString encodingScheme_ = com.google.protobuf.ByteString.EMPTY; + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public boolean hasEncodingScheme() { + return ((bitField1_ & 0x00000002) == 0x00000002); + } + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public com.google.protobuf.ByteString getEncodingScheme() { + return encodingScheme_; + } + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public Builder setEncodingScheme(com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); } + bitField1_ |= 0x00000002; + encodingScheme_ = value; + onChanged(); + return this; + } + /** + * <code>optional bytes encodingScheme = 35;</code> + */ + public Builder clearEncodingScheme() { + bitField1_ = (bitField1_ & ~0x00000002); + encodingScheme_ = getDefaultInstance().getEncodingScheme(); + onChanged(); + return this; + } - private static com.google.protobuf.Descriptors.Descriptor - internal_static_PColumn_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_PColumn_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_PTableStats_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_PTableStats_fieldAccessorTable; - private static com.google.protobuf.Descriptors.Descriptor - internal_static_PTable_descriptor; - private static - com.google.protobuf.GeneratedMessage.FieldAccessorTable - internal_static_PTable_fieldAccessorTable; + // repeated .EncodedCQCounter encodedCQCounters = 36; + private java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> encodedCQCounters_ = + java.util.Collections.emptyList(); + private void ensureEncodedCQCountersIsMutable() { + if (!((bitField1_ & 0x00000004) == 0x00000004)) { + encodedCQCounters_ = new java.util.ArrayList<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter>(encodedCQCounters_); + bitField1_ |= 0x00000004; + } + } - public static com.google.protobuf.Descriptors.FileDescriptor - getDescriptor() { - return descriptor; - } - private static com.google.protobuf.Descriptors.FileDescriptor - descriptor; - static { - java.lang.String[] descriptorData = { - "\n\014PTable.proto\032\021PGuidePosts.proto\"\246\002\n\007PC" + - "olumn\022\027\n\017columnNameBytes\030\001 \002(\014\022\027\n\017family" + - "NameBytes\030\002 \001(\014\022\020\n\010dataType\030\003 \002(\t\022\021\n\tmax" + - "Length\030\004 \001(\005\022\r\n\005scale\030\005 \001(\005\022\020\n\010nullable\030" + - "\006 \002(\010\022\020\n\010position\030\007 \002(\005\022\021\n\tsortOrder\030\010 \002" + - "(\005\022\021\n\tarraySize\030\t \001(\005\022\024\n\014viewConstant\030\n " + - "\001(\014\022\026\n\016viewReferenced\030\013 \001(\010\022\022\n\nexpressio" + - "n\030\014 \001(\t\022\026\n\016isRowTimestamp\030\r \001(\010\022\021\n\tisDyn" + - "amic\030\016 \001(\010\"\232\001\n\013PTableStats\022\013\n\003key\030\001 \002(\014\022" + - "\016\n\006values\030\002 \003(\014\022\033\n\023guidePostsByteCount\030\003", - " \001(\003\022\025\n\rkeyBytesCount\030\004 \001(\003\022\027\n\017guidePost" + - "sCount\030\005 \001(\005\022!\n\013pGuidePosts\030\006 \001(\0132\014.PGui" + - "dePosts\"\217\006\n\006PTable\022\027\n\017schemaNameBytes\030\001 " + - "\002(\014\022\026\n\016tableNameBytes\030\002 \002(\014\022\036\n\ttableType" + - "\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 \002" + - "(\003\022\023\n\013pkNameBytes\030\007 \001(\014\022\021\n\tbucketNum\030\010 \002" + - "(\005\022\031\n\007columns\030\t \003(\0132\010.PColumn\022\030\n\007indexes" + - "\030\n \003(\0132\007.PTable\022\027\n\017isImmutableRows\030\013 \002(\010" + - "\022\032\n\022dataTableNameBytes\030\r \001(\014\022\031\n\021defaultF", - "amilyName\030\016 \001(\014\022\022\n\ndisableWAL\030\017 \002(\010\022\023\n\013m" + - "ultiTenant\030\020 \002(\010\022\020\n\010viewType\030\021 \001(\014\022\025\n\rvi" + - "ewStatement\030\022 \001(\014\022\025\n\rphysicalNames\030\023 \003(\014" + - "\022\020\n\010tenantId\030\024 \001(\014\022\023\n\013viewIndexId\030\025 \001(\005\022" + - "\021\n\tindexType\030\026 \001(\014\022\026\n\016statsTimeStamp\030\027 \001" + - "(\003\022\022\n\nstoreNulls\030\030 \001(\010\022\027\n\017baseColumnCoun" + - "t\030\031 \001(\005\022\036\n\026rowKeyOrderOptimizable\030\032 \001(\010\022" + - "\025\n\rtransactional\030\033 \001(\010\022\034\n\024updateCacheFre" + - "quency\030\034 \001(\003\022\035\n\025indexDisableTimestamp\030\035 " + - "\001(\003\022\031\n\021isNamespaceMapped\030\036 \001(\010\022\034\n\024autoPa", - "rititonSeqName\030\037 \001(\t\022\032\n\022isAppendOnlySche" + - "ma\030 \001(\010\022\027\n\017parentNameBytes\030! \001(\014*A\n\nPTa" + - "bleType\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.phoen" + - "ix.coprocessor.generatedB\014PTableProtosH\001" + - "\210\001\001\240\001\001" - }; - com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = - new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { - public com.google.protobuf.ExtensionRegistry assignDescriptors( - com.google.protobuf.Descriptors.FileDescriptor root) { - descriptor = root; - internal_static_PColumn_descriptor = - getDescriptor().getMessageTypes().get(0); - internal_static_PColumn_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_PColumn_descriptor, - new java.lang.String[] { "ColumnNameBytes", "FamilyNameBytes", "DataType", "MaxLength", "Scale", "Nullable", "Position", "SortOrder", "ArraySize", "ViewConstant", "ViewReferenced", "Expression", "IsRowTimestamp", "IsDynamic", }); - internal_static_PTableStats_descriptor = - getDescriptor().getMessageTypes().get(1); - internal_static_PTableStats_fieldAccessorTable = new - com.google.protobuf.GeneratedMessage.FieldAccessorTable( - internal_static_PTableStats_descriptor, - new java.lang.String[] { "Key", "Values", "GuidePostsByteCount", "KeyBytesCount", "GuidePostsCount", "PGuidePosts", }); - internal_static_PTable_descriptor = - getDescriptor().getMessageTypes().get(2); - 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", "DataTableNameBytes", "DefaultFamilyName", "DisableWAL", "MultiTenant", "ViewType", "ViewStatement", "PhysicalNames", "TenantId", "ViewIndexId", "IndexType", "StatsTimeStamp", "StoreNulls", "BaseColumnCount", "RowKeyOrderOptimizable", "Transactional", "UpdateCacheFrequency", "IndexDisableTimestamp", "IsNamespaceMapped", "AutoParititonSeqName", "IsAppendOnlySchema", "ParentNameBytes", }); + private com.google.protobuf.RepeatedFieldBuilder< + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder> encodedCQCountersBuilder_; + + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> getEncodedCQCountersList() { + if (encodedCQCountersBuilder_ == null) { + return java.util.Collections.unmodifiableList(encodedCQCounters_); + } else { + return encodedCQCountersBuilder_.getMessageList(); + } + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public int getEncodedCQCountersCount() { + if (encodedCQCountersBuilder_ == null) { + return encodedCQCounters_.size(); + } else { + return encodedCQCountersBuilder_.getCount(); + } + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter getEncodedCQCounters(int index) { + if (encodedCQCountersBuilder_ == null) { + return encodedCQCounters_.get(index); + } else { + return encodedCQCountersBuilder_.getMessage(index); + } + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder setEncodedCQCounters( + int index, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter value) { + if (encodedCQCountersBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.set(index, value); + onChanged(); + } else { + encodedCQCountersBuilder_.setMessage(index, value); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder setEncodedCQCounters( + int index, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder builderForValue) { + if (encodedCQCountersBuilder_ == null) { + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.set(index, builderForValue.build()); + onChanged(); + } else { + encodedCQCountersBuilder_.setMessage(index, builderForValue.build()); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder addEncodedCQCounters(org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter value) { + if (encodedCQCountersBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.add(value); + onChanged(); + } else { + encodedCQCountersBuilder_.addMessage(value); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder addEncodedCQCounters( + int index, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter value) { + if (encodedCQCountersBuilder_ == null) { + if (value == null) { + throw new NullPointerException(); + } + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.add(index, value); + onChanged(); + } else { + encodedCQCountersBuilder_.addMessage(index, value); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder addEncodedCQCounters( + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder builderForValue) { + if (encodedCQCountersBuilder_ == null) { + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.add(builderForValue.build()); + onChanged(); + } else { + encodedCQCountersBuilder_.addMessage(builderForValue.build()); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder addEncodedCQCounters( + int index, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder builderForValue) { + if (encodedCQCountersBuilder_ == null) { + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.add(index, builderForValue.build()); + onChanged(); + } else { + encodedCQCountersBuilder_.addMessage(index, builderForValue.build()); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder addAllEncodedCQCounters( + java.lang.Iterable<? extends org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter> values) { + if (encodedCQCountersBuilder_ == null) { + ensureEncodedCQCountersIsMutable(); + super.addAll(values, encodedCQCounters_); + onChanged(); + } else { + encodedCQCountersBuilder_.addAllMessages(values); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder clearEncodedCQCounters() { + if (encodedCQCountersBuilder_ == null) { + encodedCQCounters_ = java.util.Collections.emptyList(); + bitField1_ = (bitField1_ & ~0x00000004); + onChanged(); + } else { + encodedCQCountersBuilder_.clear(); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public Builder removeEncodedCQCounters(int index) { + if (encodedCQCountersBuilder_ == null) { + ensureEncodedCQCountersIsMutable(); + encodedCQCounters_.remove(index); + onChanged(); + } else { + encodedCQCountersBuilder_.remove(index); + } + return this; + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder getEncodedCQCountersBuilder( + int index) { + return getEncodedCQCountersFieldBuilder().getBuilder(index); + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder getEncodedCQCountersOrBuilder( + int index) { + if (encodedCQCountersBuilder_ == null) { + return encodedCQCounters_.get(index); } else { + return encodedCQCountersBuilder_.getMessageOrBuilder(index); + } + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public java.util.List<? extends org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder> + getEncodedCQCountersOrBuilderList() { + if (encodedCQCountersBuilder_ != null) { + return encodedCQCountersBuilder_.getMessageOrBuilderList(); + } else { + return java.util.Collections.unmodifiableList(encodedCQCounters_); + } + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder addEncodedCQCountersBuilder() { + return getEncodedCQCountersFieldBuilder().addBuilder( + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.getDefaultInstance()); + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder addEncodedCQCountersBuilder( + int index) { + return getEncodedCQCountersFieldBuilder().addBuilder( + index, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.getDefaultInstance()); + } + /** + * <code>repeated .EncodedCQCounter encodedCQCounters = 36;</code> + */ + public java.util.List<org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder> + getEncodedCQCountersBuilderList() { + return getEncodedCQCountersFieldBuilder().getBuilderList(); + } + private com.google.protobuf.RepeatedFieldBuilder< + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder> + getEncodedCQCountersFieldBuilder() { + if (encodedCQCountersBuilder_ == null) { + encodedCQCountersBuilder_ = new com.google.protobuf.RepeatedFieldBuilder< + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder>( + encodedCQCounters_, + ((bitField1_ & 0x00000004) == 0x00000004), + getParentForChildren(), + isClean()); + encodedCQCounters_ = null; + } + return encodedCQCountersBuilder_; + } + + // @@protoc_insertion_point(builder_scope:PTable) + } + + static { + defaultInstance = new PTable(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:PTable) + } + + public interface EncodedCQCounterOrBuilder + extends com.google.protobuf.MessageOrBuilder { + + // required string colFamily = 1; + /** + * <code>required string colFamily = 1;</code> + */ + boolean hasColFamily(); + /** + * <code>required string colFamily = 1;</code> + */ + java.lang.String getColFamily(); + /** + * <code>required string colFamily = 1;</code> + */ + com.google.protobuf.ByteString + getColFamilyBytes(); + + // required int32 counter = 2; + /** + * <code>required int32 counter = 2;</code> + */ + boolean hasCounter(); + /** + * <code>required int32 counter = 2;</code> + */ + int getCounter(); + } + /** + * Protobuf type {@code EncodedCQCounter} + */ + public static final class EncodedCQCounter extends + com.google.protobuf.GeneratedMessage + implements EncodedCQCounterOrBuilder { + // Use EncodedCQCounter.newBuilder() to construct. + private EncodedCQCounter(com.google.protobuf.GeneratedMessage.Builder<?> builder) { + super(builder); + this.unknownFields = builder.getUnknownFields(); + } + private EncodedCQCounter(boolean noInit) { this.unknownFields = com.google.protobuf.UnknownFieldSet.getDefaultInstance(); } + + private static final EncodedCQCounter defaultInstance; + public static EncodedCQCounter getDefaultInstance() { + return defaultInstance; + } + + public EncodedCQCounter getDefaultInstanceForType() { + return defaultInstance; + } + + private final com.google.protobuf.UnknownFieldSet unknownFields; + @java.lang.Override + public final com.google.protobuf.UnknownFieldSet + getUnknownFields() { + return this.unknownFields; + } + private EncodedCQCounter( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + initFields(); + int mutable_bitField0_ = 0; + com.google.protobuf.UnknownFieldSet.Builder unknownFields = + com.google.protobuf.UnknownFieldSet.newBuilder(); + try { + boolean done = false; + while (!done) { + int tag = input.readTag(); + switch (tag) { + case 0: + done = true; + break; + default: { + if (!parseUnknownField(input, unknownFields, + extensionRegistry, tag)) { + done = true; + } + break; + } + case 10: { + bitField0_ |= 0x00000001; + colFamily_ = input.readBytes(); + break; + } + case 16: { + bitField0_ |= 0x00000002; + counter_ = input.readInt32(); + break; + } + } + } + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + throw e.setUnfinishedMessage(this); + } catch (java.io.IOException e) { + throw new com.google.protobuf.InvalidProtocolBufferException( + e.getMessage()).setUnfinishedMessage(this); + } finally { + this.unknownFields = unknownFields.build(); + makeExtensionsImmutable(); + } + } + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.internal_static_EncodedCQCounter_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.internal_static_EncodedCQCounter_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.class, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder.class); + } + + public static com.google.protobuf.Parser<EncodedCQCounter> PARSER = + new com.google.protobuf.AbstractParser<EncodedCQCounter>() { + public EncodedCQCounter parsePartialFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws com.google.protobuf.InvalidProtocolBufferException { + return new EncodedCQCounter(input, extensionRegistry); + } + }; + + @java.lang.Override + public com.google.protobuf.Parser<EncodedCQCounter> getParserForType() { + return PARSER; + } + + private int bitField0_; + // required string colFamily = 1; + public static final int COLFAMILY_FIELD_NUMBER = 1; + private java.lang.Object colFamily_; + /** + * <code>required string colFamily = 1;</code> + */ + public boolean hasColFamily() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string colFamily = 1;</code> + */ + public java.lang.String getColFamily() { + java.lang.Object ref = colFamily_; + 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()) { + colFamily_ = s; + } + return s; + } + } + /** + * <code>required string colFamily = 1;</code> + */ + public com.google.protobuf.ByteString + getColFamilyBytes() { + java.lang.Object ref = colFamily_; + if (ref instanceof java.lang.String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + colFamily_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + + // required int32 counter = 2; + public static final int COUNTER_FIELD_NUMBER = 2; + private int counter_; + /** + * <code>required int32 counter = 2;</code> + */ + public boolean hasCounter() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required int32 counter = 2;</code> + */ + public int getCounter() { + return counter_; + } + + private void initFields() { + colFamily_ = ""; + counter_ = 0; + } + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized != -1) return isInitialized == 1; + + if (!hasColFamily()) { + memoizedIsInitialized = 0; + return false; + } + if (!hasCounter()) { + 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, getColFamilyBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeInt32(2, counter_); + } + 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, getColFamilyBytes()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += com.google.protobuf.CodedOutputStream + .computeInt32Size(2, counter_); + } + size += getUnknownFields().getSerializedSize(); + memoizedSerializedSize = size; + return size; + } + + private static final long serialVersionUID = 0L; + @java.lang.Override + protected java.lang.Object writeReplace() + throws java.io.ObjectStreamException { + return super.writeReplace(); + } + + @java.lang.Override + public boolean equals(final java.lang.Object obj) { + if (obj == this) { + return true; + } + if (!(obj instanceof org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter)) { + return super.equals(obj); + } + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter other = (org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter) obj; + + boolean result = true; + result = result && (hasColFamily() == other.hasColFamily()); + if (hasColFamily()) { + result = result && getColFamily() + .equals(other.getColFamily()); + } + result = result && (hasCounter() == other.hasCounter()); + if (hasCounter()) { + result = result && (getCounter() + == other.getCounter()); + } + 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 (hasColFamily()) { + hash = (37 * hash) + COLFAMILY_FIELD_NUMBER; + hash = (53 * hash) + getColFamily().hashCode(); + } + if (hasCounter()) { + hash = (37 * hash) + COUNTER_FIELD_NUMBER; + hash = (53 * hash) + getCounter(); + } + hash = (29 * hash) + getUnknownFields().hashCode(); + memoizedHashCode = hash; + return hash; + } + + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter parseFrom( + com.google.protobuf.ByteString data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter 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.PTableProtos.EncodedCQCounter parseFrom(byte[] data) + throws com.google.protobuf.InvalidProtocolBufferException { + return PARSER.parseFrom(data); + } + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter 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.PTableProtos.EncodedCQCounter parseFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter 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.PTableProtos.EncodedCQCounter parseDelimitedFrom(java.io.InputStream input) + throws java.io.IOException { + return PARSER.parseDelimitedFrom(input); + } + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter 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.PTableProtos.EncodedCQCounter parseFrom( + com.google.protobuf.CodedInputStream input) + throws java.io.IOException { + return PARSER.parseFrom(input); + } + public static org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter parseFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + return PARSER.parseFrom(input, extensionRegistry); + } + + public static Builder newBuilder() { return Builder.create(); } + public Builder newBuilderForType() { return newBuilder(); } + public static Builder newBuilder(org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter 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 EncodedCQCounter} + */ + public static final class Builder extends + com.google.protobuf.GeneratedMessage.Builder<Builder> + implements org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounterOrBuilder { + public static final com.google.protobuf.Descriptors.Descriptor + getDescriptor() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.internal_static_EncodedCQCounter_descriptor; + } + + protected com.google.protobuf.GeneratedMessage.FieldAccessorTable + internalGetFieldAccessorTable() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.internal_static_EncodedCQCounter_fieldAccessorTable + .ensureFieldAccessorsInitialized( + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.class, org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.Builder.class); + } + + // Construct using org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.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(); + colFamily_ = ""; + bitField0_ = (bitField0_ & ~0x00000001); + counter_ = 0; + bitField0_ = (bitField0_ & ~0x00000002); + return this; + } + + public Builder clone() { + return create().mergeFrom(buildPartial()); + } + + public com.google.protobuf.Descriptors.Descriptor + getDescriptorForType() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.internal_static_EncodedCQCounter_descriptor; + } + + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter getDefaultInstanceForType() { + return org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.getDefaultInstance(); + } + + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter build() { + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter result = buildPartial(); + if (!result.isInitialized()) { + throw newUninitializedMessageException(result); + } + return result; + } + + public org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter buildPartial() { + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter result = new org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter(this); + int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } + result.colFamily_ = colFamily_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.counter_ = counter_; + result.bitField0_ = to_bitField0_; + onBuilt(); + return result; + } + + public Builder mergeFrom(com.google.protobuf.Message other) { + if (other instanceof org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter) { + return mergeFrom((org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter)other); + } else { + super.mergeFrom(other); + return this; + } + } + + public Builder mergeFrom(org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter other) { + if (other == org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter.getDefaultInstance()) return this; + if (other.hasColFamily()) { + bitField0_ |= 0x00000001; + colFamily_ = other.colFamily_; + onChanged(); + } + if (other.hasCounter()) { + setCounter(other.getCounter()); + } + this.mergeUnknownFields(other.getUnknownFields()); + return this; + } + + public final boolean isInitialized() { + if (!hasColFamily()) { + + return false; + } + if (!hasCounter()) { + + return false; + } + return true; + } + + public Builder mergeFrom( + com.google.protobuf.CodedInputStream input, + com.google.protobuf.ExtensionRegistryLite extensionRegistry) + throws java.io.IOException { + org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter parsedMessage = null; + try { + parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); + } catch (com.google.protobuf.InvalidProtocolBufferException e) { + parsedMessage = (org.apache.phoenix.coprocessor.generated.PTableProtos.EncodedCQCounter) e.getUnfinishedMessage(); + throw e; + } finally { + if (parsedMessage != null) { + mergeFrom(parsedMessage); + } + } + return this; + } + private int bitField0_; + + // required string colFamily = 1; + private java.lang.Object colFamily_ = ""; + /** + * <code>required string colFamily = 1;</code> + */ + public boolean hasColFamily() { + return ((bitField0_ & 0x00000001) == 0x00000001); + } + /** + * <code>required string colFamily = 1;</code> + */ + public java.lang.String getColFamily() { + java.lang.Object ref = colFamily_; + if (!(ref instanceof java.lang.String)) { + java.lang.String s = ((com.google.protobuf.ByteString) ref) + .toStringUtf8(); + colFamily_ = s; + return s; + } else { + return (java.lang.String) ref; + } + } + /** + * <code>required string colFamily = 1;</code> + */ + public com.google.protobuf.ByteString + getColFamilyBytes() { + java.lang.Object ref = colFamily_; + if (ref instanceof String) { + com.google.protobuf.ByteString b = + com.google.protobuf.ByteString.copyFromUtf8( + (java.lang.String) ref); + colFamily_ = b; + return b; + } else { + return (com.google.protobuf.ByteString) ref; + } + } + /** + * <code>required string colFamily = 1;</code> + */ + public Builder setColFamily( + java.lang.String value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + colFamily_ = value; + onChanged(); + return this; + } + /** + * <code>required string colFamily = 1;</code> + */ + public Builder clearColFamily() { + bitField0_ = (bitField0_ & ~0x00000001); + colFamily_ = getDefaultInstance().getColFamily(); + onChanged(); + return this; + } + /** + * <code>required string colFamily = 1;</code> + */ + public Builder setColFamilyBytes( + com.google.protobuf.ByteString value) { + if (value == null) { + throw new NullPointerException(); + } + bitField0_ |= 0x00000001; + colFamily_ = value; + onChanged(); + return this; + } + + // required int32 counter = 2; + private int counter_ ; + /** + * <code>required int32 counter = 2;</code> + */ + public boolean hasCounter() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>required int32 counter = 2;</code> + */ + public int getCounter() { + return counter_; + } + /** + * <code>required int32 counter = 2;</code> + */ + public Builder setCounter(int value) { + bitField0_ |= 0x00000002; + counter_ = value; + onChanged(); + return this; + } + /** + * <code>required int32 counter = 2;</code> + */ + public Builder clearCounter() { + bitField0_ = (bitField0_ & ~0x00000002); + counter_ = 0; + onChanged(); + return this; + } + + // @@protoc_insertion_point(builder_scope:EncodedCQCounter) + } + + static { + defaultInstance = new EncodedCQCounter(true); + defaultInstance.initFields(); + } + + // @@protoc_insertion_point(class_scope:EncodedCQCounter) + } + + private static com.google.protobuf.Descriptors.Descriptor + internal_static_PColumn_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_PColumn_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_PTableStats_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_PTableStats_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_PTable_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_PTable_fieldAccessorTable; + private static com.google.protobuf.Descriptors.Descriptor + internal_static_EncodedCQCounter_descriptor; + private static + com.google.protobuf.GeneratedMessage.FieldAccessorTable + internal_static_EncodedCQCounter_fieldAccessorTable; + + public static com.google.protobuf.Descriptors.FileDescriptor + getDescriptor() { + return descriptor; + } + private static com.google.protobuf.Descriptors.FileDescriptor + descriptor; + static { + java.lang.String[] descriptorData = { + "\n\014PTable.proto\032\021PGuidePosts.proto\"\304\002\n\007PC" + + "olumn\022\027\n\017columnNameBytes\030\001 \002(\014\022\027\n\017family" + + "NameBytes\030\002 \001(\014\022\020\n\010dataType\030\003 \002(\t\022\021\n\tmax" + + "Length\030\004 \001(\005\022\r\n\005scale\030\005 \001(\005\022\020\n\010nullable\030" + + "\006 \002(\010\022\020\n\010position\030\007 \002(\005\022\021\n\tsortOrder\030\010 \002" + + "(\005\022\021\n\tarraySize\030\t \001(\005\022\024\n\014viewConstant\030\n " + + "\001(\014\022\026\n\016viewReferenced\030\013 \001(\010\022\022\n\nexpressio" + + "n\030\014 \001(\t\022\026\n\016isRowTimestamp\030\r \001(\010\022\021\n\tisDyn" + + "amic\030\016 \001(\010\022\034\n\024columnQualifierBytes\030\017 \001(\014" + + "\"\232\001\n\013PTableStats\022\013\n\003key\030\001 \002(\014\022\016\n\006values\030", + "\002 \003(\014\022\033\n\023guidePostsByteCount\030\003 \001(\003\022\025\n\rke" + + "yBytesCount\030\004 \001(\003\022\027\n\017guidePostsCount\030\005 \001" + + "(\005\022!\n\013pGuidePosts\030\006 \001(\0132\014.PGuidePosts\"\354\006" + + "\n\006PTable\022\027\n\017schemaNameBytes\030\001 \002(\014\022\026\n\016tab" + + "leNameBytes\030\002 \002(\014\022\036\n\ttableType\030\003 \002(\0162\013.P" + + "TableType\022\022\n\nindexState\030\004 \001(\t\022\026\n\016sequenc" + + "eNumber\030\005 \002(\003\022\021\n\ttimeStamp\030\006 \002(\003\022\023\n\013pkNa" + + "meBytes\030\007 \001(\014\022\021\n\tbucketNum\030\010 \002(\005\022\031\n\007colu" + + "mns\030\t \003(\0132\010.PColumn\022\030\n\007indexes\030\n \003(\0132\007.P" + + "Table\022\027\n\017isImmutableRows\030\013 \002(\010\022\032\n\022dataTa", + "bleNameBytes\030\r \001(\014\022\031\n\021defaultFamilyName\030" + + "\016 \001(\014\022\022\n\ndisableWAL\030\017 \002(\010\022\023\n\013multiTenant" + + "\030\020 \002(\010\022\020\n\010viewType\030\021 \001(\014\022\025\n\rviewStatemen" + + "t\030\022 \001(\014\022\025\n\rphysicalNames\030\023 \003(\014\022\020\n\010tenant" + + "Id\030\024 \001(\014\022\023\n\013viewIndexId\030\025 \001(\005\022\021\n\tindexTy" + + "pe\030\026 \001(\014\022\026\n\016statsTimeStamp\030\027 \001(\003\022\022\n\nstor" + + "eNulls\030\030 \001(\010\022\027\n\017baseColumnCount\030\031 \001(\005\022\036\n" + + "\026rowKeyOrderOptimizable\030\032 \001(\010\022\025\n\rtransac" + + "tional\030\033 \001(\010\022\034\n\024updateCacheFrequency\030\034 \001" + + "(\003\022\035\n\025indexDisableTimestamp\030\035 \001(\003\022\031\n\021isN", + "amespaceMapped\030\036 \001(\010\022\034\n\024autoParititonSeq" + + "Name\030\037 \001(\t\022\032\n\022isAppendOnlySchema\030 \001(\010\022\027" + + "\n\017parentNameBytes\030! \001(\014\022\025\n\rstorageScheme" + + "\030\" \001(\014\022\026\n\016encodingScheme\030# \001(\014\022,\n\021encode" + + "dCQCounters\030$ \003(\0132\021.EncodedCQCounter\"6\n\020" + + "EncodedCQCounter\022\021\n\tcolFamily\030\001 \002(\t\022\017\n\007c" + + "ounter\030\002 \002(\005*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.genera" + + "tedB\014PTableProtosH\001\210\001\001\240\001\001" + }; + com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = + new com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner() { + public com.google.protobuf.ExtensionRegistry assignDescriptors( + com.google.protobuf.Descriptors.FileDescriptor root) { + descriptor = root; + internal_static_PColumn_descriptor = + getDescriptor().getMessageTypes().get(0); + internal_static_PColumn_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_PColumn_descriptor, + new java.lang.String[] { "ColumnNameBytes", "FamilyNameBytes", "DataType", "MaxLength", "Scale", "Nullable", "Position", "SortOrder", "ArraySize", "ViewConstant", "ViewReferenced", "Expression", "IsRowTimestamp", "IsDynamic", "ColumnQualifierBytes", }); + internal_static_PTableStats_descriptor = + getDescriptor().getMessageTypes().get(1); + internal_static_PTableStats_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_PTableStats_descriptor, + new java.lang.String[] { "Key", "Values", "GuidePostsByteCount", "KeyBytesCount", "GuidePostsCount", "PGuidePosts", }); + internal_static_PTable_descriptor = + getDescriptor().getMessageTypes().get(2); + 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", "DataTableNameBytes", "DefaultFamilyName", "DisableWAL", "MultiTenant", "ViewType", "ViewStatement", "PhysicalNames", "TenantId", "ViewIndexId", "IndexType", "StatsTimeStamp", "StoreNulls", "BaseColumnCount", "RowKeyOrderOptimizable", "Transactional", "UpdateCacheFrequency", "IndexDisableTimestamp", "IsNamespaceMapped", "AutoParititonSeqName", "IsAppendOnlySchema", "ParentNameBytes", "StorageScheme", "EncodingScheme", "EncodedCQCounters", }); + internal_static_EncodedCQCounter_descriptor = + getDescriptor().getMessageTypes().get(3); + internal_static_EncodedCQCounter_fieldAccessorTable = new + com.google.protobuf.GeneratedMessage.FieldAccessorTable( + internal_static_EncodedCQCounter_descriptor, + new java.lang.String[] { "ColFamily", "Counter", }); return null; } };