Package org.apache.hadoop.hbase.backup

Class TestIncrementalBackupMergeWithFailures.BackupMergeJobWithFailures

java.lang.Object

org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

org.apache.hadoop.hbase.backup.TestIncrementalBackupMergeWithFailures.BackupMergeJobWithFailures

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.hbase.backup.BackupMergeJob

Enclosing class:

TestIncrementalBackupMergeWithFailures

static class TestIncrementalBackupMergeWithFailures.BackupMergeJobWithFailures
extends org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

Field Summary

Fields

Modifier and Type	Field	Description
(package private) TestIncrementalBackupMergeWithFailures.FailurePhase	failurePhase

Fields inherited from class org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

conf, LOG, player

Constructor Summary

Constructors

Constructor	Description
BackupMergeJobWithFailures()

Method Summary

Modifier and Type	Method	Description
private void	checkFailure(TestIncrementalBackupMergeWithFailures.FailurePhase phase)
void	run(String[] backupIds)	This is the exact copy of parent's run() with injections of different types of failures
void	setConf(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

cleanupBulkLoadDirs, convertToDest, copyFile, copyMetaData, deleteBackupImages, findInputDirectories, getBackupIdsToDelete, getConf, getTableNamesInBackupImages, moveData, toPathList, toTableNameList, updateBackupManifest

Methods inherited from class java.lang.Object

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

Field Details

failurePhase

TestIncrementalBackupMergeWithFailures.FailurePhase failurePhase

Constructor Details

BackupMergeJobWithFailures

BackupMergeJobWithFailures()

Method Details

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

Overrides:

setConf in class org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

run

public void run(String[] backupIds)
         throws IOException

This is the exact copy of parent's run() with injections of different types of failures

Specified by:

run in interface org.apache.hadoop.hbase.backup.BackupMergeJob

Overrides:

run in class org.apache.hadoop.hbase.backup.mapreduce.MapReduceBackupMergeJob

Throws:

IOException

checkFailure

private void checkFailure(TestIncrementalBackupMergeWithFailures.FailurePhase phase)
                   throws IOException

Throws:

IOException