aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorChandan Rajah <chandan.rajah@gmail.com>2013-06-26 17:13:42 +0100
committerChandan Rajah <chandan.rajah@gmail.com>2013-06-26 17:13:42 +0100
commite8ba249d5ce2ec293a4d19b54fc8298d4eac0271 (patch)
tree9f24162582cd5f41e7bd8216fcc8aad03a48fa7c /src/main/java
parentad8b3bd9fa2de833cecf33ff9b82580e675ac290 (diff)
downloadSpyGlass-e8ba249d5ce2ec293a4d19b54fc8298d4eac0271.tar.gz
SpyGlass-e8ba249d5ce2ec293a4d19b54fc8298d4eac0271.zip
Fixed minor bugs with HBase prefix salter
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/parallelai/spyglass/hbase/HBaseSalter.java13
1 files changed, 9 insertions, 4 deletions
diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseSalter.java b/src/main/java/parallelai/spyglass/hbase/HBaseSalter.java
index fc656a4..e3f5dc9 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseSalter.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseSalter.java
@@ -149,16 +149,21 @@ public class HBaseSalter {
public static byte[][] getAllKeysWithStop(byte[] originalKey, String prefixList, byte stopKey) throws IOException {
char[] prefixArray = prefixList.toCharArray();
-
- return getAllKeysWithStartStop(originalKey, prefixList, (byte)prefixArray[0], (byte)(stopKey - 1));
+
+ return getAllKeysWithStartStop(originalKey, prefixList, (byte)prefixArray[0], stopKey);
+// return getAllKeysWithStartStop(originalKey, prefixList, (byte)prefixArray[0], (byte)(stopKey - 1));
}
public static byte[][] getAllKeysInRange(byte[] originalKey, String prefixList, byte startPrefix, byte stopPrefix) {
- return getAllKeysWithStartStop(originalKey, prefixList, startPrefix, (byte)(stopPrefix - 1));
+ return getAllKeysWithStartStop(originalKey, prefixList, startPrefix, stopPrefix);
+// return getAllKeysWithStartStop(originalKey, prefixList, startPrefix, (byte)(stopPrefix - 1));
}
private static byte[][] getAllKeysWithStartStop(byte[] originalKey, String prefixList, byte startPrefix, byte stopPrefix) {
- char[] prefixArray = prefixList.toCharArray();
+ LOG.info("".format("getAllKeysWithStartStop: OKEY (%s) PLIST (%s) PSRT (%s) PSTP (%s)",
+ Bytes.toString(originalKey), prefixList, startPrefix, stopPrefix));
+
+ char[] prefixArray = prefixList.toCharArray();
TreeSet<Byte> prefixSet = new TreeSet<Byte>();
for( char c : prefixArray ) {