Package 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

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestSaslFanOutOneBlockAsyncDFSOutput
extends AsyncFSTestBase

Field Summary

Fields

Modifier and Type	Field	Description
private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	CHANNEL_CLASS
private String	cipherSuite
private 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 final File	KEYTAB_FILE
private static final org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor	MONITOR
private static String	PRINCIPAL
private 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	Description
TestSaslFanOutOneBlockAsyncDFSOutput(String protection, String encryptionAlgorithm, String cipherSuite)

Method Summary

Modifier and Type	Method	Description
private void	createEncryptionZone()
private org.apache.hadoop.fs.Path	getEncryptionTestFile()
private org.apache.hadoop.fs.Path	getTestFile()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
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 Details

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

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

protection

private String protection

encryptionAlgorithm

private String encryptionAlgorithm

cipherSuite

private String cipherSuite

testDirOnTestFs

private org.apache.hadoop.fs.Path testDirOnTestFs

entryptionTestDirOnTestFs

private org.apache.hadoop.fs.Path entryptionTestDirOnTestFs

Constructor Details

TestSaslFanOutOneBlockAsyncDFSOutput

public TestSaslFanOutOneBlockAsyncDFSOutput(String protection,
 String encryptionAlgorithm,
 String cipherSuite)

Method Details

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

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

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

createEncryptionZone

private void createEncryptionZone()
                           throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
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

@TestTemplate
public void test()
          throws Exception

Throws:

Exception