org.apache.hadoop.hbase.io.asyncfs

Class TestSaslFanOutOneBlockAsyncDFSOutput

java.lang.Object

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

org.apache.hadoop.hbase.io.asyncfs.TestSaslFanOutOneBlockAsyncDFSOutput

public class TestSaslFanOutOneBlockAsyncDFSOutput
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
String	cipherSuite
static HBaseClassTestRule	CLASS_RULE
String	encryptionAlgorithm
private org.apache.hadoop.fs.Path	entryptionTestDirOnTestFs
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	EVENT_LOOP_GROUP
private static org.apache.hadoop.hdfs.DistributedFileSystem	FS
private static String	HOST
private static String	HTTP_PRINCIPAL
private static org.apache.hadoop.minikdc.MiniKdc	KDC
private static File	KEYTAB_FILE
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor	MONITOR
org.junit.rules.TestName	name
private static String	PRINCIPAL
String	protection
private static int	READ_TIMEOUT_MS
private static String	TEST_KEY_NAME
private org.apache.hadoop.fs.Path	testDirOnTestFs
private static String	USERNAME

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

CLUSTER, CLUSTER_TEST_DIR, UTIL

Constructor Summary

Constructors

Constructor and Description
TestSaslFanOutOneBlockAsyncDFSOutput()

Method Summary

Modifier and Type	Method and Description
private void	createEncryptionZone()
static Iterable<Object[]>	data()
private org.apache.hadoop.fs.Path	getEncryptionTestFile()
private org.apache.hadoop.fs.Path	getTestFile()
void	setUp()
static void	setUpBeforeClass()
private static void	setUpKeyProvider(org.apache.hadoop.conf.Configuration conf)
private static org.apache.hadoop.minikdc.MiniKdc	setupMiniKdc(File keytabFile) Sets up MiniKdc for testing security.
void	tearDown()
static void	tearDownAfterClass()
void	test()
private void	test(org.apache.hadoop.fs.Path file)

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

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

KEYTAB_FILE

private static final File KEYTAB_FILE

KDC

private static org.apache.hadoop.minikdc.MiniKdc KDC

HOST

private static String HOST

USERNAME

private static String USERNAME

PRINCIPAL

private static String PRINCIPAL

HTTP_PRINCIPAL

private static String HTTP_PRINCIPAL

TEST_KEY_NAME

private static String TEST_KEY_NAME

MONITOR

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

name

public org.junit.rules.TestName name

protection

public String protection

encryptionAlgorithm

public String encryptionAlgorithm

cipherSuite

public String cipherSuite

testDirOnTestFs

private org.apache.hadoop.fs.Path testDirOnTestFs

entryptionTestDirOnTestFs

private org.apache.hadoop.fs.Path entryptionTestDirOnTestFs

Constructor Detail

TestSaslFanOutOneBlockAsyncDFSOutput

public TestSaslFanOutOneBlockAsyncDFSOutput()

Method Detail

data

public static Iterable<Object[]> data()

setUpKeyProvider

private static void setUpKeyProvider(org.apache.hadoop.conf.Configuration conf)
                              throws Exception

Throws:

Exception

setupMiniKdc

private static org.apache.hadoop.minikdc.MiniKdc setupMiniKdc(File keytabFile)
                                                       throws Exception

Sets up MiniKdc for testing security. Uses HBaseKerberosUtils to set the given keytab file as HBaseKerberosUtils.KRB_KEYTAB_FILE.

Throws:

Exception

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

createEncryptionZone

private void createEncryptionZone()
                           throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

getTestFile

private org.apache.hadoop.fs.Path getTestFile()

getEncryptionTestFile

private org.apache.hadoop.fs.Path getEncryptionTestFile()

test

private void test(org.apache.hadoop.fs.Path file)
           throws IOException,
                  InterruptedException,
                  ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

test

public void test()
          throws IOException,
                 InterruptedException,
                 ExecutionException

Throws:

IOException

InterruptedException

ExecutionException