public class TestStateMachineProcedure extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TestStateMachineProcedure.SimpleChildProcedure |
static class |
TestStateMachineProcedure.TestProcEnv |
static class |
TestStateMachineProcedure.TestSMProcedure |
static class |
TestStateMachineProcedure.TestSMProcedureBadRollback |
static class |
TestStateMachineProcedure.TestSMProcedureState |
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 org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestStateMachineProcedure.TestProcEnv> |
procExecutor |
private org.apache.hadoop.hbase.procedure2.store.ProcedureStore |
procStore |
private static Exception |
TEST_FAILURE_EXCEPTION |
private org.apache.hadoop.fs.Path |
testDir |
Constructor and Description |
---|
TestStateMachineProcedure() |
Modifier and Type | Method and Description |
---|---|
void |
setUp() |
void |
tearDown() |
void |
testAbortStuckProcedure() |
void |
testChildBadRollbackStateCount() |
void |
testChildNormalRollbackStateCount() |
void |
testChildOnLastStep() |
void |
testChildOnLastStepDoubleExecution() |
void |
testChildOnLastStepWithRollback() |
void |
testChildOnLastStepWithRollbackDoubleExecution() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final Exception TEST_FAILURE_EXCEPTION
private static final int PROCEDURE_EXECUTOR_SLOTS
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestStateMachineProcedure.TestProcEnv> procExecutor
private org.apache.hadoop.hbase.procedure2.store.ProcedureStore procStore
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 TestStateMachineProcedure()
public void setUp() throws IOException
IOException
public void tearDown() throws IOException
IOException
public void testAbortStuckProcedure() throws InterruptedException
InterruptedException
public void testChildOnLastStep()
public void testChildOnLastStepDoubleExecution() throws Exception
Exception
public void testChildOnLastStepWithRollback()
public void testChildNormalRollbackStateCount()
public void testChildBadRollbackStateCount()
public void testChildOnLastStepWithRollbackDoubleExecution() throws Exception
Exception
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.