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

HBASE-10135 Remove ? extends from HLogSplitter#getOutputCounts 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1550359 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
eclark 2013-12-12 07:03:12 +00:00
parent a28881da2d
commit 1c266f876a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java
View File

@ -1044,7 +1044,7 @@ public class HLogSplitter {
}); });
CompletionService<Void> completionService = CompletionService<Void> completionService =
new ExecutorCompletionService<Void>(closeThreadPool); new ExecutorCompletionService<Void>(closeThreadPool);
for (final Map.Entry<byte[], ? extends SinkWriter> writersEntry : writers.entrySet()) { for (final Map.Entry<byte[], SinkWriter> writersEntry : writers.entrySet()) {
LOG.debug("Submitting close of " + ((WriterAndPath)writersEntry.getValue()).p); LOG.debug("Submitting close of " + ((WriterAndPath)writersEntry.getValue()).p);
completionService.submit(new Callable<Void>() { completionService.submit(new Callable<Void>() {
public Void call() throws Exception { public Void call() throws Exception {
@ -1260,7 +1260,7 @@ public class HLogSplitter {
Map<byte[], Long> getOutputCounts() { Map<byte[], Long> getOutputCounts() {
TreeMap<byte[], Long> ret = new TreeMap<byte[], Long>(Bytes.BYTES_COMPARATOR); TreeMap<byte[], Long> ret = new TreeMap<byte[], Long>(Bytes.BYTES_COMPARATOR);
synchronized (writers) { synchronized (writers) {
for (Map.Entry<byte[], ? extends SinkWriter> entry : writers.entrySet()) { for (Map.Entry<byte[], SinkWriter> entry : writers.entrySet()) {
ret.put(entry.getKey(), entry.getValue().editsWritten); ret.put(entry.getKey(), entry.getValue().editsWritten);
} }
} }