You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2017/05/26 23:48:04 UTC
[56/59] [abbrv] hbase git commit: HBASE-14614 Procedure v2 - Core
Assignment Manager (Matteo Bertozzi) Move to a new AssignmentManager,
one that describes Assignment using a State Machine built on top of
ProcedureV2 facility.
http://git-wip-us.apache.org/repos/asf/hbase/blob/1e82848a/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>