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

HBASE-7588 Fix two findbugs warning in MemStoreFlusher; REVERTED 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1437121 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2013-01-22 19:43:44 +00:00
parent 3b345cd684
commit c3e140cd14
1 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreFlusher.java
View File

@ -20,7 +20,6 @@ package org.apache.hadoop.hbase.regionserver;
import java.io.IOException; import java.io.IOException;
import java.lang.management.ManagementFactory; import java.lang.management.ManagementFactory;
import java.util.Arrays;
import java.util.ConcurrentModificationException; import java.util.ConcurrentModificationException;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;
@ -45,7 +44,6 @@ import org.apache.hadoop.hbase.RemoteExceptionHandler;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;
import org.apache.hadoop.hbase.util.HasThread; import org.apache.hadoop.hbase.util.HasThread;
import org.apache.hadoop.hbase.util.HashedBytes;
import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.util.StringUtils;
import org.cliffc.high_scale_lib.Counter; import org.cliffc.high_scale_lib.Counter;
@ -532,12 +530,6 @@ class MemStoreFlusher extends HasThread implements FlushRequester {
public int compareTo(Delayed o) { public int compareTo(Delayed o) {
return -1; return -1;
} }
@Override
public boolean equals(Object obj) {
return (this == obj);
}
} }
/** /**
@ -601,20 +593,9 @@ class MemStoreFlusher extends HasThread implements FlushRequester {
other.getDelay(TimeUnit.MILLISECONDS)).intValue(); other.getDelay(TimeUnit.MILLISECONDS)).intValue();
} }
@Override @Override
public String toString() { public String toString() {
return "[flush region " + Bytes.toStringBinary(region.getRegionName()) + "]"; return "[flush region " + Bytes.toStringBinary(region.getRegionName()) + "]";
} }
@Override
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null || getClass() != obj.getClass())
return false;
Delayed other = (Delayed) obj;
return compareTo(other) == 0;
}
} }
} }