org.apache.hadoop.hbase.test

Class IntegrationTestBigLinkedList.Search

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.test.IntegrationTestBigLinkedList.Search

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

Enclosing class:

IntegrationTestBigLinkedList

static class IntegrationTestBigLinkedList.Search
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

Tool to search missing rows in WALs and hfiles. Pass in file or dir of keys to search for. Key file must have been written by Verify step (we depend on the format it writes out. We'll read them in and then search in hbase WALs and oldWALs dirs (Some of this is TODO).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IntegrationTestBigLinkedList.Search.WALSearcher WALPlayer override that searches for keys loaded in the setup.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static String	FOUND_GROUP_KEY
protected org.apache.hadoop.mapreduce.Job	job
private static org.slf4j.Logger	LOG
(package private) static String	SEARCHER_INPUTDIR_KEY

Constructor Summary

Constructors

Constructor and Description
Search()

Method Summary

Modifier and Type	Method and Description
private static void	printUsage(String error)
private static SortedSet<byte[]>	readFileToSearch(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.LocatedFileStatus keyFileStatus)
(package private) static SortedSet<byte[]>	readKeysToSearch(org.apache.hadoop.conf.Configuration conf)
int	run(org.apache.hadoop.fs.Path inputDir, int numMappers)
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

LOG

private static final org.slf4j.Logger LOG

job

protected org.apache.hadoop.mapreduce.Job job

FOUND_GROUP_KEY

static final String FOUND_GROUP_KEY

See Also:

Constant Field Values

SEARCHER_INPUTDIR_KEY

static final String SEARCHER_INPUTDIR_KEY

See Also:

Constant Field Values

Constructor Detail

Search

Search()

Method Detail

printUsage

private static void printUsage(String error)

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

run

public int run(org.apache.hadoop.fs.Path inputDir,
               int numMappers)
        throws Exception

Throws:

Exception

readKeysToSearch

static SortedSet<byte[]> readKeysToSearch(org.apache.hadoop.conf.Configuration conf)
                                   throws IOException,
                                          InterruptedException

Throws:

IOException

InterruptedException

readFileToSearch

private static SortedSet<byte[]> readFileToSearch(org.apache.hadoop.conf.Configuration conf,
                                                  org.apache.hadoop.fs.FileSystem fs,
                                                  org.apache.hadoop.fs.LocatedFileStatus keyFileStatus)
                                           throws IOException,
                                                  InterruptedException

Throws:

IOException

InterruptedException