org.apache.hadoop.hbase.master

Class TestRollingRestart

java.lang.Object

org.apache.hadoop.hbase.master.TestRollingRestart

public class TestRollingRestart
extends Object

Tests the restarting of everything as done during rolling restarts.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
boolean	splitWALCoordinatedByZK

Constructor Summary

Constructors

Constructor and Description
TestRollingRestart()

Method Summary

Modifier and Type	Method and Description
private void	assertRegionsAssigned(MiniHBaseCluster cluster, Set<String> expectedRegions)
static Collection	coordinatedByZK()
private NavigableSet<String>	getDoubleAssignedRegions(MiniHBaseCluster cluster)
private int	getNumberOfOnlineRegions(MiniHBaseCluster cluster)
private void	log(String msg)
void	testBasicRollingRestart()
private void	waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster, org.apache.hadoop.hbase.ServerName serverName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

splitWALCoordinatedByZK

public boolean splitWALCoordinatedByZK

Constructor Detail

TestRollingRestart

public TestRollingRestart()

Method Detail

testBasicRollingRestart

public void testBasicRollingRestart()
                             throws Exception

Throws:

Exception

waitForRSShutdownToStartAndFinish

private void waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster,
                                               org.apache.hadoop.hbase.ServerName serverName)
                                        throws InterruptedException

Throws:

InterruptedException

log

private void log(String msg)

getNumberOfOnlineRegions

private int getNumberOfOnlineRegions(MiniHBaseCluster cluster)

assertRegionsAssigned

private void assertRegionsAssigned(MiniHBaseCluster cluster,
                                   Set<String> expectedRegions)
                            throws IOException

Throws:

IOException

getDoubleAssignedRegions

private NavigableSet<String> getDoubleAssignedRegions(MiniHBaseCluster cluster)
                                               throws IOException

Throws:

IOException

coordinatedByZK

public static Collection coordinatedByZK()