public class TestProcedureRecovery extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
TestProcedureRecovery.BaseTestStepProcedure |
static class |
TestProcedureRecovery.TestMultiStepProcedure |
private static class |
TestProcedureRecovery.TestProcEnv |
static class |
TestProcedureRecovery.TestSingleStepProcedure |
static class |
TestProcedureRecovery.TestStateMachineProcedure |
| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private org.apache.hadoop.fs.FileSystem |
fs |
private HBaseCommonTestingUtility |
htu |
private static org.slf4j.Logger |
LOG |
private org.apache.hadoop.fs.Path |
logDir |
private static int |
PROCEDURE_EXECUTOR_SLOTS |
private static TestProcedureRecovery.TestProcEnv |
procEnv |
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureRecovery.TestProcEnv> |
procExecutor |
private static int |
procSleepInterval |
private static org.apache.hadoop.hbase.procedure2.store.ProcedureStore |
procStore |
private org.apache.hadoop.fs.Path |
testDir |
| Constructor and Description |
|---|
TestProcedureRecovery() |
| Modifier and Type | Method and Description |
|---|---|
private void |
dumpLogDirState() |
private void |
restart() |
void |
setUp() |
void |
tearDown() |
void |
testMultiStepProcRecovery() |
void |
testMultiStepRollbackRecovery() |
void |
testNoopLoad() |
void |
testSingleStepProcRecovery() |
void |
testStateMachineMultipleLevel() |
void |
testStateMachineRecovery() |
void |
testStateMachineRollbackRecovery() |
private void |
waitProcedure(long procId) |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final int PROCEDURE_EXECUTOR_SLOTS
private static TestProcedureRecovery.TestProcEnv procEnv
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureRecovery.TestProcEnv> procExecutor
private static org.apache.hadoop.hbase.procedure2.store.ProcedureStore procStore
private static int procSleepInterval
private HBaseCommonTestingUtility htu
private org.apache.hadoop.fs.FileSystem fs
private org.apache.hadoop.fs.Path testDir
private org.apache.hadoop.fs.Path logDir
public TestProcedureRecovery()
public void setUp() throws IOException
IOExceptionpublic void tearDown() throws IOException
IOExceptionpublic void testNoopLoad() throws Exception
Exceptionpublic void testSingleStepProcRecovery() throws Exception
Exceptionpublic void testMultiStepProcRecovery() throws Exception
Exceptionpublic void testMultiStepRollbackRecovery() throws Exception
Exceptionpublic void testStateMachineMultipleLevel() throws Exception
Exceptionpublic void testStateMachineRecovery() throws Exception
Exceptionpublic void testStateMachineRollbackRecovery() throws Exception
Exceptionprivate void waitProcedure(long procId)
private void dumpLogDirState()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.