initial_parts_written_to_storage_per_node.sql

WITH
    'pypi' AS db_name,
    'pypi' AS table_name,
    (
        SELECT uuid
        FROM system.tables
        WHERE (database = db_name) AND (name = table_name)
    ) AS table_id
SELECT
    DENSE_RANK() OVER(ORDER BY hostName()) AS n,
    formatReadableQuantity(countIf(event_type = 'NewPart')) AS parts,
    formatReadableQuantity(sumIf(rows, event_type = 'NewPart')) AS rows_total
FROM clusterAllReplicas(default, system.part_log)
WHERE table_uuid = table_id
GROUP BY hostName() WITH Totals
ORDER BY n
SETTINGS skip_unavailable_shards = 1;