From 078b040d0267af61125ca4492313972d661ac4cc Mon Sep 17 00:00:00 2001 From: zhangliang <zhangliang@apache.org> Date: Wed, 22 Jan 2025 23:32:15 +0800 Subject: [PATCH] Rename ShardingSphereStatisticsNodePath --- .../service/metadata/table/TableRowDataPersistService.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/metadata/table/TableRowDataPersistService.java b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/metadata/table/TableRowDataPersistService.java index 5f3dac3ad8ce1..b4460d373deb8 100644 --- a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/metadata/table/TableRowDataPersistService.java +++ b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/service/metadata/table/TableRowDataPersistService.java @@ -50,7 +50,8 @@ public void persist(final String databaseName, final String schemaName, final St if (rows.isEmpty()) { repository.persist(ShardingSphereStatisticsNodePath.getTablePath(databaseName, schemaName, tableName.toLowerCase()), ""); } else { - rows.forEach(each -> repository.persist(ShardingSphereStatisticsNodePath.getTableRowPath(databaseName, schemaName, tableName.toLowerCase(), each.getUniqueKey()), YamlEngine.marshal(each))); + rows.forEach( + each -> repository.persist(ShardingSphereStatisticsNodePath.getTableRowPath(databaseName, schemaName, tableName.toLowerCase(), each.getUniqueKey()), YamlEngine.marshal(each))); } }