http://git-wip-us.apache.org/repos/asf/hbase/blob/9cd5f2d5/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java ---------------------------------------------------------------------- diff --git a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java index 711b9c8..812cf3b 100644 --- a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java +++ b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java @@ -728,6 +728,40 @@ public final class AdminProtos { * <code>optional bool isRecovering = 3;</code> */ boolean getIsRecovering(); + + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + boolean hasSplittable(); + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + boolean getSplittable(); + + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + boolean hasMergeable(); + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + boolean getMergeable(); } /** * Protobuf type {@code hbase.pb.GetRegionInfoResponse} @@ -743,6 +777,8 @@ public final class AdminProtos { private GetRegionInfoResponse() { compactionState_ = 0; isRecovering_ = false; + splittable_ = false; + mergeable_ = false; } @java.lang.Override @@ -802,6 +838,16 @@ public final class AdminProtos { isRecovering_ = input.readBool(); break; } + case 32: { + bitField0_ |= 0x00000008; + splittable_ = input.readBool(); + break; + } + case 40: { + bitField0_ |= 0x00000010; + mergeable_ = input.readBool(); + break; + } } } } catch (org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException e) { @@ -987,6 +1033,52 @@ public final class AdminProtos { return isRecovering_; } + public static final int SPLITTABLE_FIELD_NUMBER = 4; + private boolean splittable_; + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public boolean hasSplittable() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public boolean getSplittable() { + return splittable_; + } + + public static final int MERGEABLE_FIELD_NUMBER = 5; + private boolean mergeable_; + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public boolean hasMergeable() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public boolean getMergeable() { + return mergeable_; + } + private byte memoizedIsInitialized = -1; public final boolean isInitialized() { byte isInitialized = memoizedIsInitialized; @@ -1016,6 +1108,12 @@ public final class AdminProtos { if (((bitField0_ & 0x00000004) == 0x00000004)) { output.writeBool(3, isRecovering_); } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + output.writeBool(4, splittable_); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + output.writeBool(5, mergeable_); + } unknownFields.writeTo(output); } @@ -1036,6 +1134,14 @@ public final class AdminProtos { size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream .computeBoolSize(3, isRecovering_); } + if (((bitField0_ & 0x00000008) == 0x00000008)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeBoolSize(4, splittable_); + } + if (((bitField0_ & 0x00000010) == 0x00000010)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeBoolSize(5, mergeable_); + } size += unknownFields.getSerializedSize(); memoizedSize = size; return size; @@ -1067,6 +1173,16 @@ public final class AdminProtos { result = result && (getIsRecovering() == other.getIsRecovering()); } + result = result && (hasSplittable() == other.hasSplittable()); + if (hasSplittable()) { + result = result && (getSplittable() + == other.getSplittable()); + } + result = result && (hasMergeable() == other.hasMergeable()); + if (hasMergeable()) { + result = result && (getMergeable() + == other.getMergeable()); + } result = result && unknownFields.equals(other.unknownFields); return result; } @@ -1091,6 +1207,16 @@ public final class AdminProtos { hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( getIsRecovering()); } + if (hasSplittable()) { + hash = (37 * hash) + SPLITTABLE_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( + getSplittable()); + } + if (hasMergeable()) { + hash = (37 * hash) + MERGEABLE_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( + getMergeable()); + } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; @@ -1220,6 +1346,10 @@ public final class AdminProtos { bitField0_ = (bitField0_ & ~0x00000002); isRecovering_ = false; bitField0_ = (bitField0_ & ~0x00000004); + splittable_ = false; + bitField0_ = (bitField0_ & ~0x00000008); + mergeable_ = false; + bitField0_ = (bitField0_ & ~0x00000010); return this; } @@ -1260,6 +1390,14 @@ public final class AdminProtos { to_bitField0_ |= 0x00000004; } result.isRecovering_ = isRecovering_; + if (((from_bitField0_ & 0x00000008) == 0x00000008)) { + to_bitField0_ |= 0x00000008; + } + result.splittable_ = splittable_; + if (((from_bitField0_ & 0x00000010) == 0x00000010)) { + to_bitField0_ |= 0x00000010; + } + result.mergeable_ = mergeable_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -1311,6 +1449,12 @@ public final class AdminProtos { if (other.hasIsRecovering()) { setIsRecovering(other.getIsRecovering()); } + if (other.hasSplittable()) { + setSplittable(other.getSplittable()); + } + if (other.hasMergeable()) { + setMergeable(other.getMergeable()); + } this.mergeUnknownFields(other.unknownFields); onChanged(); return this; @@ -1530,6 +1674,102 @@ public final class AdminProtos { onChanged(); return this; } + + private boolean splittable_ ; + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public boolean hasSplittable() { + return ((bitField0_ & 0x00000008) == 0x00000008); + } + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public boolean getSplittable() { + return splittable_; + } + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public Builder setSplittable(boolean value) { + bitField0_ |= 0x00000008; + splittable_ = value; + onChanged(); + return this; + } + /** + * <pre> + * True if region is splittable, false otherwise. + * </pre> + * + * <code>optional bool splittable = 4;</code> + */ + public Builder clearSplittable() { + bitField0_ = (bitField0_ & ~0x00000008); + splittable_ = false; + onChanged(); + return this; + } + + private boolean mergeable_ ; + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public boolean hasMergeable() { + return ((bitField0_ & 0x00000010) == 0x00000010); + } + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public boolean getMergeable() { + return mergeable_; + } + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public Builder setMergeable(boolean value) { + bitField0_ |= 0x00000010; + mergeable_ = value; + onChanged(); + return this; + } + /** + * <pre> + * True if region is mergeable, false otherwise. + * </pre> + * + * <code>optional bool mergeable = 5;</code> + */ + public Builder clearMergeable() { + bitField0_ = (bitField0_ & ~0x00000010); + mergeable_ = false; + onChanged(); + return this; + } public final Builder setUnknownFields( final org.apache.hadoop.hbase.shaded.com.google.protobuf.UnknownFieldSet unknownFields) { return super.setUnknownFields(unknownFields); @@ -9414,53 +9654,70 @@ public final class AdminProtos { } - public interface CloseRegionForSplitOrMergeRequestOrBuilder extends - // @@protoc_insertion_point(interface_extends:hbase.pb.CloseRegionForSplitOrMergeRequest) + public interface FlushRegionRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:hbase.pb.FlushRegionRequest) org.apache.hadoop.hbase.shaded.com.google.protobuf.MessageOrBuilder { /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> - getRegionList(); + boolean hasRegion(); /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(int index); + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(); /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - int getRegionCount(); + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder(); + /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - java.util.List<? extends org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> - getRegionOrBuilderList(); + boolean hasIfOlderThanTs(); /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder( - int index); + long getIfOlderThanTs(); + + /** + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> + */ + boolean hasWriteFlushWalMarker(); + /** + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> + */ + boolean getWriteFlushWalMarker(); } /** * <pre> ** - * Closes the specified region(s) for - * split or merge + * Flushes the MemStore of the specified region. + * <p> + * This method is synchronous. * </pre> * - * Protobuf type {@code hbase.pb.CloseRegionForSplitOrMergeRequest} + * Protobuf type {@code hbase.pb.FlushRegionRequest} */ - public static final class CloseRegionForSplitOrMergeRequest extends + public static final class FlushRegionRequest extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 implements - // @@protoc_insertion_point(message_implements:hbase.pb.CloseRegionForSplitOrMergeRequest) - CloseRegionForSplitOrMergeRequestOrBuilder { - // Use CloseRegionForSplitOrMergeRequest.newBuilder() to construct. - private CloseRegionForSplitOrMergeRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { + // @@protoc_insertion_point(message_implements:hbase.pb.FlushRegionRequest) + FlushRegionRequestOrBuilder { + // Use FlushRegionRequest.newBuilder() to construct. + private FlushRegionRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { super(builder); } - private CloseRegionForSplitOrMergeRequest() { - region_ = java.util.Collections.emptyList(); + private FlushRegionRequest() { + ifOlderThanTs_ = 0L; + writeFlushWalMarker_ = false; } @java.lang.Override @@ -9468,7 +9725,7 @@ public final class AdminProtos { getUnknownFields() { return this.unknownFields; } - private CloseRegionForSplitOrMergeRequest( + private FlushRegionRequest( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { @@ -9492,12 +9749,26 @@ public final class AdminProtos { break; } case 10: { - if (!((mutable_bitField0_ & 0x00000001) == 0x00000001)) { - region_ = new java.util.ArrayList<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier>(); - mutable_bitField0_ |= 0x00000001; + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder subBuilder = null; + if (((bitField0_ & 0x00000001) == 0x00000001)) { + subBuilder = region_.toBuilder(); + } + region_ = input.readMessage(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.PARSER, extensionRegistry); + if (subBuilder != null) { + subBuilder.mergeFrom(region_); + region_ = subBuilder.buildPartial(); } - region_.add( - input.readMessage(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.PARSER, extensionRegistry)); + bitField0_ |= 0x00000001; + break; + } + case 16: { + bitField0_ |= 0x00000002; + ifOlderThanTs_ = input.readUInt64(); + break; + } + case 24: { + bitField0_ |= 0x00000004; + writeFlushWalMarker_ = input.readBool(); break; } } @@ -9508,82 +9779,112 @@ public final class AdminProtos { throw new org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException( e).setUnfinishedMessage(this); } finally { - if (((mutable_bitField0_ & 0x00000001) == 0x00000001)) { - region_ = java.util.Collections.unmodifiableList(region_); - } this.unknownFields = unknownFields.build(); makeExtensionsImmutable(); } } public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeRequest_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionRequest_descriptor; } protected org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeRequest_fieldAccessorTable + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.Builder.class); + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.Builder.class); } + private int bitField0_; public static final int REGION_FIELD_NUMBER = 1; - private java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> region_; + private org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier region_; /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> getRegionList() { - return region_; + public boolean hasRegion() { + return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public java.util.List<? extends org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> - getRegionOrBuilderList() { - return region_; + public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion() { + return region_ == null ? org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance() : region_; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public int getRegionCount() { - return region_.size(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder() { + return region_ == null ? org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance() : region_; } + + public static final int IF_OLDER_THAN_TS_FIELD_NUMBER = 2; + private long ifOlderThanTs_; /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(int index) { - return region_.get(index); + public boolean hasIfOlderThanTs() { + return ((bitField0_ & 0x00000002) == 0x00000002); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder( - int index) { - return region_.get(index); - } - - private byte memoizedIsInitialized = -1; - public final boolean isInitialized() { - byte isInitialized = memoizedIsInitialized; - if (isInitialized == 1) return true; - if (isInitialized == 0) return false; - - for (int i = 0; i < getRegionCount(); i++) { - if (!getRegion(i).isInitialized()) { - memoizedIsInitialized = 0; - return false; - } - } - memoizedIsInitialized = 1; - return true; + public long getIfOlderThanTs() { + return ifOlderThanTs_; } - public void writeTo(org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream output) - throws java.io.IOException { - for (int i = 0; i < region_.size(); i++) { - output.writeMessage(1, region_.get(i)); - } - unknownFields.writeTo(output); + public static final int WRITE_FLUSH_WAL_MARKER_FIELD_NUMBER = 3; + private boolean writeFlushWalMarker_; + /** + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> + */ + public boolean hasWriteFlushWalMarker() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> + */ + public boolean getWriteFlushWalMarker() { + return writeFlushWalMarker_; + } + + private byte memoizedIsInitialized = -1; + public final boolean isInitialized() { + byte isInitialized = memoizedIsInitialized; + if (isInitialized == 1) return true; + if (isInitialized == 0) return false; + + if (!hasRegion()) { + memoizedIsInitialized = 0; + return false; + } + if (!getRegion().isInitialized()) { + memoizedIsInitialized = 0; + return false; + } + memoizedIsInitialized = 1; + return true; + } + + public void writeTo(org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream output) + throws java.io.IOException { + if (((bitField0_ & 0x00000001) == 0x00000001)) { + output.writeMessage(1, getRegion()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeUInt64(2, ifOlderThanTs_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeBool(3, writeFlushWalMarker_); + } + unknownFields.writeTo(output); } public int getSerializedSize() { @@ -9591,9 +9892,17 @@ public final class AdminProtos { if (size != -1) return size; size = 0; - for (int i = 0; i < region_.size(); i++) { + if (((bitField0_ & 0x00000001) == 0x00000001)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeMessageSize(1, getRegion()); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeUInt64Size(2, ifOlderThanTs_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream - .computeMessageSize(1, region_.get(i)); + .computeBoolSize(3, writeFlushWalMarker_); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -9606,14 +9915,27 @@ public final class AdminProtos { if (obj == this) { return true; } - if (!(obj instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest)) { + if (!(obj instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest)) { return super.equals(obj); } - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest other = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest) obj; + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest other = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest) obj; boolean result = true; - result = result && getRegionList() - .equals(other.getRegionList()); + result = result && (hasRegion() == other.hasRegion()); + if (hasRegion()) { + result = result && getRegion() + .equals(other.getRegion()); + } + result = result && (hasIfOlderThanTs() == other.hasIfOlderThanTs()); + if (hasIfOlderThanTs()) { + result = result && (getIfOlderThanTs() + == other.getIfOlderThanTs()); + } + result = result && (hasWriteFlushWalMarker() == other.hasWriteFlushWalMarker()); + if (hasWriteFlushWalMarker()) { + result = result && (getWriteFlushWalMarker() + == other.getWriteFlushWalMarker()); + } result = result && unknownFields.equals(other.unknownFields); return result; } @@ -9625,67 +9947,77 @@ public final class AdminProtos { } int hash = 41; hash = (19 * hash) + getDescriptor().hashCode(); - if (getRegionCount() > 0) { + if (hasRegion()) { hash = (37 * hash) + REGION_FIELD_NUMBER; - hash = (53 * hash) + getRegionList().hashCode(); + hash = (53 * hash) + getRegion().hashCode(); + } + if (hasIfOlderThanTs()) { + hash = (37 * hash) + IF_OLDER_THAN_TS_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashLong( + getIfOlderThanTs()); + } + if (hasWriteFlushWalMarker()) { + hash = (37 * hash) + WRITE_FLUSH_WAL_MARKER_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( + getWriteFlushWalMarker()); } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString data) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString data, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom(byte[] data) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom(byte[] data) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( byte[] data, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom(java.io.InputStream input) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom(java.io.InputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( java.io.InputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseDelimitedFrom(java.io.InputStream input) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseDelimitedWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseDelimitedFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseDelimitedFrom( java.io.InputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseDelimitedWithIOException(PARSER, input, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { @@ -9697,7 +10029,7 @@ public final class AdminProtos { public static Builder newBuilder() { return DEFAULT_INSTANCE.toBuilder(); } - public static Builder newBuilder(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest prototype) { + public static Builder newBuilder(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest prototype) { return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); } public Builder toBuilder() { @@ -9714,29 +10046,30 @@ public final class AdminProtos { /** * <pre> ** - * Closes the specified region(s) for - * split or merge + * Flushes the MemStore of the specified region. + * <p> + * This method is synchronous. * </pre> * - * Protobuf type {@code hbase.pb.CloseRegionForSplitOrMergeRequest} + * Protobuf type {@code hbase.pb.FlushRegionRequest} */ public static final class Builder extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements - // @@protoc_insertion_point(builder_implements:hbase.pb.CloseRegionForSplitOrMergeRequest) - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequestOrBuilder { + // @@protoc_insertion_point(builder_implements:hbase.pb.FlushRegionRequest) + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequestOrBuilder { public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeRequest_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionRequest_descriptor; } protected org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeRequest_fieldAccessorTable + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionRequest_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.Builder.class); + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.Builder.class); } - // Construct using org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.newBuilder() + // Construct using org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.newBuilder() private Builder() { maybeForceBuilderInitialization(); } @@ -9755,43 +10088,56 @@ public final class AdminProtos { public Builder clear() { super.clear(); if (regionBuilder_ == null) { - region_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000001); + region_ = null; } else { regionBuilder_.clear(); } + bitField0_ = (bitField0_ & ~0x00000001); + ifOlderThanTs_ = 0L; + bitField0_ = (bitField0_ & ~0x00000002); + writeFlushWalMarker_ = false; + bitField0_ = (bitField0_ & ~0x00000004); return this; } public org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeRequest_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionRequest_descriptor; } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest getDefaultInstanceForType() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.getDefaultInstance(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest getDefaultInstanceForType() { + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.getDefaultInstance(); } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest build() { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest result = buildPartial(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest build() { + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest result = buildPartial(); if (!result.isInitialized()) { throw newUninitializedMessageException(result); } return result; } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest buildPartial() { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest result = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest(this); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest buildPartial() { + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest result = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest(this); int from_bitField0_ = bitField0_; + int to_bitField0_ = 0; + if (((from_bitField0_ & 0x00000001) == 0x00000001)) { + to_bitField0_ |= 0x00000001; + } if (regionBuilder_ == null) { - if (((bitField0_ & 0x00000001) == 0x00000001)) { - region_ = java.util.Collections.unmodifiableList(region_); - bitField0_ = (bitField0_ & ~0x00000001); - } result.region_ = region_; } else { result.region_ = regionBuilder_.build(); } + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.ifOlderThanTs_ = ifOlderThanTs_; + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + result.writeFlushWalMarker_ = writeFlushWalMarker_; + result.bitField0_ = to_bitField0_; onBuilt(); return result; } @@ -9823,41 +10169,24 @@ public final class AdminProtos { return (Builder) super.addRepeatedField(field, value); } public Builder mergeFrom(org.apache.hadoop.hbase.shaded.com.google.protobuf.Message other) { - if (other instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest) { - return mergeFrom((org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest)other); + if (other instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest) { + return mergeFrom((org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest)other); } else { super.mergeFrom(other); return this; } } - public Builder mergeFrom(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest other) { - if (other == org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest.getDefaultInstance()) return this; - if (regionBuilder_ == null) { - if (!other.region_.isEmpty()) { - if (region_.isEmpty()) { - region_ = other.region_; - bitField0_ = (bitField0_ & ~0x00000001); - } else { - ensureRegionIsMutable(); - region_.addAll(other.region_); - } - onChanged(); - } - } else { - if (!other.region_.isEmpty()) { - if (regionBuilder_.isEmpty()) { - regionBuilder_.dispose(); - regionBuilder_ = null; - region_ = other.region_; - bitField0_ = (bitField0_ & ~0x00000001); - regionBuilder_ = - org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.alwaysUseFieldBuilders ? - getRegionFieldBuilder() : null; - } else { - regionBuilder_.addAllMessages(other.region_); - } - } + public Builder mergeFrom(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest other) { + if (other == org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest.getDefaultInstance()) return this; + if (other.hasRegion()) { + mergeRegion(other.getRegion()); + } + if (other.hasIfOlderThanTs()) { + setIfOlderThanTs(other.getIfOlderThanTs()); + } + if (other.hasWriteFlushWalMarker()) { + setWriteFlushWalMarker(other.getWriteFlushWalMarker()); } this.mergeUnknownFields(other.unknownFields); onChanged(); @@ -9865,10 +10194,11 @@ public final class AdminProtos { } public final boolean isInitialized() { - for (int i = 0; i < getRegionCount(); i++) { - if (!getRegion(i).isInitialized()) { - return false; - } + if (!hasRegion()) { + return false; + } + if (!getRegion().isInitialized()) { + return false; } return true; } @@ -9877,11 +10207,11 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest parsedMessage = null; + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest parsedMessage = null; try { parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); } catch (org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest) e.getUnfinishedMessage(); + parsedMessage = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest) e.getUnfinishedMessage(); throw e.unwrapIOException(); } finally { if (parsedMessage != null) { @@ -9892,244 +10222,202 @@ public final class AdminProtos { } private int bitField0_; - private java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> region_ = - java.util.Collections.emptyList(); - private void ensureRegionIsMutable() { - if (!((bitField0_ & 0x00000001) == 0x00000001)) { - region_ = new java.util.ArrayList<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier>(region_); - bitField0_ |= 0x00000001; - } - } - - private org.apache.hadoop.hbase.shaded.com.google.protobuf.RepeatedFieldBuilderV3< + private org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier region_ = null; + private org.apache.hadoop.hbase.shaded.com.google.protobuf.SingleFieldBuilderV3< org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> regionBuilder_; - - /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> - */ - public java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> getRegionList() { - if (regionBuilder_ == null) { - return java.util.Collections.unmodifiableList(region_); - } else { - return regionBuilder_.getMessageList(); - } - } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public int getRegionCount() { - if (regionBuilder_ == null) { - return region_.size(); - } else { - return regionBuilder_.getCount(); - } + public boolean hasRegion() { + return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(int index) { + public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion() { if (regionBuilder_ == null) { - return region_.get(index); + return region_ == null ? org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance() : region_; } else { - return regionBuilder_.getMessage(index); + return regionBuilder_.getMessage(); } } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder setRegion( - int index, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier value) { + public Builder setRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier value) { if (regionBuilder_ == null) { if (value == null) { throw new NullPointerException(); } - ensureRegionIsMutable(); - region_.set(index, value); + region_ = value; onChanged(); } else { - regionBuilder_.setMessage(index, value); + regionBuilder_.setMessage(value); } + bitField0_ |= 0x00000001; return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ public Builder setRegion( - int index, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder builderForValue) { + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder builderForValue) { if (regionBuilder_ == null) { - ensureRegionIsMutable(); - region_.set(index, builderForValue.build()); + region_ = builderForValue.build(); onChanged(); } else { - regionBuilder_.setMessage(index, builderForValue.build()); + regionBuilder_.setMessage(builderForValue.build()); } + bitField0_ |= 0x00000001; return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder addRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier value) { + public Builder mergeRegion(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier value) { if (regionBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); + if (((bitField0_ & 0x00000001) == 0x00000001) && + region_ != null && + region_ != org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance()) { + region_ = + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.newBuilder(region_).mergeFrom(value).buildPartial(); + } else { + region_ = value; } - ensureRegionIsMutable(); - region_.add(value); onChanged(); } else { - regionBuilder_.addMessage(value); + regionBuilder_.mergeFrom(value); } + bitField0_ |= 0x00000001; return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder addRegion( - int index, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier value) { + public Builder clearRegion() { if (regionBuilder_ == null) { - if (value == null) { - throw new NullPointerException(); - } - ensureRegionIsMutable(); - region_.add(index, value); + region_ = null; onChanged(); } else { - regionBuilder_.addMessage(index, value); + regionBuilder_.clear(); } + bitField0_ = (bitField0_ & ~0x00000001); return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder addRegion( - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder builderForValue) { - if (regionBuilder_ == null) { - ensureRegionIsMutable(); - region_.add(builderForValue.build()); - onChanged(); - } else { - regionBuilder_.addMessage(builderForValue.build()); - } - return this; + public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder getRegionBuilder() { + bitField0_ |= 0x00000001; + onChanged(); + return getRegionFieldBuilder().getBuilder(); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder addRegion( - int index, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder builderForValue) { - if (regionBuilder_ == null) { - ensureRegionIsMutable(); - region_.add(index, builderForValue.build()); - onChanged(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder() { + if (regionBuilder_ != null) { + return regionBuilder_.getMessageOrBuilder(); } else { - regionBuilder_.addMessage(index, builderForValue.build()); + return region_ == null ? + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance() : region_; } - return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>required .hbase.pb.RegionSpecifier region = 1;</code> */ - public Builder addAllRegion( - java.lang.Iterable<? extends org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier> values) { - if (regionBuilder_ == null) { - ensureRegionIsMutable(); - org.apache.hadoop.hbase.shaded.com.google.protobuf.AbstractMessageLite.Builder.addAll( - values, region_); - onChanged(); - } else { - regionBuilder_.addAllMessages(values); + private org.apache.hadoop.hbase.shaded.com.google.protobuf.SingleFieldBuilderV3< + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> + getRegionFieldBuilder() { + if (regionBuilder_ == null) { + regionBuilder_ = new org.apache.hadoop.hbase.shaded.com.google.protobuf.SingleFieldBuilderV3< + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder>( + getRegion(), + getParentForChildren(), + isClean()); + region_ = null; } - return this; + return regionBuilder_; } + + private long ifOlderThanTs_ ; /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public Builder clearRegion() { - if (regionBuilder_ == null) { - region_ = java.util.Collections.emptyList(); - bitField0_ = (bitField0_ & ~0x00000001); - onChanged(); - } else { - regionBuilder_.clear(); - } - return this; + public boolean hasIfOlderThanTs() { + return ((bitField0_ & 0x00000002) == 0x00000002); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public Builder removeRegion(int index) { - if (regionBuilder_ == null) { - ensureRegionIsMutable(); - region_.remove(index); - onChanged(); - } else { - regionBuilder_.remove(index); - } - return this; + public long getIfOlderThanTs() { + return ifOlderThanTs_; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder getRegionBuilder( - int index) { - return getRegionFieldBuilder().getBuilder(index); + public Builder setIfOlderThanTs(long value) { + bitField0_ |= 0x00000002; + ifOlderThanTs_ = value; + onChanged(); + return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <code>optional uint64 if_older_than_ts = 2;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder( - int index) { - if (regionBuilder_ == null) { - return region_.get(index); } else { - return regionBuilder_.getMessageOrBuilder(index); - } + public Builder clearIfOlderThanTs() { + bitField0_ = (bitField0_ & ~0x00000002); + ifOlderThanTs_ = 0L; + onChanged(); + return this; } + + private boolean writeFlushWalMarker_ ; /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> */ - public java.util.List<? extends org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> - getRegionOrBuilderList() { - if (regionBuilder_ != null) { - return regionBuilder_.getMessageOrBuilderList(); - } else { - return java.util.Collections.unmodifiableList(region_); - } + public boolean hasWriteFlushWalMarker() { + return ((bitField0_ & 0x00000004) == 0x00000004); } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder addRegionBuilder() { - return getRegionFieldBuilder().addBuilder( - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance()); + public boolean getWriteFlushWalMarker() { + return writeFlushWalMarker_; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> */ - public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder addRegionBuilder( - int index) { - return getRegionFieldBuilder().addBuilder( - index, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.getDefaultInstance()); + public Builder setWriteFlushWalMarker(boolean value) { + bitField0_ |= 0x00000004; + writeFlushWalMarker_ = value; + onChanged(); + return this; } /** - * <code>repeated .hbase.pb.RegionSpecifier region = 1;</code> + * <pre> + * whether to write a marker to WAL even if not flushed + * </pre> + * + * <code>optional bool write_flush_wal_marker = 3;</code> */ - public java.util.List<org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder> - getRegionBuilderList() { - return getRegionFieldBuilder().getBuilderList(); - } - private org.apache.hadoop.hbase.shaded.com.google.protobuf.RepeatedFieldBuilderV3< - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder> - getRegionFieldBuilder() { - if (regionBuilder_ == null) { - regionBuilder_ = new org.apache.hadoop.hbase.shaded.com.google.protobuf.RepeatedFieldBuilderV3< - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder>( - region_, - ((bitField0_ & 0x00000001) == 0x00000001), - getParentForChildren(), - isClean()); - region_ = null; - } - return regionBuilder_; + public Builder clearWriteFlushWalMarker() { + bitField0_ = (bitField0_ & ~0x00000004); + writeFlushWalMarker_ = false; + onChanged(); + return this; } public final Builder setUnknownFields( final org.apache.hadoop.hbase.shaded.com.google.protobuf.UnknownFieldSet unknownFields) { @@ -10142,70 +10430,90 @@ public final class AdminProtos { } - // @@protoc_insertion_point(builder_scope:hbase.pb.CloseRegionForSplitOrMergeRequest) + // @@protoc_insertion_point(builder_scope:hbase.pb.FlushRegionRequest) } - // @@protoc_insertion_point(class_scope:hbase.pb.CloseRegionForSplitOrMergeRequest) - private static final org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest DEFAULT_INSTANCE; + // @@protoc_insertion_point(class_scope:hbase.pb.FlushRegionRequest) + private static final org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest DEFAULT_INSTANCE; static { - DEFAULT_INSTANCE = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest(); + DEFAULT_INSTANCE = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest(); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest getDefaultInstance() { + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest getDefaultInstance() { return DEFAULT_INSTANCE; } - @java.lang.Deprecated public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<CloseRegionForSplitOrMergeRequest> - PARSER = new org.apache.hadoop.hbase.shaded.com.google.protobuf.AbstractParser<CloseRegionForSplitOrMergeRequest>() { - public CloseRegionForSplitOrMergeRequest parsePartialFrom( + @java.lang.Deprecated public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<FlushRegionRequest> + PARSER = new org.apache.hadoop.hbase.shaded.com.google.protobuf.AbstractParser<FlushRegionRequest>() { + public FlushRegionRequest parsePartialFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { - return new CloseRegionForSplitOrMergeRequest(input, extensionRegistry); + return new FlushRegionRequest(input, extensionRegistry); } }; - public static org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<CloseRegionForSplitOrMergeRequest> parser() { + public static org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<FlushRegionRequest> parser() { return PARSER; } @java.lang.Override - public org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<CloseRegionForSplitOrMergeRequest> getParserForType() { + public org.apache.hadoop.hbase.shaded.com.google.protobuf.Parser<FlushRegionRequest> getParserForType() { return PARSER; } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeRequest getDefaultInstanceForType() { + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest getDefaultInstanceForType() { return DEFAULT_INSTANCE; } } - public interface CloseRegionForSplitOrMergeResponseOrBuilder extends - // @@protoc_insertion_point(interface_extends:hbase.pb.CloseRegionForSplitOrMergeResponse) + public interface FlushRegionResponseOrBuilder extends + // @@protoc_insertion_point(interface_extends:hbase.pb.FlushRegionResponse) org.apache.hadoop.hbase.shaded.com.google.protobuf.MessageOrBuilder { /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - boolean hasClosed(); + boolean hasLastFlushTime(); /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - boolean getClosed(); + long getLastFlushTime(); + + /** + * <code>optional bool flushed = 2;</code> + */ + boolean hasFlushed(); + /** + * <code>optional bool flushed = 2;</code> + */ + boolean getFlushed(); + + /** + * <code>optional bool wrote_flush_wal_marker = 3;</code> + */ + boolean hasWroteFlushWalMarker(); + /** + * <code>optional bool wrote_flush_wal_marker = 3;</code> + */ + boolean getWroteFlushWalMarker(); } /** - * Protobuf type {@code hbase.pb.CloseRegionForSplitOrMergeResponse} + * Protobuf type {@code hbase.pb.FlushRegionResponse} */ - public static final class CloseRegionForSplitOrMergeResponse extends + public static final class FlushRegionResponse extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 implements - // @@protoc_insertion_point(message_implements:hbase.pb.CloseRegionForSplitOrMergeResponse) - CloseRegionForSplitOrMergeResponseOrBuilder { - // Use CloseRegionForSplitOrMergeResponse.newBuilder() to construct. - private CloseRegionForSplitOrMergeResponse(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { + // @@protoc_insertion_point(message_implements:hbase.pb.FlushRegionResponse) + FlushRegionResponseOrBuilder { + // Use FlushRegionResponse.newBuilder() to construct. + private FlushRegionResponse(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<?> builder) { super(builder); } - private CloseRegionForSplitOrMergeResponse() { - closed_ = false; + private FlushRegionResponse() { + lastFlushTime_ = 0L; + flushed_ = false; + wroteFlushWalMarker_ = false; } @java.lang.Override @@ -10213,7 +10521,7 @@ public final class AdminProtos { getUnknownFields() { return this.unknownFields; } - private CloseRegionForSplitOrMergeResponse( + private FlushRegionResponse( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { @@ -10238,7 +10546,17 @@ public final class AdminProtos { } case 8: { bitField0_ |= 0x00000001; - closed_ = input.readBool(); + lastFlushTime_ = input.readUInt64(); + break; + } + case 16: { + bitField0_ |= 0x00000002; + flushed_ = input.readBool(); + break; + } + case 24: { + bitField0_ |= 0x00000004; + wroteFlushWalMarker_ = input.readBool(); break; } } @@ -10255,30 +10573,60 @@ public final class AdminProtos { } public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeResponse_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionResponse_descriptor; } protected org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeResponse_fieldAccessorTable + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionResponse_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.Builder.class); + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.Builder.class); } private int bitField0_; - public static final int CLOSED_FIELD_NUMBER = 1; - private boolean closed_; + public static final int LAST_FLUSH_TIME_FIELD_NUMBER = 1; + private long lastFlushTime_; /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - public boolean hasClosed() { + public boolean hasLastFlushTime() { return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - public boolean getClosed() { - return closed_; + public long getLastFlushTime() { + return lastFlushTime_; + } + + public static final int FLUSHED_FIELD_NUMBER = 2; + private boolean flushed_; + /** + * <code>optional bool flushed = 2;</code> + */ + public boolean hasFlushed() { + return ((bitField0_ & 0x00000002) == 0x00000002); + } + /** + * <code>optional bool flushed = 2;</code> + */ + public boolean getFlushed() { + return flushed_; + } + + public static final int WROTE_FLUSH_WAL_MARKER_FIELD_NUMBER = 3; + private boolean wroteFlushWalMarker_; + /** + * <code>optional bool wrote_flush_wal_marker = 3;</code> + */ + public boolean hasWroteFlushWalMarker() { + return ((bitField0_ & 0x00000004) == 0x00000004); + } + /** + * <code>optional bool wrote_flush_wal_marker = 3;</code> + */ + public boolean getWroteFlushWalMarker() { + return wroteFlushWalMarker_; } private byte memoizedIsInitialized = -1; @@ -10287,7 +10635,7 @@ public final class AdminProtos { if (isInitialized == 1) return true; if (isInitialized == 0) return false; - if (!hasClosed()) { + if (!hasLastFlushTime()) { memoizedIsInitialized = 0; return false; } @@ -10298,7 +10646,13 @@ public final class AdminProtos { public void writeTo(org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream output) throws java.io.IOException { if (((bitField0_ & 0x00000001) == 0x00000001)) { - output.writeBool(1, closed_); + output.writeUInt64(1, lastFlushTime_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + output.writeBool(2, flushed_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + output.writeBool(3, wroteFlushWalMarker_); } unknownFields.writeTo(output); } @@ -10310,7 +10664,15 @@ public final class AdminProtos { size = 0; if (((bitField0_ & 0x00000001) == 0x00000001)) { size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream - .computeBoolSize(1, closed_); + .computeUInt64Size(1, lastFlushTime_); + } + if (((bitField0_ & 0x00000002) == 0x00000002)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeBoolSize(2, flushed_); + } + if (((bitField0_ & 0x00000004) == 0x00000004)) { + size += org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedOutputStream + .computeBoolSize(3, wroteFlushWalMarker_); } size += unknownFields.getSerializedSize(); memoizedSize = size; @@ -10323,16 +10685,26 @@ public final class AdminProtos { if (obj == this) { return true; } - if (!(obj instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse)) { + if (!(obj instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse)) { return super.equals(obj); } - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse other = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse) obj; + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse other = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse) obj; boolean result = true; - result = result && (hasClosed() == other.hasClosed()); - if (hasClosed()) { - result = result && (getClosed() - == other.getClosed()); + result = result && (hasLastFlushTime() == other.hasLastFlushTime()); + if (hasLastFlushTime()) { + result = result && (getLastFlushTime() + == other.getLastFlushTime()); + } + result = result && (hasFlushed() == other.hasFlushed()); + if (hasFlushed()) { + result = result && (getFlushed() + == other.getFlushed()); + } + result = result && (hasWroteFlushWalMarker() == other.hasWroteFlushWalMarker()); + if (hasWroteFlushWalMarker()) { + result = result && (getWroteFlushWalMarker() + == other.getWroteFlushWalMarker()); } result = result && unknownFields.equals(other.unknownFields); return result; @@ -10345,68 +10717,78 @@ public final class AdminProtos { } int hash = 41; hash = (19 * hash) + getDescriptor().hashCode(); - if (hasClosed()) { - hash = (37 * hash) + CLOSED_FIELD_NUMBER; + if (hasLastFlushTime()) { + hash = (37 * hash) + LAST_FLUSH_TIME_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashLong( + getLastFlushTime()); + } + if (hasFlushed()) { + hash = (37 * hash) + FLUSHED_FIELD_NUMBER; hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( - getClosed()); + getFlushed()); + } + if (hasWroteFlushWalMarker()) { + hash = (37 * hash) + WROTE_FLUSH_WAL_MARKER_FIELD_NUMBER; + hash = (53 * hash) + org.apache.hadoop.hbase.shaded.com.google.protobuf.Internal.hashBoolean( + getWroteFlushWalMarker()); } hash = (29 * hash) + unknownFields.hashCode(); memoizedHashCode = hash; return hash; } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString data) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString data, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom(byte[] data) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom(byte[] data) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( byte[] data, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { return PARSER.parseFrom(data, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom(java.io.InputStream input) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom(java.io.InputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( java.io.InputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseDelimitedFrom(java.io.InputStream input) + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseDelimitedFrom(java.io.InputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseDelimitedWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseDelimitedFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseDelimitedFrom( java.io.InputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseDelimitedWithIOException(PARSER, input, extensionRegistry); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input) throws java.io.IOException { return org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 .parseWithIOException(PARSER, input); } - public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parseFrom( + public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parseFrom( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { @@ -10418,7 +10800,7 @@ public final class AdminProtos { public static Builder newBuilder() { return DEFAULT_INSTANCE.toBuilder(); } - public static Builder newBuilder(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse prototype) { + public static Builder newBuilder(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse prototype) { return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype); } public Builder toBuilder() { @@ -10433,25 +10815,25 @@ public final class AdminProtos { return builder; } /** - * Protobuf type {@code hbase.pb.CloseRegionForSplitOrMergeResponse} + * Protobuf type {@code hbase.pb.FlushRegionResponse} */ public static final class Builder extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements - // @@protoc_insertion_point(builder_implements:hbase.pb.CloseRegionForSplitOrMergeResponse) - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponseOrBuilder { + // @@protoc_insertion_point(builder_implements:hbase.pb.FlushRegionResponse) + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponseOrBuilder { public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptor() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeResponse_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionResponse_descriptor; } protected org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeResponse_fieldAccessorTable + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionResponse_fieldAccessorTable .ensureFieldAccessorsInitialized( - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.Builder.class); + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.Builder.class); } - // Construct using org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.newBuilder() + // Construct using org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.newBuilder() private Builder() { maybeForceBuilderInitialization(); } @@ -10468,36 +10850,48 @@ public final class AdminProtos { } public Builder clear() { super.clear(); - closed_ = false; + lastFlushTime_ = 0L; bitField0_ = (bitField0_ & ~0x00000001); + flushed_ = false; + bitField0_ = (bitField0_ & ~0x00000002); + wroteFlushWalMarker_ = false; + bitField0_ = (bitField0_ & ~0x00000004); return this; } public org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.Descriptor getDescriptorForType() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_CloseRegionForSplitOrMergeResponse_descriptor; + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.internal_static_hbase_pb_FlushRegionResponse_descriptor; } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse getDefaultInstanceForType() { - return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.getDefaultInstance(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse getDefaultInstanceForType() { + return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.getDefaultInstance(); } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse build() { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse result = buildPartial(); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse build() { + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse result = buildPartial(); if (!result.isInitialized()) { throw newUninitializedMessageException(result); } return result; } - public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse buildPartial() { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse result = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse(this); + public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse buildPartial() { + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse result = new org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse(this); int from_bitField0_ = bitField0_; int to_bitField0_ = 0; if (((from_bitField0_ & 0x00000001) == 0x00000001)) { to_bitField0_ |= 0x00000001; } - result.closed_ = closed_; + result.lastFlushTime_ = lastFlushTime_; + if (((from_bitField0_ & 0x00000002) == 0x00000002)) { + to_bitField0_ |= 0x00000002; + } + result.flushed_ = flushed_; + if (((from_bitField0_ & 0x00000004) == 0x00000004)) { + to_bitField0_ |= 0x00000004; + } + result.wroteFlushWalMarker_ = wroteFlushWalMarker_; result.bitField0_ = to_bitField0_; onBuilt(); return result; @@ -10530,18 +10924,24 @@ public final class AdminProtos { return (Builder) super.addRepeatedField(field, value); } public Builder mergeFrom(org.apache.hadoop.hbase.shaded.com.google.protobuf.Message other) { - if (other instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse) { - return mergeFrom((org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse)other); + if (other instanceof org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse) { + return mergeFrom((org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse)other); } else { super.mergeFrom(other); return this; } } - public Builder mergeFrom(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse other) { - if (other == org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse.getDefaultInstance()) return this; - if (other.hasClosed()) { - setClosed(other.getClosed()); + public Builder mergeFrom(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse other) { + if (other == org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse.getDefaultInstance()) return this; + if (other.hasLastFlushTime()) { + setLastFlushTime(other.getLastFlushTime()); + } + if (other.hasFlushed()) { + setFlushed(other.getFlushed()); + } + if (other.hasWroteFlushWalMarker()) { + setWroteFlushWalMarker(other.getWroteFlushWalMarker()); } this.mergeUnknownFields(other.unknownFields); onChanged(); @@ -10549,7 +10949,7 @@ public final class AdminProtos { } public final boolean isInitialized() { - if (!hasClosed()) { + if (!hasLastFlushTime()) { return false; } return true; @@ -10559,11 +10959,11 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws java.io.IOException { - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse parsedMessage = null; + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse parsedMessage = null; try { parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry); } catch (org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException e) { - parsedMessage = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionForSplitOrMergeResponse) e.getUnfinishedMessage(); + parsedMessage = (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse) e.getUnfinishedMessage(); throw e.unwrapIOException(); } finally { if (parsedMessage != null) { @@ -10574,34 +10974,98 @@ public final class AdminProtos { } private int bitField0_; - private boolean closed_ ; + private long lastFlushTime_ ; /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - public boolean hasClosed() { + public boolean hasLastFlushTime() { return ((bitField0_ & 0x00000001) == 0x00000001); } /** - * <code>required bool closed = 1;</code> + * <code>required uint64 last_flush_time = 1;</code> */ - public boolean getClosed() { - return closed_; + public long getLastFlushTime() { + return la
<TRUNCATED>