This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 1d1dc5d3b2a [HUDI-6623] Move the sorting of HoodieMetaserverClient
instants from meta server side to client side (#9331)
1d1dc5d3b2a is described below
commit 1d1dc5d3b2af3670bdd4be3a2c386e6d2e2a809f
Author: dongsj <[email protected]>
AuthorDate: Mon Sep 23 11:02:58 2024 +0800
[HUDI-6623] Move the sorting of HoodieMetaserverClient instants from meta
server side to client side (#9331)
Co-authored-by: dongsj <[email protected]>
Co-authored-by: Y Ethan Guo <[email protected]>
---
.../org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java
b/hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java
index eee1bb31ff8..56a6e6b2df6 100644
---
a/hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java
+++
b/hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/metaserver/client/HoodieMetaserverClientImp.java
@@ -38,6 +38,7 @@ import org.slf4j.LoggerFactory;
import java.net.URI;
import java.nio.ByteBuffer;
+import java.util.Comparator;
import java.util.List;
import java.util.function.Supplier;
import java.util.stream.Collectors;
@@ -110,6 +111,7 @@ public class HoodieMetaserverClientImp implements
HoodieMetaserverClient {
public List<HoodieInstant> listInstants(String db, String tb, int commitNum)
{
return exceptionWrapper(() -> this.client.listInstants(db, tb,
commitNum).stream()
.map(EntityConversions::fromTHoodieInstant)
+ .sorted(Comparator.comparing(HoodieInstant::getTimestamp).reversed())
.collect(Collectors.toList())).get();
}
