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
Modifier and TypeClassDescriptionstatic class
WALPlayer override that searches for keys loaded in the setup. -
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprivate static void
printUsage
(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) int
int
run
(org.apache.hadoop.fs.Path inputDir, int numMappers) 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 Details
-
LOG
-
job
-
FOUND_GROUP_KEY
- See Also:
-
SEARCHER_INPUTDIR_KEY
- See Also:
-
-
Constructor Details
-
Search
Search()
-
-
Method Details
-
printUsage
-
run
- Specified by:
run
in 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:
IOException
InterruptedException
-
readFileToSearch
private static SortedSet<byte[]> readFileToSearch(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.LocatedFileStatus keyFileStatus) throws IOException, InterruptedException - Throws:
IOException
InterruptedException
-