diff --git a/amoro-format-paimon/src/main/java/org/apache/amoro/formats/paimon/PaimonTableDescriptor.java b/amoro-format-paimon/src/main/java/org/apache/amoro/formats/paimon/PaimonTableDescriptor.java index 89f94b5713..473488f471 100644 --- a/amoro-format-paimon/src/main/java/org/apache/amoro/formats/paimon/PaimonTableDescriptor.java +++ b/amoro-format-paimon/src/main/java/org/apache/amoro/formats/paimon/PaimonTableDescriptor.java @@ -141,7 +141,7 @@ public ServerTableMeta getTableDetail(AmoroTable amoroTable) { Snapshot snapshot = store.snapshotManager().latestSnapshot(); if (snapshot != null) { AmoroSnapshotsOfTable snapshotsOfTable = - manifestListInfo(store, snapshot, (m, s) -> s.dataManifests(m)); + manifestListInfo(store, snapshot, ManifestList::readDataManifests); long fileSize = snapshotsOfTable.getOriginalFileSize(); String totalSize = CommonUtil.byteToXB(fileSize); int fileCount = snapshotsOfTable.getFileCount(); @@ -231,7 +231,7 @@ public List getSnapshotDetail( ManifestList manifestList = store.manifestListFactory().create(); ManifestFile manifestFile = store.manifestFileFactory().create(); - List manifestFileMetas = snapshot.deltaManifests(manifestList); + List manifestFileMetas = manifestList.readDeltaManifests(snapshot); for (ManifestFileMeta manifestFileMeta : manifestFileMetas) { manifestFileMeta.fileSize(); List manifestEntries = manifestFile.read(manifestFileMeta.fileName()); @@ -313,7 +313,7 @@ public List getTableFiles( futures.add( CompletableFuture.runAsync( () -> { - List deltaManifests = snapshot.deltaManifests(manifestList); + List deltaManifests = manifestList.readDeltaManifests(snapshot); for (ManifestFileMeta manifestFileMeta : deltaManifests) { List manifestEntries = manifestFile.read(manifestFileMeta.fileName()); @@ -392,7 +392,7 @@ public Pair, Integer> getOptimizingProcessesInfo( FilesStatisticsBuilder outputBuilder = new FilesStatisticsBuilder(); ManifestFile manifestFile = store.manifestFileFactory().create(); ManifestList manifestList = store.manifestListFactory().create(); - List manifestFileMetas = s.deltaManifests(manifestList); + List manifestFileMetas = manifestList.readDeltaManifests(s); boolean hasMaxLevels = false; long minCreateTime = Long.MAX_VALUE; long maxCreateTime = Long.MIN_VALUE; @@ -469,12 +469,12 @@ private AmoroSnapshotsOfTable getSnapshotsOfTable(FileStore store, Snapshot s // file number AmoroSnapshotsOfTable deltaSnapshotsOfTable = - manifestListInfo(store, snapshot, (m, s) -> s.deltaManifests(m)); + manifestListInfo(store, snapshot, ManifestList::readDeltaManifests); int deltaFileCount = deltaSnapshotsOfTable.getFileCount(); int dataFileCount = - manifestListInfo(store, snapshot, (m, s) -> s.dataManifests(m)).getFileCount(); - int changeLogFileCount = - manifestListInfo(store, snapshot, (m, s) -> s.changelogManifests(m)).getFileCount(); + manifestListInfo(store, snapshot, ManifestList::readDataManifests).getFileCount(); + long changeLogFileCount = + manifestListInfo(store, snapshot, ManifestList::readChangelogManifests).getFileCount(); summary.put("delta-files", String.valueOf(deltaFileCount)); summary.put("data-files", String.valueOf(dataFileCount)); summary.put("changelogs", String.valueOf(changeLogFileCount)); diff --git a/pom.xml b/pom.xml index 6250669cf0..2b7290b220 100644 --- a/pom.xml +++ b/pom.xml @@ -102,7 +102,7 @@ 3.3.1 1.4.3 - 0.8.2 + 0.9.0 3.1.1 3.4.0 2.0.3