Package org.apache.hadoop.hbase.mapreduce

Class TestRoundRobinTableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestRoundRobinTableInputFormat

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

Basic test of RoundRobinTableInputFormat; i.e. RRTIF.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestRoundRobinTableInputFormat.SplitComparator	Private comparator copied from private JobSubmmiter Hadoop class...

Field Summary

Fields

Modifier and Type	Field	Description
private static final String[]	KEYS
private static final int	SERVERS_COUNT

Constructor Summary

Constructors

Constructor	Description
TestRoundRobinTableInputFormat()

Method Summary

Modifier and Type	Method	Description
private void	assertLengthDescending(List<org.apache.hadoop.mapreduce.InputSplit> list)	Assert that lengths are descending.
private void	checkRetainsBooleanValue(org.apache.hadoop.mapreduce.JobContext jobContext, org.apache.hadoop.hbase.mapreduce.RoundRobinTableInputFormat rrtif, boolean b)
private List<org.apache.hadoop.mapreduce.InputSplit>	createSplits()	Returns Splits made out of KEYS.
void	testConfigureUnconfigure()	Test that configure/unconfigure set and properly undo the HBASE_REGIONSIZECALCULATOR_ENABLE configuration.
private void	testDistribution(List<org.apache.hadoop.mapreduce.InputSplit> list)
void	testRoundRobinSplit()	Test default behavior.

Methods inherited from class java.lang.Object

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

Field Details

SERVERS_COUNT

private static final int SERVERS_COUNT

See Also:

• Constant Field Values

KEYS

private static final String[] KEYS

Constructor Details

TestRoundRobinTableInputFormat

public TestRoundRobinTableInputFormat()

Method Details

testRoundRobinSplit

@Test
public void testRoundRobinSplit()
                         throws IOException,
InterruptedException

Test default behavior.

Throws:

IOException

InterruptedException

createSplits

private List<org.apache.hadoop.mapreduce.InputSplit> createSplits()

Returns Splits made out of KEYS. Splits are for five Servers. Length is ZERO!

testDistribution

private void testDistribution(List<org.apache.hadoop.mapreduce.InputSplit> list)
                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

assertLengthDescending

private void assertLengthDescending(List<org.apache.hadoop.mapreduce.InputSplit> list)
                             throws IOException,
InterruptedException

Assert that lengths are descending. RRTIF writes lengths in descending order so any subsequent sort using dump SplitComparator as is done in JobSubmitter up in Hadoop keeps our RRTIF ordering.

Throws:

IOException

InterruptedException

testConfigureUnconfigure

@Test
public void testConfigureUnconfigure()

Test that configure/unconfigure set and properly undo the HBASE_REGIONSIZECALCULATOR_ENABLE configuration.

checkRetainsBooleanValue

private void checkRetainsBooleanValue(org.apache.hadoop.mapreduce.JobContext jobContext,
 org.apache.hadoop.hbase.mapreduce.RoundRobinTableInputFormat rrtif,
 boolean b)