@Test public void testFindMissingRegionsInMETANoMissing() throws Exception { createRegionInMetaAndFileSystem(); assertEquals("Should had returned 0 missing regions", 0, fixer.findMissingRegionsInMETA("test-tbl").size()); }
List<Path> findMissingRegionsInMETA(String table) throws IOException { InternalMetaChecker<Path> missingChecker = new InternalMetaChecker<>(); return missingChecker.checkRegionsInMETA(table, (regions, dirs) -> { ListUtils<Path, RegionInfo> utils = new ListUtils<>(); return utils.complement(dirs, regions, d -> d.getName(), r -> r.getEncodedName()); }); }
FsRegionsMetaRecoverer implements Closeable { List<Path> findMissingRegionsInMETA(String table) throws IOException { InternalMetaChecker<Path> missingChecker = new InternalMetaChecker<>(); return missingChecker.checkRegionsInMETA(table, (regions, dirs) -> { ListUtils<Path, RegionInfo> utils = new ListUtils<>(); return utils.complement(dirs, regions, d -> d.getName(), r -> r.getEncodedName()); }); } }
FsRegionsMetaRecoverer implements Closeable { List<Path> findMissingRegionsInMETA(String table) throws IOException { InternalMetaChecker<Path> missingChecker = new InternalMetaChecker<>(); return missingChecker.checkRegionsInMETA(table, (regions, dirs) -> { ListUtils<Path, RegionInfo> utils = new ListUtils<>(); return utils.complement(dirs, regions, d -> d.getName(), r -> r.getEncodedName()); }); } FsRegionsMetaRecoverer(Configuration configuration);   FsRegionsMetaRecoverer(Configuration configuration, Connection connection, FileSystem fileSystem); }
FsRegionsMetaRecoverer implements Closeable { List<Path> findMissingRegionsInMETA(String table) throws IOException { InternalMetaChecker<Path> missingChecker = new InternalMetaChecker<>(); return missingChecker.checkRegionsInMETA(table, (regions, dirs) -> { ListUtils<Path, RegionInfo> utils = new ListUtils<>(); return utils.complement(dirs, regions, d -> d.getName(), r -> r.getEncodedName()); }); } FsRegionsMetaRecoverer(Configuration configuration);   FsRegionsMetaRecoverer(Configuration configuration, Connection connection, FileSystem fileSystem); Map<TableName,List<Path>> reportTablesMissingRegions(final List<String> namespacesOrTables); Map<TableName,List<RegionInfo>> reportTablesExtraRegions(final List<String> namespacesOrTables); List<Future<List<String>>> addMissingRegionsInMetaForTables(
      List<String> nameSpaceOrTable); List<Future<List<String>>> removeExtraRegionsFromMetaForTables(
    List<String> nameSpaceOrTable); @Override void close(); }
FsRegionsMetaRecoverer implements Closeable { List<Path> findMissingRegionsInMETA(String table) throws IOException { InternalMetaChecker<Path> missingChecker = new InternalMetaChecker<>(); return missingChecker.checkRegionsInMETA(table, (regions, dirs) -> { ListUtils<Path, RegionInfo> utils = new ListUtils<>(); return utils.complement(dirs, regions, d -> d.getName(), r -> r.getEncodedName()); }); } FsRegionsMetaRecoverer(Configuration configuration);   FsRegionsMetaRecoverer(Configuration configuration, Connection connection, FileSystem fileSystem); Map<TableName,List<Path>> reportTablesMissingRegions(final List<String> namespacesOrTables); Map<TableName,List<RegionInfo>> reportTablesExtraRegions(final List<String> namespacesOrTables); List<Future<List<String>>> addMissingRegionsInMetaForTables(
      List<String> nameSpaceOrTable); List<Future<List<String>>> removeExtraRegionsFromMetaForTables(
    List<String> nameSpaceOrTable); @Override void close();  }