public class TestSecureBulkLoadManager extends Object
Modifier and Type | Class and Description |
---|---|
(package private) class |
TestSecureBulkLoadManager.MyExceptionToAvoidRetry
A trick is used to make sure server-side failures( if any ) not being covered up by a client
retry.
|
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
COLUMN |
private static org.apache.hadoop.conf.Configuration |
conf |
private Thread |
ealierBulkload |
private static byte[] |
FAMILY |
private static byte[] |
key1 |
private static byte[] |
key2 |
private static byte[] |
key3 |
private Thread |
laterBulkload |
private static org.slf4j.Logger |
LOG |
private static byte[] |
SPLIT_ROWKEY |
private static org.apache.hadoop.hbase.TableName |
TABLE |
protected static HBaseTestingUtility |
testUtil |
private static byte[] |
value1 |
private static byte[] |
value3 |
Constructor and Description |
---|
TestSecureBulkLoadManager() |
Modifier and Type | Method and Description |
---|---|
private void |
doBulkloadWithoutRetry(org.apache.hadoop.fs.Path dir) |
private void |
prepareHFile(org.apache.hadoop.fs.Path dir,
byte[] key,
byte[] value) |
static void |
setUp() |
static void |
tearDown() |
void |
testForRaceCondition()
After a secure bulkload finished , there is a clean-up for FileSystems used in the bulkload.
|
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static org.apache.hadoop.hbase.TableName TABLE
private static byte[] FAMILY
private static byte[] COLUMN
private static byte[] key1
private static byte[] key2
private static byte[] key3
private static byte[] value1
private static byte[] value3
private static byte[] SPLIT_ROWKEY
private Thread ealierBulkload
private Thread laterBulkload
protected static final HBaseTestingUtility testUtil
private static org.apache.hadoop.conf.Configuration conf
public TestSecureBulkLoadManager()
public void testForRaceCondition() throws Exception
Exception
private void doBulkloadWithoutRetry(org.apache.hadoop.fs.Path dir) throws Exception
Exception
private void prepareHFile(org.apache.hadoop.fs.Path dir, byte[] key, byte[] value) throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.