@InterfaceAudience.Private public class HFileCorruptionChecker extends Object
Constructor and Description |
---|
HFileCorruptionChecker(Configuration conf,
ExecutorService executor,
boolean quarantine) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkColFamDir(Path cfDir)
Check all files in a column family dir.
|
protected void |
checkHFile(Path p)
Checks a path to see if it is a valid hfile.
|
protected void |
checkRegionDir(Path regionDir)
Check all column families in a region dir.
|
void |
checkTables(Collection<Path> tables)
Check the specified table dirs for bad hfiles.
|
Collection<Path> |
getCorrupted() |
Collection<Path> |
getFailures() |
int |
getHFilesChecked() |
Collection<Path> |
getMissing() |
Collection<Path> |
getQuarantined() |
void |
report(HBaseFsck.ErrorReporter out)
Print a human readable summary of hfile quarantining operations.
|
public HFileCorruptionChecker(Configuration conf, ExecutorService executor, boolean quarantine) throws IOException
IOException
protected void checkHFile(Path p) throws IOException
p
- full Path to an HFileIOException
- This is a connectivity related exceptionprotected void checkColFamDir(Path cfDir) throws IOException
cfDir
- column family directoryIOException
protected void checkRegionDir(Path regionDir) throws IOException
regionDir
- region directoryIOException
public void checkTables(Collection<Path> tables) throws IOException
IOException
public Collection<Path> getFailures()
public Collection<Path> getCorrupted()
public int getHFilesChecked()
public Collection<Path> getQuarantined()
public Collection<Path> getMissing()
public void report(HBaseFsck.ErrorReporter out)
out
-