public List listTables()

in src/main/java/org/apache/flink/connector/rocketmq/catalog/RocketMQCatalog.java [161:176]

• 16 lines of code
• 3 McCabe index (conditional complexity)

    public List<String> listTables(String databaseName)
            throws DatabaseNotExistException, CatalogException {
        if (!getDefaultDatabase().equals(databaseName)) {
            throw new DatabaseNotExistException(getName(), databaseName);
        }
        try {
            List<String> tables = schemaRegistryClient.getSubjectsByTenant("default", "default");
            return tables;
        } catch (Exception e) {
            throw new CatalogException(
                    String.format(
                            "Failed to get topics of namespace %s from schema registry client.",
                            databaseName),
                    e);
        }
    }