Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-26490 Add builder for class ReplicationLoadSink (#3883) 

Signed-off-by: Reid Chan <reidchan@apache.org>
Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
Yutong Xiao 2021-12-04 23:00:22 +08:00 committed by Duo Zhang
parent 45347bb81a
commit 02fa0903a2
2 changed files with 47 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationLoadSink.java
View File

@ -22,9 +22,7 @@ public class ReplicationLoadSink {
private final long timestampStarted; private final long timestampStarted;
private final long totalOpsProcessed; private final long totalOpsProcessed;
// TODO: add the builder for this class private ReplicationLoadSink(long age, long timestamp, long timestampStarted,
@InterfaceAudience.Private
public ReplicationLoadSink(long age, long timestamp, long timestampStarted,
long totalOpsProcessed) { long totalOpsProcessed) {
this.ageOfLastAppliedOp = age; this.ageOfLastAppliedOp = age;
this.timestampsOfLastAppliedOp = timestamp; this.timestampsOfLastAppliedOp = timestamp;
@ -56,4 +54,44 @@ public class ReplicationLoadSink {
public long getTotalOpsProcessed() { public long getTotalOpsProcessed() {
return totalOpsProcessed; return totalOpsProcessed;
} }
@InterfaceAudience.Private
public static ReplicationLoadSinkBuilder newBuilder() {
return new ReplicationLoadSinkBuilder();
}
@InterfaceAudience.Private
public static final class ReplicationLoadSinkBuilder {
private long ageOfLastAppliedOp;
private long timestampsOfLastAppliedOp;
private long timestampStarted;
private long totalOpsProcessed;
private ReplicationLoadSinkBuilder() {}
public ReplicationLoadSinkBuilder setAgeOfLastAppliedOp(long ageOfLastAppliedOp) {
this.ageOfLastAppliedOp = ageOfLastAppliedOp;
return this;
}
public ReplicationLoadSinkBuilder setTimestampsOfLastAppliedOp(long timestampsOfLastAppliedOp) {
this.timestampsOfLastAppliedOp = timestampsOfLastAppliedOp;
return this;
}
public ReplicationLoadSinkBuilder setTimestampStarted(long timestampStarted) {
this.timestampStarted = timestampStarted;
return this;
}
public ReplicationLoadSinkBuilder setTotalOpsProcessed(long totalOpsProcessed) {
this.totalOpsProcessed = totalOpsProcessed;
return this;
}
public ReplicationLoadSink build() {
return new ReplicationLoadSink(ageOfLastAppliedOp, timestampsOfLastAppliedOp,
timestampStarted, totalOpsProcessed);
}
}
} }

10
hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java
View File

@ -2796,10 +2796,12 @@ public final class ProtobufUtil {
public static ReplicationLoadSink toReplicationLoadSink( public static ReplicationLoadSink toReplicationLoadSink(
ClusterStatusProtos.ReplicationLoadSink rls) { ClusterStatusProtos.ReplicationLoadSink rls) {
return new ReplicationLoadSink(rls.getAgeOfLastAppliedOp(), ReplicationLoadSink.ReplicationLoadSinkBuilder builder = ReplicationLoadSink.newBuilder();
rls.getTimeStampsOfLastAppliedOp(), builder.setAgeOfLastAppliedOp(rls.getAgeOfLastAppliedOp()).
rls.hasTimestampStarted()? rls.getTimestampStarted(): -1L, setTimestampsOfLastAppliedOp(rls.getTimeStampsOfLastAppliedOp()).
rls.hasTotalOpsProcessed()? rls.getTotalOpsProcessed(): -1L); setTimestampStarted(rls.hasTimestampStarted()? rls.getTimestampStarted(): -1L).
setTotalOpsProcessed(rls.hasTotalOpsProcessed()? rls.getTotalOpsProcessed(): -1L);
return builder.build();
} }
public static ReplicationLoadSource toReplicationLoadSource( public static ReplicationLoadSource toReplicationLoadSource(