@Test public void testGetAllTablesFound() throws Exception { addMockDbs(); assertTrue(mCatalog.getAllTables("db2").contains("1")); assertTrue(mCatalog.getAllTables("db2").contains("2")); assertTrue(mCatalog.getAllTables("db2").contains("3")); assertTrue(mCatalog.getAllTables("db2").contains("4")); }
public List<String> getAllTables(String dbName) throws IOException { Database db = getDatabaseByName(dbName); return db.getTables().stream().map(Table::getName).collect(Collectors.toList()); }
AlluxioCatalog implements Journaled { public List<String> getAllTables(String dbName) throws IOException { Database db = getDatabaseByName(dbName); return db.getTables().stream().map(Table::getName).collect(Collectors.toList()); } }
AlluxioCatalog implements Journaled { public List<String> getAllTables(String dbName) throws IOException { Database db = getDatabaseByName(dbName); return db.getTables().stream().map(Table::getName).collect(Collectors.toList()); } AlluxioCatalog(); }
AlluxioCatalog implements Journaled { public List<String> getAllTables(String dbName) throws IOException { Database db = getDatabaseByName(dbName); return db.getTables().stream().map(Table::getName).collect(Collectors.toList()); } AlluxioCatalog(); LayoutRegistry getLayoutRegistry(); SyncStatus attachDatabase(JournalContext journalContext, String udbType,
      String udbConnectionUri, String udbDbName, String dbName, Map<String, String> map,
      boolean ignoreSyncErrors); SyncStatus syncDatabase(JournalContext journalContext, String dbName); boolean detachDatabase(JournalContext journalContext, String dbName); Table getTable(String dbName, String tableName); List<String> getAllDatabases(); alluxio.grpc.table.Database getDatabase(String dbName); List<String> getAllTables(String dbName); List<ColumnStatisticsInfo> getTableColumnStatistics(String dbName, String tableName,
      List<String> colNames); Map<String, ColumnStatisticsList> getPartitionColumnStatistics(String dbName,
      String tableName, List<String> partNames, List<String> colNames); List<alluxio.grpc.table.Partition> readTable(String dbName, String tableName,
      Constraint constraint); void completeTransformTable(JournalContext journalContext, String dbName, String tableName,
      String definition, Map<String, Layout> transformedLayouts); List<TransformPlan> getTransformPlan(String dbName, String tableName,
      TransformDefinition definition); @Override boolean processJournalEntry(Journal.JournalEntry entry); @Override void resetState(); @Override Iterator<Journal.JournalEntry> getJournalEntryIterator(); @Override CheckpointName getCheckpointName(); }
AlluxioCatalog implements Journaled { public List<String> getAllTables(String dbName) throws IOException { Database db = getDatabaseByName(dbName); return db.getTables().stream().map(Table::getName).collect(Collectors.toList()); } AlluxioCatalog(); LayoutRegistry getLayoutRegistry(); SyncStatus attachDatabase(JournalContext journalContext, String udbType,
      String udbConnectionUri, String udbDbName, String dbName, Map<String, String> map,
      boolean ignoreSyncErrors); SyncStatus syncDatabase(JournalContext journalContext, String dbName); boolean detachDatabase(JournalContext journalContext, String dbName); Table getTable(String dbName, String tableName); List<String> getAllDatabases(); alluxio.grpc.table.Database getDatabase(String dbName); List<String> getAllTables(String dbName); List<ColumnStatisticsInfo> getTableColumnStatistics(String dbName, String tableName,
      List<String> colNames); Map<String, ColumnStatisticsList> getPartitionColumnStatistics(String dbName,
      String tableName, List<String> partNames, List<String> colNames); List<alluxio.grpc.table.Partition> readTable(String dbName, String tableName,
      Constraint constraint); void completeTransformTable(JournalContext journalContext, String dbName, String tableName,
      String definition, Map<String, Layout> transformedLayouts); List<TransformPlan> getTransformPlan(String dbName, String tableName,
      TransformDefinition definition); @Override boolean processJournalEntry(Journal.JournalEntry entry); @Override void resetState(); @Override Iterator<Journal.JournalEntry> getJournalEntryIterator(); @Override CheckpointName getCheckpointName();  }