external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Show pg_total_relation_size values in citus_shards

citus-shards-pg_total_relation_size
Jelte Fennema 2021-06-14 17:49:01 +02:00
parent 4c3934272f
commit ba47351865
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/metadata/metadata_utility.c
View File

@ -962,7 +962,7 @@ AppendShardSizeMinMaxQuery(StringInfo selectQuery, uint64 shardId,
partitionColumn->varattno, false); partitionColumn->varattno, false);
appendStringInfo(selectQuery, appendStringInfo(selectQuery,
"SELECT " UINT64_FORMAT "SELECT " UINT64_FORMAT
" AS shard_id, min(%s)::text AS shard_minvalue, max(%s)::text AS shard_maxvalue, pg_relation_size(%s) AS shard_size FROM %s ", " AS shard_id, min(%s)::text AS shard_minvalue, max(%s)::text AS shard_maxvalue, pg_total_relation_size(%s) AS shard_size FROM %s ",
shardId, partitionColumnName, shardId, partitionColumnName,
partitionColumnName, partitionColumnName,
quotedShardName, shardName); quotedShardName, shardName);
@ -972,7 +972,7 @@ AppendShardSizeMinMaxQuery(StringInfo selectQuery, uint64 shardId,
/* we don't need to update min/max for non-append distributed tables because they don't change */ /* we don't need to update min/max for non-append distributed tables because they don't change */
appendStringInfo(selectQuery, appendStringInfo(selectQuery,
"SELECT " UINT64_FORMAT "SELECT " UINT64_FORMAT
" AS shard_id, NULL::text AS shard_minvalue, NULL::text AS shard_maxvalue, pg_relation_size(%s) AS shard_size ", " AS shard_id, NULL::text AS shard_minvalue, NULL::text AS shard_maxvalue, pg_total_relation_size(%s) AS shard_size ",
shardId, quotedShardName); shardId, quotedShardName);
} }
} }