BackupRestoreUtil.java 文件源码

private static Map<String, BackupFileInfo> scanInfoFiles(FileSystem fs, Path backupDir) throws IOException {
  final Map<String, BackupFileInfo> tableToInfo = Maps.newHashMap();
  final FileStatus[] backupFiles = fs.listStatus(backupDir, BACKUP_INFO_FILES_GLOB);
  for (FileStatus backupFile : backupFiles) {
    final String tableName = getTableName(backupFile.getPath().getName(), BACKUP_INFO_FILE_SUFFIX);
    // read backup info file
    final byte[] headerBytes = new byte[(int) backupFile.getLen()];
    IOUtils.readFully(fs.open(backupFile.getPath()), headerBytes, 0, headerBytes.length);
    final BackupFileInfo backupFileInfo = new BackupFileInfo();
    ProtostuffUtil.fromJSON(headerBytes, backupFileInfo, BackupFileInfo.getSchema(), false);
    tableToInfo.put(tableName, backupFileInfo);
  }
  return tableToInfo;
}