public class TestMergesSplitsAddToTracker extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
FAMILY_NAME |
private static String |
FAMILY_NAME_STR |
TableNameTestRule |
name |
private static HBaseTestingUtility |
TEST_UTIL |
Constructor and Description |
---|
TestMergesSplitsAddToTracker() |
Modifier and Type | Method and Description |
---|---|
static void |
afterClass() |
private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.regionserver.StoreFileInfo,String> |
copyFileInTheStoreDir(org.apache.hadoop.hbase.regionserver.HRegion region) |
private org.apache.hadoop.hbase.TableName |
createTable(byte[] splitKey) |
private org.apache.hadoop.fs.Path |
mergeFileFromRegion(org.apache.hadoop.hbase.regionserver.HRegion regionToMerge,
org.apache.hadoop.hbase.regionserver.HRegionFileSystem mergeFS) |
private void |
putThreeRowsAndFlush(org.apache.hadoop.hbase.TableName table) |
void |
setup() |
static void |
setupClass() |
private void |
split(org.apache.hadoop.hbase.TableName table,
byte[] splitKey) |
void |
testCommitDaughterRegion() |
void |
testCommitMergedRegion() |
void |
testMergeLoadsFromTracker() |
void |
testSplitLoadsFromTracker() |
private void |
validateDaughterRegionsFiles(org.apache.hadoop.hbase.regionserver.HRegion region,
String orignalFileName,
String untrackedFile) |
private void |
verifyFilesAreTracked(org.apache.hadoop.fs.Path regionDir,
org.apache.hadoop.fs.FileSystem fs) |
public static final HBaseClassTestRule CLASS_RULE
private static HBaseTestingUtility TEST_UTIL
private static final String FAMILY_NAME_STR
private static final byte[] FAMILY_NAME
public TableNameTestRule name
public TestMergesSplitsAddToTracker()
public static void setupClass() throws Exception
Exception
public static void afterClass() throws Exception
Exception
public void setup()
private org.apache.hadoop.hbase.TableName createTable(byte[] splitKey) throws IOException
IOException
public void testCommitDaughterRegion() throws Exception
Exception
public void testCommitMergedRegion() throws Exception
Exception
public void testSplitLoadsFromTracker() throws Exception
Exception
private void split(org.apache.hadoop.hbase.TableName table, byte[] splitKey) throws IOException
IOException
public void testMergeLoadsFromTracker() throws Exception
Exception
private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.regionserver.StoreFileInfo,String> copyFileInTheStoreDir(org.apache.hadoop.hbase.regionserver.HRegion region) throws IOException
IOException
private void validateDaughterRegionsFiles(org.apache.hadoop.hbase.regionserver.HRegion region, String orignalFileName, String untrackedFile) throws IOException
IOException
private void verifyFilesAreTracked(org.apache.hadoop.fs.Path regionDir, org.apache.hadoop.fs.FileSystem fs) throws Exception
Exception
private org.apache.hadoop.fs.Path mergeFileFromRegion(org.apache.hadoop.hbase.regionserver.HRegion regionToMerge, org.apache.hadoop.hbase.regionserver.HRegionFileSystem mergeFS) throws IOException
IOException
private void putThreeRowsAndFlush(org.apache.hadoop.hbase.TableName table) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.