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
IOException
public void tearDown() throws IOException
IOException
public void testNoopLoad() throws Exception
Exception
public void testSingleStepProcRecovery() throws Exception
Exception
public void testMultiStepProcRecovery() throws Exception
Exception
public void testMultiStepRollbackRecovery() throws Exception
Exception
public void testStateMachineMultipleLevel() throws Exception
Exception
public void testStateMachineRecovery() throws Exception
Exception
public void testStateMachineRollbackRecovery() throws Exception
Exception
private void waitProcedure(long procId)
private void dumpLogDirState()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.