Package org.apache.hadoop.hbase.snapshot

Class TestExportSnapshotHelpers

java.lang.Object

org.apache.hadoop.hbase.snapshot.TestExportSnapshotHelpers

@Tag("org.apache.hadoop.hbase.testclassification.MapReduceTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestExportSnapshotHelpers
extends Object

Test Export Snapshot Tool helpers

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestExportSnapshotHelpers.TestCustomFileGrouper
static class	TestExportSnapshotHelpers.TestFileLocationResolver

Constructor Summary

Constructors

Constructor	Description
TestExportSnapshotHelpers()

Method Summary

Modifier and Type	Method	Description
void	testBalanceSplit()	Verfy the result of getBalanceSplits() method.
void	testFileLocationResolverWithCustomResolver()
void	testFileLocationResolverWithNoopResolver()
void	testGroupFilesForSplitsWithCustomFileGrouper()
void	testGroupFilesForSplitsWithoutCustomFileGrouper()
void	testInputSplitWithFileLocationResolver()
private void	verifyBalanceSplit(List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo,Long>> split, String[] expected, long expectedSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TestExportSnapshotHelpers

public TestExportSnapshotHelpers()

Method Details

testBalanceSplit

@Test
public void testBalanceSplit()

Verfy the result of getBalanceSplits() method. The result are groups of files, used as input list for the "export" mappers. All the groups should have similar amount of data. The input list is a pair of file path and length. The getBalanceSplits() function sort it by length, and assign to each group a file, going back and forth through the groups.

verifyBalanceSplit

private void verifyBalanceSplit(List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo,Long>> split,
 String[] expected,
 long expectedSize)

testGroupFilesForSplitsWithoutCustomFileGrouper

@Test
public void testGroupFilesForSplitsWithoutCustomFileGrouper()

testGroupFilesForSplitsWithCustomFileGrouper

@Test
public void testGroupFilesForSplitsWithCustomFileGrouper()

testFileLocationResolverWithNoopResolver

@Test
public void testFileLocationResolverWithNoopResolver()

testFileLocationResolverWithCustomResolver

@Test
public void testFileLocationResolverWithCustomResolver()

testInputSplitWithFileLocationResolver

@Test
public void testInputSplitWithFileLocationResolver()
                                            throws Exception

Throws:

Exception