Package org.apache.hadoop.hbase.procedure2

Class TestProcedureEvents

java.lang.Object

org.apache.hadoop.hbase.procedure2.TestProcedureEvents

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestProcedureEvents
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	TestProcedureEvents.TestProcEnv
static class	TestProcedureEvents.TestTimeoutEventProcedure	This Event+Procedure exhibits following behavior: On procedure execute() If had enough timeouts, abort the procedure.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.fs.FileSystem	fs
private HBaseCommonTestingUtil	htu
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	logDir
private TestProcedureEvents.TestProcEnv	procEnv
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureEvents.TestProcEnv>	procExecutor
private org.apache.hadoop.hbase.procedure2.store.ProcedureStore	procStore

Constructor Summary

Constructors

Constructor	Description
TestProcedureEvents()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	tearDown()
void	testTimeoutEventProcedure()	Tests being able to suspend a Procedure for N timeouts and then failing.s Resets the timeout after each elapses.
void	testTimeoutEventProcedureDoubleExecution()
private void	testTimeoutEventProcedureDoubleExecution(boolean killIfSuspended)
void	testTimeoutEventProcedureDoubleExecutionKillIfSuspended()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

procEnv

private TestProcedureEvents.TestProcEnv procEnv

procStore

private org.apache.hadoop.hbase.procedure2.store.ProcedureStore procStore

procExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<TestProcedureEvents.TestProcEnv> procExecutor

htu

private HBaseCommonTestingUtil htu

fs

private org.apache.hadoop.fs.FileSystem fs

logDir

private org.apache.hadoop.fs.Path logDir

Constructor Details

TestProcedureEvents

public TestProcedureEvents()

Method Details

setUp

@BeforeEach
public void setUp()
           throws IOException

Throws:

IOException

tearDown

@AfterEach
public void tearDown()
              throws IOException

Throws:

IOException

testTimeoutEventProcedure

@Test
public void testTimeoutEventProcedure()
                               throws Exception

Tests being able to suspend a Procedure for N timeouts and then failing.s Resets the timeout after each elapses. See TestProcedureEvents.TestTimeoutEventProcedure for example of how to do this sort of trickery with the ProcedureExecutor; i.e. suspend for a while, check for a condition and if not set, suspend again, etc., ultimately failing or succeeding eventually.

Throws:

Exception

testTimeoutEventProcedureDoubleExecution

@Test
public void testTimeoutEventProcedureDoubleExecution()
                                              throws Exception

Throws:

Exception

testTimeoutEventProcedureDoubleExecutionKillIfSuspended

@Test
public void testTimeoutEventProcedureDoubleExecutionKillIfSuspended()
                                                             throws Exception

Throws:

Exception

testTimeoutEventProcedureDoubleExecution

private void testTimeoutEventProcedureDoubleExecution(boolean killIfSuspended)
                                               throws Exception

Throws:

Exception