You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2013/03/07 19:13:15 UTC
svn commit: r1453983 - in
/hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example:
TestBulkDeleteProtocol.java TestRowCountEndpoint.java
TestZooKeeperScanPolicyObserver.java
Author: stack
Date: Thu Mar 7 18:13:14 2013
New Revision: 1453983
URL: http://svn.apache.org/r1453983
Log:
HBASE-8027 hbase-7994 redux; shutdown hbase-example unit tests
Modified:
hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java
hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java
hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java
Modified: hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java?rev=1453983&r1=1453982&r2=1453983&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java (original)
+++ hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestBulkDeleteProtocol.java Thu Mar 7 18:13:14 2013
@@ -65,19 +65,19 @@ public class TestBulkDeleteProtocol {
private static final byte[] QUALIFIER3 = Bytes.toBytes("c3");
private static final HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
- @Ignore @BeforeClass
+ // @Ignore @BeforeClass
public static void setupBeforeClass() throws Exception {
TEST_UTIL.getConfiguration().set(CoprocessorHost.USER_REGION_COPROCESSOR_CONF_KEY,
BulkDeleteEndpoint.class.getName());
TEST_UTIL.startMiniCluster(2);
}
- @Ignore @AfterClass
+ // @Ignore @AfterClass
public static void tearDownAfterClass() throws Exception {
TEST_UTIL.shutdownMiniCluster();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteEndpoint() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteEndpoint");
HTable ht = createTable(tableName);
@@ -99,7 +99,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteEndpointWhenRowBatchSizeLessThanRowsToDeleteFromARegion()
throws Throwable {
byte[] tableName = Bytes
@@ -154,7 +154,7 @@ public class TestBulkDeleteProtocol {
return noOfDeletedRows;
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteWithConditionBasedDelete() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteWithConditionBasedDelete");
HTable ht = createTable(tableName);
@@ -184,7 +184,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteColumn() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteColumn");
HTable ht = createTable(tableName);
@@ -213,7 +213,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteFamily() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteFamily");
HTableDescriptor htd = new HTableDescriptor(tableName);
@@ -244,7 +244,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteColumnVersion() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersion");
HTable ht = createTable(tableName);
@@ -292,7 +292,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteColumnVersionBasedOnTS() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteColumnVersionBasedOnTS");
HTable ht = createTable(tableName);
@@ -339,7 +339,7 @@ public class TestBulkDeleteProtocol {
ht.close();
}
- @Ignore @Test
+ // @Ignore @Test
public void testBulkDeleteWithNumberOfVersions() throws Throwable {
byte[] tableName = Bytes.toBytes("testBulkDeleteWithNumberOfVersions");
HTable ht = createTable(tableName);
Modified: hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java?rev=1453983&r1=1453982&r2=1453983&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java (original)
+++ hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestRowCountEndpoint.java Thu Mar 7 18:13:14 2013
@@ -54,7 +54,7 @@ public class TestRowCountEndpoint {
private static HBaseTestingUtility TEST_UTIL = null;
private static Configuration CONF = null;
- @Ignore @BeforeClass
+ // @Ignore @BeforeClass
public static void setupBeforeClass() throws Exception {
TEST_UTIL = new HBaseTestingUtility();
CONF = TEST_UTIL.getConfiguration();
@@ -65,12 +65,12 @@ public class TestRowCountEndpoint {
TEST_UTIL.createTable(TEST_TABLE, TEST_FAMILY);
}
- @Ignore @AfterClass
+ // @Ignore @AfterClass
public static void tearDownAfterClass() throws Exception {
TEST_UTIL.shutdownMiniCluster();
}
- @Ignore @Test
+ // @Ignore @Test
public void testEndpoint() throws Throwable {
HTable table = new HTable(CONF, TEST_TABLE);
Modified: hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java?rev=1453983&r1=1453982&r2=1453983&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java (original)
+++ hbase/branches/0.95/hbase-examples/src/test/java/org/apache/hadoop/hbase/coprocessor/example/TestZooKeeperScanPolicyObserver.java Thu Mar 7 18:13:14 2013
@@ -52,8 +52,9 @@ public class TestZooKeeperScanPolicyObse
private static final byte[] Q = Bytes.toBytes("qual");
private static final byte[] R = Bytes.toBytes("row");
- @Ignore @BeforeClass
+ // @BeforeClass
public static void setUpBeforeClass() throws Exception {
+ System.out.println("HERE!!!!!!!!");
// Test we can first start the ZK cluster by itself
Configuration conf = TEST_UTIL.getConfiguration();
conf.setStrings(CoprocessorHost.REGION_COPROCESSOR_CONF_KEY,
@@ -62,12 +63,12 @@ public class TestZooKeeperScanPolicyObse
TEST_UTIL.startMiniCluster();
}
- @Ignore @AfterClass
+ // @AfterClass
public static void tearDownAfterClass() throws Exception {
TEST_UTIL.shutdownMiniCluster();
}
- @Ignore @Test
+ // @Ignore @Test
public void testScanPolicyObserver() throws Exception {
byte[] tableName = Bytes.toBytes("testScanPolicyObserver");
HTableDescriptor desc = new HTableDescriptor(tableName);