From 6aed32a201dd5c436167eeba0fbb6a067644d8f5 Mon Sep 17 00:00:00 2001 From: Vallish Date: Mon, 2 Sep 2024 11:30:00 +0000 Subject: [PATCH] [Enhancement] add row count in show partition --- .../java/org/apache/doris/common/proc/PartitionsProcDir.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java b/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java index 3e7c6bdebc762b..f1aed5b6278960 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/proc/PartitionsProcDir.java @@ -76,6 +76,7 @@ public class PartitionsProcDir implements ProcDirInterface { .add("Buckets").add("ReplicationNum").add("StorageMedium").add("CooldownTime").add("RemoteStoragePolicy") .add("LastConsistencyCheckTime").add("DataSize").add("IsInMemory").add("ReplicaAllocation") .add("IsMutable").add("SyncWithBaseTables").add("UnsyncTables").add("CommittedVersion") + .add("RowCount") .build(); private Database db; @@ -383,6 +384,9 @@ private List, TRow>> getPartitionInfosInrernal() throws An partitionInfo.add(partition.getCommittedVersion()); trow.addToColumnValue(new TCell().setLongVal(partition.getCommittedVersion())); + partitionInfo.add(partition.getRowCount()); + trow.addToColumnValue(new TCell().setLongVal(partition.getRowCount())); + partitionInfos.add(Pair.of(partitionInfo, trow)); } } finally {