(paimon) branch master updated: [core] Refine CommitMessage toString (#4950)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 19cafb0479 [core] Refine CommitMessage toString (#4950)
19cafb0479 is described below

commit 19cafb0479ed66afd2cb2568c18e0ab0a3b9ed7d
Author: Xiaoguang Zhu <smd...@qq.com>
AuthorDate: Mon Jan 20 17:41:04 2025 +0800

    [core] Refine CommitMessage toString (#4950)
---
 .../main/java/org/apache/paimon/io/CompactIncrement.java   | 14 ++++----------
 .../src/main/java/org/apache/paimon/io/DataIncrement.java  |  9 ++++-----
 .../src/main/java/org/apache/paimon/io/IndexIncrement.java | 13 +++++++------
 3 files changed, 15 insertions(+), 21 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java 
b/paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java
index 23f64b5cd2..ad51642a2a 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/CompactIncrement.java
@@ -78,16 +78,10 @@ public class CompactIncrement {
     @Override
     public String toString() {
         return String.format(
-                "CompactIncrement {compactBefore = [\n%s\n], compactAfter = 
[\n%s\n], changelogFiles = [\n%s\n]}",
-                compactBefore.stream()
-                        .map(DataFileMeta::fileName)
-                        .collect(Collectors.joining(",\n")),
-                compactAfter.stream()
-                        .map(DataFileMeta::fileName)
-                        .collect(Collectors.joining(",\n")),
-                changelogFiles.stream()
-                        .map(DataFileMeta::fileName)
-                        .collect(Collectors.joining(",\n")));
+                "CompactIncrement {compactBefore = %s, compactAfter = %s, 
changelogFiles = %s}",
+                
compactBefore.stream().map(DataFileMeta::fileName).collect(Collectors.toList()),
+                
compactAfter.stream().map(DataFileMeta::fileName).collect(Collectors.toList()),
+                
changelogFiles.stream().map(DataFileMeta::fileName).collect(Collectors.toList()));
     }
 
     public static CompactIncrement emptyIncrement() {
diff --git a/paimon-core/src/main/java/org/apache/paimon/io/DataIncrement.java 
b/paimon-core/src/main/java/org/apache/paimon/io/DataIncrement.java
index f343940dfe..b7860fb15e 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/DataIncrement.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/DataIncrement.java
@@ -82,10 +82,9 @@ public class DataIncrement {
     @Override
     public String toString() {
         return String.format(
-                "NewFilesIncrement {newFiles = [\n%s\n], changelogFiles = 
[\n%s\n]}",
-                
newFiles.stream().map(DataFileMeta::fileName).collect(Collectors.joining(",\n")),
-                changelogFiles.stream()
-                        .map(DataFileMeta::fileName)
-                        .collect(Collectors.joining(",\n")));
+                "DataIncrement {newFiles = %s, deletedFiles = %s, 
changelogFiles = %s}",
+                
newFiles.stream().map(DataFileMeta::fileName).collect(Collectors.toList()),
+                
deletedFiles.stream().map(DataFileMeta::fileName).collect(Collectors.toList()),
+                
changelogFiles.stream().map(DataFileMeta::fileName).collect(Collectors.toList()));
     }
 }
diff --git a/paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java 
b/paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java
index 8e53adfbfc..9f985f54ed 100644
--- a/paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java
+++ b/paimon-core/src/main/java/org/apache/paimon/io/IndexIncrement.java
@@ -24,6 +24,7 @@ import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 /** Incremental index files. */
 public class IndexIncrement {
@@ -77,11 +78,11 @@ public class IndexIncrement {
 
     @Override
     public String toString() {
-        return "IndexIncrement{"
-                + "newIndexFiles="
-                + newIndexFiles
-                + ",deletedIndexFiles="
-                + deletedIndexFiles
-                + "}";
+        return String.format(
+                "IndexIncrement {newIndexFiles = %s, deletedIndexFiles = %s}",
+                
newIndexFiles.stream().map(IndexFileMeta::fileName).collect(Collectors.toList()),
+                deletedIndexFiles.stream()
+                        .map(IndexFileMeta::fileName)
+                        .collect(Collectors.toList()));
     }
 }