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

HBASE-15171 Addendum removes extra loop (Yu Li)

This commit is contained in:
tedyu 2016-01-28 07:08:03 -08:00
parent 421fe24e9b
commit dfa9484137
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/PutSortReducer.java
View File

@ -66,12 +66,11 @@ public class PutSortReducer extends
for (List<Cell> cells: p.getFamilyCellMap().values()) { for (List<Cell> cells: p.getFamilyCellMap().values()) {
for (Cell cell: cells) { for (Cell cell: cells) {
KeyValue kv = KeyValueUtil.ensureKeyValueTypeForMR(cell); KeyValue kv = KeyValueUtil.ensureKeyValueTypeForMR(cell);
map.add(kv); if (map.add(kv)) {// don't count duplicated kv into size
curSize += kv.heapSize();
}
} }
} }
for(KeyValue kv: map){
curSize +=kv.heapSize();
}
} }
context.setStatus("Read " + map.size() + " entries of " + map.getClass() context.setStatus("Read " + map.size() + " entries of " + map.getClass()
+ "(" + StringUtils.humanReadableInt(curSize) + ")"); + "(" + StringUtils.humanReadableInt(curSize) + ")");