public static List listConsumers()

in paimon-web-api/src/main/java/org/apache/paimon/web/api/table/TableManager.java [460:478]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    public static List<ConsumerTableMetadata> listConsumers(
            Catalog catalog, String dbName, String tableName)
            throws Catalog.TableNotExistException, IOException {
        checkNotNull(catalog, dbName, tableName);

        List<ConsumerTableMetadata> consumers = new ArrayList<>();

        Table table = getTable(catalog, dbName, "`" + tableName + "$" + CONSUMER + "`");

        RecordReader<InternalRow> reader = getReader(table);

        reader.forEachRemaining(
                row -> {
                    ConsumerTableMetadata consumerTableMetadata =
                            new ConsumerTableMetadata(row.getString(1).toString(), row.getLong(2));
                    consumers.add(consumerTableMetadata);
                });
        return consumers;
    }