org.apache.hadoop.hbase.io.asyncfs

Class TestFanOutOneBlockAsyncDFSOutput

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

org.apache.hadoop.hbase.io.asyncfs.TestFanOutOneBlockAsyncDFSOutput

public class TestFanOutOneBlockAsyncDFSOutput
extends AsyncFSTestBase

Field Summary

Fields

Modifier and Type	Field and Description
private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	CHANNEL_CLASS
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	EVENT_LOOP_GROUP
private static org.apache.hadoop.hdfs.DistributedFileSystem	FS
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor	MONITOR
org.junit.rules.TestName	name
private static int	READ_TIMEOUT_MS
private static Random	RNG

Fields inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

CLUSTER, CLUSTER_TEST_DIR, UTIL

Constructor Summary

Constructors

Constructor and Description
TestFanOutOneBlockAsyncDFSOutput()

Method Summary

Modifier and Type	Method and Description
static void	setUp()
static void	tearDown()
void	test()
void	testConnectToDatanodeFailed()
void	testCreateParentFailed() This is important for fencing when recover from RS crash.
void	testExcludeFailedConnectToDatanode()
void	testHeartbeat()
void	testRecover()
void	testWriteLargeChunk()
(package private) static void	writeAndVerify(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path f, org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutput out)

Methods inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

setupClusterTestDir, shutdownMiniDFSCluster, startMiniDFSCluster

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

FS

private static org.apache.hadoop.hdfs.DistributedFileSystem FS

EVENT_LOOP_GROUP

private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup EVENT_LOOP_GROUP

CHANNEL_CLASS

private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> CHANNEL_CLASS

READ_TIMEOUT_MS

private static int READ_TIMEOUT_MS

MONITOR

private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor MONITOR

name

public org.junit.rules.TestName name

RNG

private static final Random RNG

Constructor Detail

TestFanOutOneBlockAsyncDFSOutput

public TestFanOutOneBlockAsyncDFSOutput()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

writeAndVerify

static void writeAndVerify(org.apache.hadoop.fs.FileSystem fs,
                           org.apache.hadoop.fs.Path f,
                           org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutput out)
                    throws IOException,
                           InterruptedException,
                           ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

test

public void test()
          throws IOException,
                 InterruptedException,
                 ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testRecover

public void testRecover()
                 throws IOException,
                        InterruptedException,
                        ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testHeartbeat

public void testHeartbeat()
                   throws IOException,
                          InterruptedException,
                          ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testCreateParentFailed

public void testCreateParentFailed()
                            throws IOException

This is important for fencing when recover from RS crash.

Throws:

IOException

testConnectToDatanodeFailed

public void testConnectToDatanodeFailed()
                                 throws IOException,
                                        ClassNotFoundException,
                                        NoSuchMethodException,
                                        IllegalAccessException,
                                        InvocationTargetException,
                                        InterruptedException,
                                        NoSuchFieldException

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testExcludeFailedConnectToDatanode

public void testExcludeFailedConnectToDatanode()
                                        throws IOException,
                                               ClassNotFoundException,
                                               NoSuchMethodException,
                                               IllegalAccessException,
                                               InvocationTargetException,
                                               InterruptedException,
                                               NoSuchFieldException

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testWriteLargeChunk

public void testWriteLargeChunk()
                         throws IOException,
                                InterruptedException,
                                ExecutionException

Throws:

IOException

InterruptedException

ExecutionException