From 300197823cf3e6a1690b09c568d8f68602f44e37 Mon Sep 17 00:00:00 2001 From: LinMingQiang Date: Tue, 10 Dec 2024 01:31:09 +0800 Subject: [PATCH] [core] support summary system table to show tables detail info --- .../java/org/apache/paimon/table/system/SummaryTable.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/SummaryTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/SummaryTable.java index 44a41ba2d933..524e1f9ed0bb 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/system/SummaryTable.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/system/SummaryTable.java @@ -341,11 +341,11 @@ private void setPartitionSummary(GenericRow result) { private void setDataFilesSummary(GenericRow result) { // If the latest snapshot type is COMPACT, this will be exact, otherwise it is slightly // larger than the actual value, because these data are not merged. - long estimate_record_count = 0L; + long estimateRecordCount = 0L; long fileNums = 0L; long fileSizeInBytes = 0L; for (DataSplit dataSplit : storeTable.newSnapshotReader().read().dataSplits()) { - estimate_record_count += dataSplit.rowCount(); + estimateRecordCount += dataSplit.rowCount(); fileNums += dataSplit.dataFiles().size(); for (DataFileMeta dataFile : dataSplit.dataFiles()) { fileSizeInBytes += dataFile.fileSize(); @@ -353,7 +353,7 @@ private void setDataFilesSummary(GenericRow result) { } result.setField(17, fileNums); result.setField(18, fileSizeInBytes); - result.setField(19, estimate_record_count); + result.setField(19, estimateRecordCount); } private BinaryString toJson(Object obj) {