diff options
| author | Chandan Rajah <crajah@parallelai.com> | 2013-08-07 11:37:13 +0100 | 
|---|---|---|
| committer | Chandan Rajah <crajah@parallelai.com> | 2013-08-07 11:37:13 +0100 | 
| commit | 9a9f51c9eea317f5d28e6bc2f930b45159e7bb57 (patch) | |
| tree | d829ee927f230b26c45afd1d0e67253b25c2f114 /src/test/java/parallelai | |
| parent | de38789a032b586b0e278a81dedb5c8fb6d43e02 (diff) | |
| download | SpyGlass-9a9f51c9eea317f5d28e6bc2f930b45159e7bb57.tar.gz SpyGlass-9a9f51c9eea317f5d28e6bc2f930b45159e7bb57.zip | |
Added testing code for multi input splits
Diffstat (limited to 'src/test/java/parallelai')
| -rw-r--r-- | src/test/java/parallelai/spyglass/hbase/HBaseSalterTester.java | 22 | 
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 --------------"); | 
