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

Amend HBASE-24350: Extending and Fixing HBaseTable level replication metrics (#1704) 

- Rename WALEntryBatch#getWaEntriesWithSize -> getWalEntriesWithSize
This commit is contained in:
Andrew Purtell 2020-05-14 13:41:56 -07:00
parent 7e295e767f
commit 94f36fdb8e
No known key found for this signature in database
GPG Key ID: 8597754DD5365CCD
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.java
View File

@ -221,7 +221,7 @@ public class ReplicationSourceShipper extends Thread {
entryBatch.getNbHFiles()); entryBatch.getNbHFiles());
source.getSourceMetrics().setAgeOfLastShippedOp( source.getSourceMetrics().setAgeOfLastShippedOp(
entries.get(entries.size() - 1).getKey().getWriteTime(), walGroupId); entries.get(entries.size() - 1).getKey().getWriteTime(), walGroupId);
source.getSourceMetrics().updateTableLevelMetrics(entryBatch.getWaEntriesWithSize()); source.getSourceMetrics().updateTableLevelMetrics(entryBatch.getWalEntriesWithSize());
if (LOG.isTraceEnabled()) { if (LOG.isTraceEnabled()) {
LOG.debug("Replicated {} entries or {} operations in {} ms", LOG.debug("Replicated {} entries or {} operations in {} ms",

2
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/WALEntryBatch.java
View File

@ -83,7 +83,7 @@ class WALEntryBatch {
/** /**
* @return the WAL Entries. * @return the WAL Entries.
*/ */
public List<Pair<Entry, Long>> getWaEntriesWithSize() { public List<Pair<Entry, Long>> getWalEntriesWithSize() {
return walEntriesWithSize; return walEntriesWithSize;
} }