Package org.apache.hadoop.hbase.client

Class TestFromClientSideScanExcpetion

java.lang.Object

org.apache.hadoop.hbase.client.TestFromClientSideScanExcpetion

Direct Known Subclasses:

TestFromClientSideScanExcpetionWithCoprocessor

public class TestFromClientSideScanExcpetion
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestFromClientSideScanExcpetion.MyHRegion
static final class	TestFromClientSideScanExcpetion.MyHStore
static final class	TestFromClientSideScanExcpetion.MyStoreScanner

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
private static AtomicBoolean	IS_DO_NOT_RETRY
org.junit.rules.TestName	name
private static AtomicBoolean	ON
private static AtomicLong	REQ_COUNT
private static int	SLAVES
protected static final HBaseTestingUtil	TEST_UTIL
private static AtomicBoolean	THROW_ONCE

Constructor Summary

Constructors

Constructor	Description
TestFromClientSideScanExcpetion()

Method Summary

Modifier and Type	Method	Description
private static void	inject()
private static void	reset()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testClientScannerIsResetWhenScanThrowsIOException()	Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state.
void	testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE()	Tests the case where a coprocessor throws a regular IOException in the scan.
void	testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE()	Tests the case where a coprocessor throws a DoNotRetryIOException in the scan.

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

FAMILY

private static byte[] FAMILY

SLAVES

private static int SLAVES

name

public org.junit.rules.TestName name

ON

private static AtomicBoolean ON

REQ_COUNT

private static AtomicLong REQ_COUNT

IS_DO_NOT_RETRY

private static AtomicBoolean IS_DO_NOT_RETRY

THROW_ONCE

private static AtomicBoolean THROW_ONCE

Constructor Details

TestFromClientSideScanExcpetion

public TestFromClientSideScanExcpetion()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

reset

private static void reset()

inject

private static void inject()

testClientScannerIsResetWhenScanThrowsIOException

public void testClientScannerIsResetWhenScanThrowsIOException()
                                                       throws IOException,
InterruptedException

Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state. The client has to ensure that the ClientScanner does not get an exception and also sees all the data.

Throws:

IOException

InterruptedException

testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE

public void testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE()
                                                           throws IOException,
InterruptedException

Tests the case where a coprocessor throws a DoNotRetryIOException in the scan. The expectation is that the exception will bubble up to the client scanner instead of being retried.

Throws:

IOException

InterruptedException

testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE

public void testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE()
                                                          throws IOException,
InterruptedException

Tests the case where a coprocessor throws a regular IOException in the scan. The expectation is that the we will keep on retrying, but fail after the retries are exhausted instead of retrying indefinitely.

Throws:

IOException

InterruptedException