Package 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 ClassesModifier and TypeClassDescriptionstatic classWALPlayer override that searches for keys loaded in the setup. -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate static voidprintUsage(String error) private static SortedSet<byte[]>readFileToSearch(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.LocatedFileStatus keyFileStatus) (package private) static SortedSet<byte[]>readKeysToSearch(org.apache.hadoop.conf.Configuration conf) intintrun(org.apache.hadoop.fs.Path inputDir, int numMappers) Methods inherited from class org.apache.hadoop.conf.Configured
getConf, setConfMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.hadoop.conf.Configurable
getConf, setConf
-
Field Details
-
LOG
-
job
-
FOUND_GROUP_KEY
- See Also:
-
SEARCHER_INPUTDIR_KEY
- See Also:
-
-
Constructor Details
-
Search
Search()
-
-
Method Details
-
printUsage
-
run
- Specified by:
runin interfaceorg.apache.hadoop.util.Tool- Throws:
Exception
-
run
- Throws:
Exception
-
readKeysToSearch
static SortedSet<byte[]> readKeysToSearch(org.apache.hadoop.conf.Configuration conf) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-
readFileToSearch
private static SortedSet<byte[]> readFileToSearch(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.LocatedFileStatus keyFileStatus) throws IOException, InterruptedException - Throws:
IOExceptionInterruptedException
-