aboutsummaryrefslogtreecommitdiffstats
path: root/src/test/java
diff options
context:
space:
mode:
authorChandan Rajah <crajah@parallelai.com>2013-08-07 11:37:13 +0100
committerChandan Rajah <crajah@parallelai.com>2013-08-07 11:37:13 +0100
commit9a9f51c9eea317f5d28e6bc2f930b45159e7bb57 (patch)
treed829ee927f230b26c45afd1d0e67253b25c2f114 /src/test/java
parentde38789a032b586b0e278a81dedb5c8fb6d43e02 (diff)
downloadSpyGlass-9a9f51c9eea317f5d28e6bc2f930b45159e7bb57.tar.gz
SpyGlass-9a9f51c9eea317f5d28e6bc2f930b45159e7bb57.zip
Added testing code for multi input splits
Diffstat (limited to 'src/test/java')
-rw-r--r--src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java22
1 files changed, 11 insertions, 11 deletions
diff --git a/src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java b/src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java
index 34d7ab4..1f4c8e7 100644
--- a/src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java
+++ b/src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java
@@ -96,7 +96,7 @@ public class HBaseSalterTester {
public void getAllKeysWithPrefixAndRange() throws IOException {
String keyStr = "1021";
byte [] keyBytes = Bytes.toBytes(keyStr);
- String prefix = "1234";
+ String prefix = "12345";
String fullPrefix = "0123456789";
char [] prefixArr = prefix.toCharArray();
@@ -163,7 +163,7 @@ public class HBaseSalterTester {
public void getAllKeysWithPrefixWithStop() throws IOException {
String keyStr = "1021";
byte [] keyBytes = Bytes.toBytes(keyStr);
- String prefix = "01234";
+ String prefix = "012345";
String fullPrefix = "0123456789";
char [] prefixArr = prefix.toCharArray();
@@ -276,7 +276,7 @@ public class HBaseSalterTester {
byte [] regionStart = Bytes.toBytes("1");
byte [] regionsStop = Bytes.toBytes("4");
- String expectedPrefix = "123";
+ String expectedPrefix = "1234";
char [] prefixArr = expectedPrefix.toCharArray();
byte [][] expectedStart = new byte[prefixArr.length][];
@@ -312,7 +312,7 @@ public class HBaseSalterTester {
getDistributedIntervalsWithRegionsStartStopWithPrefix(
"1020", "1021",
"1_1021", "3_1023",
- "12", "012345"
+ "123", "012345"
);
System.out.println("------------ TEST 21 --------------");
@@ -326,7 +326,7 @@ public class HBaseSalterTester {
getDistributedIntervalsWithRegionsStartStopWithPrefix(
"1020", "1021",
Bytes.toString(HConstants.EMPTY_START_ROW), "3_1023",
- "012", "012345"
+ "0123", "012345"
);
System.out.println("------------ TEST 23 --------------");
@@ -340,42 +340,42 @@ public class HBaseSalterTester {
getDistributedIntervalsWithRegionsStartStopWithPrefix(
Bytes.toString(HConstants.EMPTY_START_ROW), "1021",
"1_1021", "3_1023",
- "12", "012345"
+ "123", "012345"
);
System.out.println("------------ TEST 25 --------------");
getDistributedIntervalsWithRegionsStartStopWithPrefix(
"1020", Bytes.toString(HConstants.EMPTY_END_ROW),
"1_1021", "3_1023",
- "12", "012345"
+ "123", "012345"
);
System.out.println("------------ TEST 26 --------------");
getDistributedIntervalsWithRegionsStartStopWithPrefix(
Bytes.toString(HConstants.EMPTY_START_ROW), Bytes.toString(HConstants.EMPTY_END_ROW),
"1_1021", "3_1023",
- "12", "012345"
+ "123", "012345"
);
System.out.println("------------ TEST 27 --------------");
getDistributedIntervalsWithRegionsStartStopWithPrefix(
Bytes.toString(HConstants.EMPTY_START_ROW), "1021",
Bytes.toString(HConstants.EMPTY_START_ROW), "3_1023",
- "012", "012345"
+ "0123", "012345"
);
System.out.println("------------ TEST 28 --------------");
getDistributedIntervalsWithRegionsStartStopWithPrefix(
"1020", Bytes.toString(HConstants.EMPTY_END_ROW),
Bytes.toString(HConstants.EMPTY_START_ROW), "3_1023",
- "012", "012345"
+ "0123", "012345"
);
System.out.println("------------ TEST 29 --------------");
getDistributedIntervalsWithRegionsStartStopWithPrefix(
Bytes.toString(HConstants.EMPTY_START_ROW), Bytes.toString(HConstants.EMPTY_END_ROW),
Bytes.toString(HConstants.EMPTY_START_ROW), "3_1023",
- "012", "012345"
+ "0123", "012345"
);
System.out.println("------------ TEST 30 --------------");