public class TestWALPlayer extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static SingleProcessHBaseCluster |
cluster |
private static org.apache.hadoop.conf.Configuration |
conf |
private static org.apache.hadoop.fs.FileSystem |
fs |
private static org.apache.hadoop.fs.FileSystem |
logFs |
org.junit.rules.TestName |
name |
private static org.apache.hadoop.fs.Path |
rootDir |
private static HBaseTestingUtil |
TEST_UTIL |
private static org.apache.hadoop.fs.Path |
walRootDir |
Constructor and Description |
---|
TestWALPlayer() |
Modifier and Type | Method and Description |
---|---|
static void |
afterClass() |
static void |
beforeClass() |
void |
testMainMethod()
Test main method
|
void |
testPlayingRecoveredEdit()
Test that WALPlayer can replay recovered.edits files.
|
void |
testWALKeyValueMapper()
Test WALKeyValueMapper setup and map
|
private void |
testWALKeyValueMapper(String tableConfigKey) |
void |
testWALKeyValueMapperWithDeprecatedConfig() |
void |
testWALPlayer()
Simple end-to-end test
|
void |
testWALPlayerBulkLoadWithOverriddenTimestamps()
Tests that when you write multiple cells with the same timestamp they are properly sorted by
their sequenceId in WALPlayer/CellSortReducer so that the correct one wins when querying from
the resulting bulkloaded HFiles.
|
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtil TEST_UTIL
private static SingleProcessHBaseCluster cluster
private static org.apache.hadoop.fs.Path rootDir
private static org.apache.hadoop.fs.Path walRootDir
private static org.apache.hadoop.fs.FileSystem fs
private static org.apache.hadoop.fs.FileSystem logFs
private static org.apache.hadoop.conf.Configuration conf
public org.junit.rules.TestName name
public TestWALPlayer()
public static void beforeClass() throws Exception
Exception
public static void afterClass() throws Exception
Exception
public void testPlayingRecoveredEdit() throws Exception
Exception
public void testWALPlayerBulkLoadWithOverriddenTimestamps() throws Exception
Exception
public void testWALPlayer() throws Exception
Exception
public void testWALKeyValueMapper() throws Exception
Exception
public void testWALKeyValueMapperWithDeprecatedConfig() throws Exception
Exception
private void testWALKeyValueMapper(String tableConfigKey) throws Exception
Exception
public void testMainMethod() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.