diff --git a/src/backend/distributed/sql/citus--11.2-1--11.3-1.sql b/src/backend/distributed/sql/citus--11.2-1--11.3-1.sql index 6fbeede70..73a2bf8a9 100644 --- a/src/backend/distributed/sql/citus--11.2-1--11.3-1.sql +++ b/src/backend/distributed/sql/citus--11.2-1--11.3-1.sql @@ -3,4 +3,3 @@ -- bump version to 11.3-1 #include "udfs/citus_stats_tenants/11.3-1.sql" -#include "udfs/citus_stats_tenants_storage/11.3-1.sql" diff --git a/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql b/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql index 855b4f9d1..4bf4c75ff 100644 --- a/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql +++ b/src/backend/distributed/sql/downgrades/citus--11.3-1--11.2-1.sql @@ -2,7 +2,4 @@ -- this is an empty downgrade path since citus--11.2-1--11.3-1.sql is empty for now DROP VIEW pg_catalog.citus_stats_tenants; -DROP VIEW pg_catalog.citus_stats_tenants_storage; - DROP FUNCTION pg_catalog.citus_stats_tenants(boolean); -DROP FUNCTION pg_catalog.citus_stats_tenants_storage; diff --git a/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/11.3-1.sql b/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/11.3-1.sql deleted file mode 100644 index c1604a7a1..000000000 --- a/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/11.3-1.sql +++ /dev/null @@ -1,28 +0,0 @@ -CREATE OR REPLACE FUNCTION pg_catalog.citus_stats_tenants_storage ( - OUT colocation_id INT, - OUT tenant_attribute TEXT, - OUT storage_estimate INT -) -RETURNS SETOF record -LANGUAGE plpgsql -AS $function$ -DECLARE -tn TEXT; -dc TEXT; -ci INT; -BEGIN - FOR ci, tn, dc IN SELECT cts.colocation_id, cts.table_name, cts.distribution_column FROM citus_tables cts - LOOP - RETURN QUERY - EXECUTE 'SELECT ' || ci || '::int, ' || dc || '::text, sum(pg_column_size(' || tn || '.*))::int FROM ' || tn || ' GROUP BY ' || dc; - END LOOP; -END; -$function$; - -CREATE OR REPLACE VIEW citus.citus_stats_tenants_storage AS -SELECT colocation_id, tenant_attribute, sum(storage_estimate) total_storage FROM pg_catalog.citus_stats_tenants_storage() -GROUP BY colocation_id, tenant_attribute -ORDER BY total_storage DESC; - -ALTER VIEW citus.citus_stats_tenants_storage SET SCHEMA pg_catalog; -GRANT SELECT ON pg_catalog.citus_stats_tenants_storage TO PUBLIC; diff --git a/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/latest.sql b/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/latest.sql deleted file mode 100644 index c1604a7a1..000000000 --- a/src/backend/distributed/sql/udfs/citus_stats_tenants_storage/latest.sql +++ /dev/null @@ -1,28 +0,0 @@ -CREATE OR REPLACE FUNCTION pg_catalog.citus_stats_tenants_storage ( - OUT colocation_id INT, - OUT tenant_attribute TEXT, - OUT storage_estimate INT -) -RETURNS SETOF record -LANGUAGE plpgsql -AS $function$ -DECLARE -tn TEXT; -dc TEXT; -ci INT; -BEGIN - FOR ci, tn, dc IN SELECT cts.colocation_id, cts.table_name, cts.distribution_column FROM citus_tables cts - LOOP - RETURN QUERY - EXECUTE 'SELECT ' || ci || '::int, ' || dc || '::text, sum(pg_column_size(' || tn || '.*))::int FROM ' || tn || ' GROUP BY ' || dc; - END LOOP; -END; -$function$; - -CREATE OR REPLACE VIEW citus.citus_stats_tenants_storage AS -SELECT colocation_id, tenant_attribute, sum(storage_estimate) total_storage FROM pg_catalog.citus_stats_tenants_storage() -GROUP BY colocation_id, tenant_attribute -ORDER BY total_storage DESC; - -ALTER VIEW citus.citus_stats_tenants_storage SET SCHEMA pg_catalog; -GRANT SELECT ON pg_catalog.citus_stats_tenants_storage TO PUBLIC;