From 5b10ef76a7c9f6b0a04fc36b135419de51c813dd Mon Sep 17 00:00:00 2001 From: libisthanks Date: Thu, 14 Sep 2017 09:58:34 +0800 Subject: [PATCH] HBASE-18814 Make ScanMetrics enabled and add counter into the MapReduce Job over snapshot --- .../org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java | 1 + .../java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java | 1 + 2 files changed, 2 insertions(+) diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java index 169b383..9f2cd21 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java @@ -216,6 +216,7 @@ public class TableSnapshotInputFormatImpl { scan.setIsolationLevel(IsolationLevel.READ_UNCOMMITTED); // disable caching of data blocks scan.setCacheBlocks(false); + scan.setScanMetricsEnabled(true); scanner = new ClientSideRegionScanner(conf, fs, new Path(split.restoreDir), htd, hri, scan, null); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java index fb32451..e971ff8 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/client/ClientSideRegionScanner.java @@ -87,6 +87,7 @@ public class ClientSideRegionScanner extends AbstractClientScanner { resultSize += CellUtil.estimatedSerializedSizeOf(cell); } this.scanMetrics.countOfBytesInResults.addAndGet(resultSize); + this.scanMetrics.countOfRowsScanned.incrementAndGet(); } return result; -- 1.9.3 (Apple Git-50)