diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/HRegionInfo.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/HRegionInfo.java index 1c1ad999416..2bb375e800e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/HRegionInfo.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/HRegionInfo.java @@ -147,6 +147,9 @@ implements WritableComparable { return encodedRegionName; } + /** delimiter used between portions of a region name */ + public static final int DELIMITER = ','; + /** HRegionInfo for root region */ public static final HRegionInfo ROOT_REGIONINFO = new HRegionInfo(0L, Bytes.toBytes("-ROOT-")); @@ -360,12 +363,12 @@ implements WritableComparable { int offset = tableName.length; System.arraycopy(tableName, 0, b, 0, offset); - b[offset++] = HConstants.REGIONINFO_DELIMITER; + b[offset++] = DELIMITER; if (startKey != null && startKey.length > 0) { System.arraycopy(startKey, 0, b, offset, startKey.length); offset += startKey.length; } - b[offset++] = HConstants.REGIONINFO_DELIMITER; + b[offset++] = DELIMITER; System.arraycopy(id, 0, b, offset, id.length); offset += id.length; @@ -403,7 +406,7 @@ implements WritableComparable { public static byte [] getTableName(byte [] regionName) { int offset = -1; for (int i = 0; i < regionName.length; i++) { - if (regionName[i] == HConstants.REGIONINFO_DELIMITER) { + if (regionName[i] == DELIMITER) { offset = i; break; } @@ -423,7 +426,7 @@ implements WritableComparable { throws IOException { int offset = -1; for (int i = 0; i < regionName.length; i++) { - if (regionName[i] == HConstants.REGIONINFO_DELIMITER) { + if (regionName[i] == DELIMITER) { offset = i; break; } @@ -433,7 +436,7 @@ implements WritableComparable { System.arraycopy(regionName, 0, tableName, 0, offset); offset = -1; for (int i = regionName.length - 1; i > 0; i--) { - if(regionName[i] == HConstants.REGIONINFO_DELIMITER) { + if(regionName[i] == DELIMITER) { offset = i; break; } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/catalog/MetaReader.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/catalog/MetaReader.java index 8decd66622e..c3c7de8c2ee 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/catalog/MetaReader.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/catalog/MetaReader.java @@ -454,8 +454,8 @@ public class MetaReader { static byte [] getTableStartRowForMeta(final byte [] tableName) { byte [] startRow = new byte[tableName.length + 2]; System.arraycopy(tableName, 0, startRow, 0, tableName.length); - startRow[startRow.length - 2] = HConstants.REGIONINFO_DELIMITER; - startRow[startRow.length - 1] = HConstants.REGIONINFO_DELIMITER; + startRow[startRow.length - 2] = HRegionInfo.DELIMITER; + startRow[startRow.length - 1] = HRegionInfo.DELIMITER; return startRow; } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/GetClosestRowBeforeTracker.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/GetClosestRowBeforeTracker.java index 83b14239b8c..8174cf5e0cb 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/GetClosestRowBeforeTracker.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/GetClosestRowBeforeTracker.java @@ -25,7 +25,6 @@ import java.util.TreeMap; import java.util.TreeSet; import org.apache.hadoop.classification.InterfaceAudience; -import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HRegionInfo; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue.KVComparator; @@ -71,7 +70,7 @@ class GetClosestRowBeforeTracker { int l = -1; if (metaregion) { l = KeyValue.getDelimiter(kv.getBuffer(), rowoffset, kv.getRowLength(), - HConstants.REGIONINFO_DELIMITER) - this.rowoffset; + HRegionInfo.DELIMITER) - this.rowoffset; } this.tablenamePlusDelimiterLength = metaregion? l + 1: -1; this.oldestts = System.currentTimeMillis() - ttl; diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java index 84d96527a54..99e2197cd73 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestGetClosestAtOrBefore.java @@ -166,9 +166,9 @@ public class TestGetClosestAtOrBefore extends HBaseTestCase { private byte [] extractRowFromMetaRow(final byte [] b) { int firstDelimiter = KeyValue.getDelimiter(b, 0, b.length, - HConstants.REGIONINFO_DELIMITER); + HRegionInfo.DELIMITER); int lastDelimiter = KeyValue.getDelimiterInReverse(b, 0, b.length, - HConstants.REGIONINFO_DELIMITER); + HRegionInfo.DELIMITER); int length = lastDelimiter - firstDelimiter - 1; byte [] row = new byte[length]; System.arraycopy(b, firstDelimiter + 1, row, 0, length); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreFile.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreFile.java index e8232282f55..2669cdbc86f 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreFile.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestStoreFile.java @@ -369,7 +369,7 @@ public class TestStoreFile extends HBaseTestCase { int falseNeg = 0; for (int i = 0; i < 2000; i++) { String row = String.format(localFormatter, i); - TreeSet columns = new TreeSet(Bytes.BYTES_COMPARATOR); + TreeSet columns = new TreeSet(); columns.add("family:col".getBytes()); Scan scan = new Scan(row.getBytes(),row.getBytes()); @@ -528,7 +528,7 @@ public class TestStoreFile extends HBaseTestCase { for (int j = 0; j < colCount*2; ++j) { // column qualifiers String row = String.format(localFormatter, i); String col = String.format(localFormatter, j); - TreeSet columns = new TreeSet(Bytes.BYTES_COMPARATOR); + TreeSet columns = new TreeSet(); columns.add(("col" + col).getBytes()); Scan scan = new Scan(row.getBytes(),row.getBytes()); @@ -712,7 +712,7 @@ public class TestStoreFile extends HBaseTestCase { StoreFile.BloomType.NONE, NoOpDataBlockEncoder.INSTANCE); StoreFile.Reader reader = hsf.createReader(); StoreFileScanner scanner = reader.getStoreFileScanner(false, false); - TreeSet columns = new TreeSet(Bytes.BYTES_COMPARATOR); + TreeSet columns = new TreeSet(); columns.add(qualifier); scan.setTimeRange(20, 100);