in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/table/catalog/KuduCatalog.java [133:148]
public List<String> listTables(String databaseName)
throws DatabaseNotExistException, CatalogException {
checkArgument(
!StringUtils.isNullOrWhitespaceOnly(databaseName),
"databaseName cannot be null or empty");
if (!databaseExists(databaseName)) {
throw new DatabaseNotExistException(getName(), databaseName);
}
try {
return kuduClient.getTablesList().getTablesList();
} catch (Throwable t) {
throw new CatalogException("Could not list tables", t);
}
}