diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/backup/BackupRestoreServerFactory.java hbase-server/src/main/java/org/apache/hadoop/hbase/backup/BackupRestoreServerFactory.java index 06e367f..9f66f63 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/backup/BackupRestoreServerFactory.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/backup/BackupRestoreServerFactory.java @@ -40,7 +40,7 @@ public final class BackupRestoreServerFactory { * @param conf - configuration * @return backup restore service instance */ - public static RestoreTask getRestoreService(Configuration conf) { + public static RestoreTask getRestoreTask(Configuration conf) { Class cls = conf.getClass(HBASE_INCR_RESTORE_IMPL_CLASS, MapReduceRestoreTask.class, RestoreTask.class); @@ -54,7 +54,7 @@ public final class BackupRestoreServerFactory { * @param conf - configuration * @return backup copy service */ - public static BackupCopyTask getBackupCopyService(Configuration conf) { + public static BackupCopyTask getBackupCopyTask(Configuration conf) { Class cls = conf.getClass(HBASE_BACKUP_COPY_IMPL_CLASS, MapReduceBackupCopyTask.class, BackupCopyTask.class); diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/FullTableBackupClient.java hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/FullTableBackupClient.java index e068ede..dbb3800 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/FullTableBackupClient.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/FullTableBackupClient.java @@ -67,7 +67,7 @@ public class FullTableBackupClient extends TableBackupClient{ // call ExportSnapshot to copy files based on hbase snapshot for backup // ExportSnapshot only support single snapshot export, need loop for multiple tables case - BackupCopyTask copyService = BackupRestoreServerFactory.getBackupCopyService(conf); + BackupCopyTask copyService = BackupRestoreServerFactory.getBackupCopyTask(conf); // number of snapshots matches number of tables float numOfSnapshots = backupContext.getSnapshotNames().size(); diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java index 1da5b19..90f77a8 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java @@ -95,7 +95,7 @@ public class IncrementalTableBackupClient extends TableBackupClient { String[] strArr = incrBackupFileList.toArray(new String[incrBackupFileList.size() + 1]); strArr[strArr.length - 1] = backupContext.getHLogTargetDir(); - BackupCopyTask copyService = BackupRestoreServerFactory.getBackupCopyService(conf); + BackupCopyTask copyService = BackupRestoreServerFactory.getBackupCopyTask(conf); int counter = 0; int MAX_ITERAIONS = 2; while (counter++ < MAX_ITERAIONS) { diff --git hbase-server/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreServerUtil.java hbase-server/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreServerUtil.java index 1d0642b..4173004 100644 --- hbase-server/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreServerUtil.java +++ hbase-server/src/main/java/org/apache/hadoop/hbase/backup/util/RestoreServerUtil.java @@ -242,7 +242,7 @@ public class RestoreServerUtil { } } RestoreTask restoreService = - BackupRestoreServerFactory.getRestoreService(conf); + BackupRestoreServerFactory.getRestoreTask(conf); restoreService.run(logDirs, tableNames, newTableNames, false); } @@ -479,7 +479,7 @@ public class RestoreServerUtil { Path[] dirs = new Path[regionPathList.size()]; regionPathList.toArray(dirs); RestoreTask restoreService = - BackupRestoreServerFactory.getRestoreService(conf); + BackupRestoreServerFactory.getRestoreTask(conf); restoreService.run(dirs, new TableName[] { tableName }, new TableName[] { newTableName }, true);